File tree Expand file tree Collapse file tree 1 file changed +5
-5
lines changed
sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/expressions Expand file tree Collapse file tree 1 file changed +5
-5
lines changed Original file line number Diff line number Diff 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 }
You can’t perform that action at this time.
0 commit comments