Fix evaluated value type of ApproxCountDistinctMergeFunction to Int.

ueshin · ueshin · commit fc3ac0f91e26 · 2014-05-27T19:22:33.000+09:00
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregates.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregates.scala
@@ -340,7 +340,7 @@ case class ApproxCountDistinctMergeFunction(
     hyperLogLog.addAll(evaluatedExpr.asInstanceOf[HyperLogLog])
   }
 
-  override def eval(input: Row): Any = hyperLogLog.cardinality()
+  override def eval(input: Row): Any = hyperLogLog.cardinality().toInt
 }
 
 case class SumFunction(expr: Expression, base: AggregateExpression) extends AggregateFunction {

Original file line number	Diff line number	Diff line change
`@@ -340,7 +340,7 @@ case class ApproxCountDistinctMergeFunction(`
`340`	`340`	`hyperLogLog.addAll(evaluatedExpr.asInstanceOf[HyperLogLog])`
`341`	`341`	`}`
`342`	`342`
`343`		`- override def eval(input: Row): Any = hyperLogLog.cardinality()`
	`343`	`+ override def eval(input: Row): Any = hyperLogLog.cardinality().toInt`
`344`	`344`	`}`
`345`	`345`
`346`	`346`	`case class SumFunction(expr: Expression, base: AggregateExpression) extends AggregateFunction {`