diff --git a/processing/src/main/java/io/druid/query/topn/AggregateTopNMetricFirstAlgorithm.java b/processing/src/main/java/io/druid/query/topn/AggregateTopNMetricFirstAlgorithm.java index cd1a60e72fc..c826ce2333b 100644 --- a/processing/src/main/java/io/druid/query/topn/AggregateTopNMetricFirstAlgorithm.java +++ b/processing/src/main/java/io/druid/query/topn/AggregateTopNMetricFirstAlgorithm.java @@ -65,7 +65,7 @@ public class AggregateTopNMetricFirstAlgorithm implements TopNAlgorithm public TopNParams makeInitParams(DimensionSelector dimSelector, Cursor cursor); - public TopNResultBuilder makeResultBuilder(Parameters params); + public TopNResultBuilder makeResultBuilder(Parameters params, TopNQuery query); public void run( Parameters params, diff --git a/processing/src/main/java/io/druid/query/topn/TopNMapFn.java b/processing/src/main/java/io/druid/query/topn/TopNMapFn.java index c013d546f7f..c51b63cd539 100644 --- a/processing/src/main/java/io/druid/query/topn/TopNMapFn.java +++ b/processing/src/main/java/io/druid/query/topn/TopNMapFn.java @@ -52,7 +52,7 @@ public class TopNMapFn implements Function> try { params = topNAlgorithm.makeInitParams(dimSelector, cursor); - TopNResultBuilder resultBuilder = topNAlgorithm.makeResultBuilder(params); + TopNResultBuilder resultBuilder = topNAlgorithm.makeResultBuilder(params, query); topNAlgorithm.run(params, resultBuilder, null);