diff --git a/pydruid/utils/aggregators.py b/pydruid/utils/aggregators.py index 23caa826..d677319d 100644 --- a/pydruid/utils/aggregators.py +++ b/pydruid/utils/aggregators.py @@ -39,6 +39,10 @@ def max(raw_metric): return {"type": "max", "fieldName": raw_metric} +def longlast(raw_metric): + return {"type": "longLast", "fieldName": raw_metric} + + def longsum(raw_metric): return {"type": "longSum", "fieldName": raw_metric} @@ -51,6 +55,10 @@ def longmax(raw_metric): return {"type": "longMax", "fieldName": raw_metric} +def doublelast(raw_metric): + return {"type": "doubleLast", "fieldName": raw_metric} + + def doublesum(raw_metric): return {"type": "doubleSum", "fieldName": raw_metric}