You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by jl...@apache.org on 2024/02/01 03:10:05 UTC
(pinot) 01/01: Fix backward compatible issue in DistinctCountThetaSketchAggregationFunction
This is an automated email from the ASF dual-hosted git repository.
jlli pushed a commit to branch fix-DistinctCountThetaSketchAggregationFunction
in repository https://gitbox.apache.org/repos/asf/pinot.git
commit 577e5e2c58c26fa16ac7a692c0741ed47033cc63
Author: jlli_LinkedIn <jl...@linkedin.com>
AuthorDate: Wed Jan 31 19:09:32 2024 -0800
Fix backward compatible issue in DistinctCountThetaSketchAggregationFunction
---
.../function/DistinctCountThetaSketchAggregationFunction.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/DistinctCountThetaSketchAggregationFunction.java b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/DistinctCountThetaSketchAggregationFunction.java
index 83709857f9..34afe70d37 100644
--- a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/DistinctCountThetaSketchAggregationFunction.java
+++ b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/DistinctCountThetaSketchAggregationFunction.java
@@ -1024,7 +1024,8 @@ public class DistinctCountThetaSketchAggregationFunction
int numAccumulators = accumulators.size();
List<Sketch> mergedSketches = new ArrayList<>(numAccumulators);
- for (ThetaSketchAccumulator accumulator : accumulators) {
+ for (Object accumulatorObject : accumulators) {
+ ThetaSketchAccumulator accumulator = convertSketchAccumulator(accumulatorObject);
accumulator.setThreshold(_accumulatorThreshold);
accumulator.setSetOperationBuilder(_setOperationBuilder);
mergedSketches.add(accumulator.getResult());
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org