diff --git a/pydruid/utils/aggregators.py b/pydruid/utils/aggregators.py index cfda1baa..6f023692 100644 --- a/pydruid/utils/aggregators.py +++ b/pydruid/utils/aggregators.py @@ -34,6 +34,8 @@ def max(raw_metric): def count(raw_metric): return {"type": "count", "fieldName": raw_metric} +def hyperunique(raw_metric): + return {"type": "hyperUnique", "fieldName": raw_metric} def build_aggregators(agg_input): return [dict([('name', k)] + v.items())