for JS count Aggs, do a postAgg Sum in Spark

hbutani · Sep 16, 2016 · a44c81c · a44c81c
1 parent b6092c5
commit a44c81c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/scala/org/apache/spark/sql/sources/druid/PostAggregate.scala b/src/main/scala/org/apache/spark/sql/sources/druid/PostAggregate.scala
@@ -54,7 +54,7 @@ class PostAggregate(val druidOpSchema : DruidOperatorSchema) {
       case JavascriptAggregationSpec(_, aggnm, _, _, _, _) if aggnm.startsWith("SUM") =>
         Some(Sum(attrRef(dOpAttr)))
       case JavascriptAggregationSpec(_, aggnm, _, _, _, _) if aggnm.startsWith("COUNT") =>
-        Some(Count(attrRef(dOpAttr)))
+        Some(Sum(attrRef(dOpAttr)))
       case _ => None
     }
   }