Skip to content

Commit d95824b

Browse files
committed
Apply comments
1 parent 2feb984 commit d95824b

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/expressions/CodeGenerationSuite.scala

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -110,12 +110,12 @@ class CodeGenerationSuite extends SparkFunSuite with ExpressionEvalHelper {
110110
case (expr, i) => Seq(Literal(i), expr)
111111
}))
112112
val plan = GenerateMutableProjection.generate(expressions)
113-
val actual = plan(new GenericMutableRow(length)).toSeq(expressions.map(_.dataType))
114-
val expected = Seq(new ArrayBasedMapData(
115-
new GenericArrayData(0 until length),
116-
new GenericArrayData(Seq.fill(length)(true))))
113+
val actual = plan(new GenericMutableRow(length)).toSeq(expressions.map(_.dataType)).map {
114+
case m: ArrayBasedMapData => ArrayBasedMapData.toScalaMap(m)
115+
}
116+
val expected = (0 until length).map((_, true)).toMap :: Nil
117117

118-
if (!actual.zip(expected).forall { case (data, answer) => checkResult(data, answer)}) {
118+
if (!checkResult(actual, expected)) {
119119
fail(s"Incorrect Evaluation: expressions: $expressions, actual: $actual, expected: $expected")
120120
}
121121
}

0 commit comments

Comments
 (0)