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:04 UTC
(pinot) branch fix-DistinctCountThetaSketchAggregationFunction created (now 577e5e2c58)
This is an automated email from the ASF dual-hosted git repository.
jlli pushed a change to branch fix-DistinctCountThetaSketchAggregationFunction
in repository https://gitbox.apache.org/repos/asf/pinot.git
at 577e5e2c58 Fix backward compatible issue in DistinctCountThetaSketchAggregationFunction
This branch includes the following new commits:
new 577e5e2c58 Fix backward compatible issue in DistinctCountThetaSketchAggregationFunction
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org
(pinot) 01/01: Fix backward compatible issue in DistinctCountThetaSketchAggregationFunction
Posted by jl...@apache.org.
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