fix a mistake

apache · Jan 22, 2018 · 0c22f5b · 0c22f5b
1 parent 55a288e
commit 0c22f5b
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/.../src/main/scala/org/apache/spark/sql/execution/aggregate/VectorizedHashMapGenerator.scala b/.../src/main/scala/org/apache/spark/sql/execution/aggregate/VectorizedHashMapGenerator.scala
@@ -127,9 +127,7 @@ class VectorizedHashMapGenerator(
 
     def genEqualsForKeys(groupingKeys: Seq[Buffer]): String = {
       groupingKeys.zipWithIndex.map { case (key: Buffer, ordinal: Int) =>
-        // `ColumnVector.getStruct` is different from `InternalRow.getStruct`, it only takes an
-        // `ordinal` parameter.
-        val value = ctx.getValue(s"vectors[$ordinal]", key.dataType, "buckets[idx]")
+        val value = ctx.getValueFromVector(s"vectors[$ordinal]", key.dataType, "buckets[idx]")
         s"(${ctx.genEqual(key.dataType, value, key.name)})"
       }.mkString(" && ")
     }