Github user viirya commented on a diff in the pull request:
https://github.com/apache/spark/pull/19869#discussion_r154580311
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/HashAggregateExec.scala
---
@@ -596,7 +596,7 @@ case class HashAggregateExec(
ctx.addMutableState(fastHashMapClassName, fastHashMapTerm,
s"$fastHashMapTerm = new $fastHashMapClassName();")
ctx.addMutableState(
- classOf[java.util.Iterator[ColumnarRow]].getName,
+ s"java.util.Iterator<${classOf[ColumnarRow]}>",
--- End diff --
```scala
scala> s"java.util.Iterator<${classOf[ColumnarRow]}>"
res2: String = java.util.Iterator<class
org.apache.spark.sql.execution.vectorized.ColumnarRow>
```
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
