Github user ueshin commented on a diff in the pull request:
https://github.com/apache/spark/pull/22044#discussion_r208849675
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/collectionOperations.scala
---
@@ -3410,6 +3410,28 @@ case class ArrayDistinct(child: Expression)
case _ => false
}
+ @transient protected lazy val canUseSpecializedHashSet = elementType
match {
+ case ByteType | ShortType | IntegerType | LongType | FloatType |
DoubleType => true
+ case _ => false
+ }
+
+ @transient protected lazy val (hsPostFix, hsTypeName) = {
+ val ptName = CodeGenerator.primitiveTypeName (elementType)
--- End diff --
nit: extra space after `primitiveTypeName`.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
