Add JavaScript aggregator support (druid-io#50)

atomx · May 21, 2016 · 8b30ade · 8b30ade
1 parent c362861
commit 8b30ade
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/pydruid/utils/aggregators.py b/pydruid/utils/aggregators.py
@@ -53,6 +53,12 @@ def filtered(filter, agg):
             "filter": Filter.build_filter(filter),
             "aggregator": agg}
 
+def javascript(columns_list, fn_aggregate, fn_combine, fn_reset):
+    return {"type": "javascript",
+            "fieldNames": columns_list,
+            "fnAggregate":fn_aggregate,
+            "fnCombine":fn_combine,
+            "fnReset":fn_reset}
 
 def build_aggregators(agg_input):
     return [_build_aggregator(name, kwargs)