This is an automated email from the ASF dual-hosted git repository.
jackie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
The following commit(s) were added to refs/heads/master by this push:
new 28894e4 Remove AggregationFunction.isIntermediateResultComparable()
(#7640)
28894e4 is described below
commit 28894e4dae02965cd2136bb286a13b47b57bf02b
Author: weixiangsun <[email protected]>
AuthorDate: Tue Oct 26 13:10:10 2021 -0700
Remove AggregationFunction.isIntermediateResultComparable() (#7640)
---
.../pinot/core/query/aggregation/function/AggregationFunction.java | 5 -----
.../core/query/aggregation/function/AvgAggregationFunction.java | 5 -----
.../core/query/aggregation/function/CountAggregationFunction.java | 5 -----
.../core/query/aggregation/function/DistinctAggregationFunction.java | 5 -----
.../query/aggregation/function/DistinctCountAggregationFunction.java | 5 -----
.../aggregation/function/DistinctCountBitmapAggregationFunction.java | 5 -----
.../aggregation/function/DistinctCountHLLAggregationFunction.java | 5 -----
.../aggregation/function/DistinctCountRawHLLAggregationFunction.java | 5 -----
.../function/DistinctCountThetaSketchAggregationFunction.java | 5 -----
.../core/query/aggregation/function/FastHLLAggregationFunction.java | 5 -----
.../core/query/aggregation/function/IdSetAggregationFunction.java | 5 -----
.../query/aggregation/function/LastWithTimeAggregationFunction.java | 5 -----
.../core/query/aggregation/function/MaxAggregationFunction.java | 5 -----
.../core/query/aggregation/function/MinAggregationFunction.java | 5 -----
.../query/aggregation/function/MinMaxRangeAggregationFunction.java | 5 -----
.../core/query/aggregation/function/ModeAggregationFunction.java | 5 -----
.../query/aggregation/function/PercentileAggregationFunction.java | 5 -----
.../query/aggregation/function/PercentileEstAggregationFunction.java | 5 -----
.../aggregation/function/PercentileRawEstAggregationFunction.java | 5 -----
.../function/PercentileRawTDigestAggregationFunction.java | 5 -----
.../aggregation/function/PercentileTDigestAggregationFunction.java | 5 -----
.../function/SegmentPartitionedDistinctCountAggregationFunction.java | 5 -----
.../core/query/aggregation/function/StUnionAggregationFunction.java | 5 -----
.../core/query/aggregation/function/SumAggregationFunction.java | 5 -----
.../query/aggregation/function/SumPrecisionAggregationFunction.java | 5 -----
.../query/aggregation/groupby/AggregationGroupByTrimmingService.java | 3 ++-
26 files changed, 2 insertions(+), 126 deletions(-)
diff --git
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/AggregationFunction.java
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/AggregationFunction.java
index 38d49bb..17c3b48 100644
---
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/AggregationFunction.java
+++
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/AggregationFunction.java
@@ -112,11 +112,6 @@ public interface AggregationFunction<IntermediateResult,
FinalResult extends Com
IntermediateResult merge(IntermediateResult intermediateResult1,
IntermediateResult intermediateResult2);
/**
- * Returns whether the intermediate result is comparable.
- */
- boolean isIntermediateResultComparable();
-
- /**
* Returns the {@link ColumnDataType} of the intermediate result.
* <p>This column data type is used for transferring data in data table.
*/
diff --git
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/AvgAggregationFunction.java
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/AvgAggregationFunction.java
index 6dad935..8a2af50 100644
---
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/AvgAggregationFunction.java
+++
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/AvgAggregationFunction.java
@@ -172,11 +172,6 @@ public class AvgAggregationFunction extends
BaseSingleInputAggregationFunction<A
}
@Override
- public boolean isIntermediateResultComparable() {
- return true;
- }
-
- @Override
public ColumnDataType getIntermediateResultColumnType() {
return ColumnDataType.OBJECT;
}
diff --git
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/CountAggregationFunction.java
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/CountAggregationFunction.java
index 0183433..4175799 100644
---
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/CountAggregationFunction.java
+++
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/CountAggregationFunction.java
@@ -141,11 +141,6 @@ public class CountAggregationFunction implements
AggregationFunction<Long, Long>
}
@Override
- public boolean isIntermediateResultComparable() {
- return true;
- }
-
- @Override
public ColumnDataType getIntermediateResultColumnType() {
return ColumnDataType.LONG;
}
diff --git
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/DistinctAggregationFunction.java
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/DistinctAggregationFunction.java
index b3a3634..968b91d 100644
---
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/DistinctAggregationFunction.java
+++
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/DistinctAggregationFunction.java
@@ -143,11 +143,6 @@ public class DistinctAggregationFunction implements
AggregationFunction<Object,
}
@Override
- public boolean isIntermediateResultComparable() {
- throw new UnsupportedOperationException("Operation not supported for
DISTINCT aggregation function");
- }
-
- @Override
public ColumnDataType getFinalResultColumnType() {
throw new UnsupportedOperationException("Operation not supported for
DISTINCT aggregation function");
}
diff --git
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/DistinctCountAggregationFunction.java
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/DistinctCountAggregationFunction.java
index 6431530..315e2a5 100644
---
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/DistinctCountAggregationFunction.java
+++
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/DistinctCountAggregationFunction.java
@@ -295,11 +295,6 @@ public class DistinctCountAggregationFunction extends
BaseSingleInputAggregation
}
@Override
- public boolean isIntermediateResultComparable() {
- return false;
- }
-
- @Override
public ColumnDataType getIntermediateResultColumnType() {
return ColumnDataType.OBJECT;
}
diff --git
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/DistinctCountBitmapAggregationFunction.java
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/DistinctCountBitmapAggregationFunction.java
index 92f59b7..b7ffe02 100644
---
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/DistinctCountBitmapAggregationFunction.java
+++
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/DistinctCountBitmapAggregationFunction.java
@@ -310,11 +310,6 @@ public class DistinctCountBitmapAggregationFunction
extends BaseSingleInputAggre
}
@Override
- public boolean isIntermediateResultComparable() {
- return false;
- }
-
- @Override
public ColumnDataType getIntermediateResultColumnType() {
return ColumnDataType.OBJECT;
}
diff --git
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/DistinctCountHLLAggregationFunction.java
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/DistinctCountHLLAggregationFunction.java
index 41ca0ab..c1d4f5b 100644
---
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/DistinctCountHLLAggregationFunction.java
+++
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/DistinctCountHLLAggregationFunction.java
@@ -307,11 +307,6 @@ public class DistinctCountHLLAggregationFunction extends
BaseSingleInputAggregat
}
@Override
- public boolean isIntermediateResultComparable() {
- return false;
- }
-
- @Override
public ColumnDataType getIntermediateResultColumnType() {
return ColumnDataType.OBJECT;
}
diff --git
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/DistinctCountRawHLLAggregationFunction.java
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/DistinctCountRawHLLAggregationFunction.java
index 2e0244e..d22672c 100644
---
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/DistinctCountRawHLLAggregationFunction.java
+++
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/DistinctCountRawHLLAggregationFunction.java
@@ -94,11 +94,6 @@ public class DistinctCountRawHLLAggregationFunction
}
@Override
- public boolean isIntermediateResultComparable() {
- return
_distinctCountHLLAggregationFunction.isIntermediateResultComparable();
- }
-
- @Override
public ColumnDataType getIntermediateResultColumnType() {
return
_distinctCountHLLAggregationFunction.getIntermediateResultColumnType();
}
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 bc1c9e8..10f88eb 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
@@ -977,11 +977,6 @@ public class DistinctCountThetaSketchAggregationFunction
}
@Override
- public boolean isIntermediateResultComparable() {
- return false;
- }
-
- @Override
public ColumnDataType getIntermediateResultColumnType() {
return ColumnDataType.OBJECT;
}
diff --git
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/FastHLLAggregationFunction.java
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/FastHLLAggregationFunction.java
index 202e5a8..009ee98 100644
---
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/FastHLLAggregationFunction.java
+++
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/FastHLLAggregationFunction.java
@@ -164,11 +164,6 @@ public class FastHLLAggregationFunction extends
BaseSingleInputAggregationFuncti
}
@Override
- public boolean isIntermediateResultComparable() {
- return false;
- }
-
- @Override
public ColumnDataType getIntermediateResultColumnType() {
return ColumnDataType.OBJECT;
}
diff --git
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/IdSetAggregationFunction.java
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/IdSetAggregationFunction.java
index a72882c..a6e6b34 100644
---
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/IdSetAggregationFunction.java
+++
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/IdSetAggregationFunction.java
@@ -469,11 +469,6 @@ public class IdSetAggregationFunction extends
BaseSingleInputAggregationFunction
}
@Override
- public boolean isIntermediateResultComparable() {
- return false;
- }
-
- @Override
public ColumnDataType getIntermediateResultColumnType() {
return ColumnDataType.OBJECT;
}
diff --git
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/LastWithTimeAggregationFunction.java
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/LastWithTimeAggregationFunction.java
index adc91da..cd4b057 100644
---
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/LastWithTimeAggregationFunction.java
+++
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/LastWithTimeAggregationFunction.java
@@ -211,11 +211,6 @@ public abstract class LastWithTimeAggregationFunction<V
extends Comparable<V>>
}
@Override
- public boolean isIntermediateResultComparable() {
- return false;
- }
-
- @Override
public ColumnDataType getIntermediateResultColumnType() {
return ColumnDataType.OBJECT;
}
diff --git
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/MaxAggregationFunction.java
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/MaxAggregationFunction.java
index dd23df8..7fc4130 100644
---
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/MaxAggregationFunction.java
+++
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/MaxAggregationFunction.java
@@ -112,11 +112,6 @@ public class MaxAggregationFunction extends
BaseSingleInputAggregationFunction<D
}
@Override
- public boolean isIntermediateResultComparable() {
- return true;
- }
-
- @Override
public ColumnDataType getIntermediateResultColumnType() {
return ColumnDataType.DOUBLE;
}
diff --git
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/MinAggregationFunction.java
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/MinAggregationFunction.java
index 2716992..5b820d9 100644
---
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/MinAggregationFunction.java
+++
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/MinAggregationFunction.java
@@ -112,11 +112,6 @@ public class MinAggregationFunction extends
BaseSingleInputAggregationFunction<D
}
@Override
- public boolean isIntermediateResultComparable() {
- return true;
- }
-
- @Override
public ColumnDataType getIntermediateResultColumnType() {
return ColumnDataType.DOUBLE;
}
diff --git
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/MinMaxRangeAggregationFunction.java
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/MinMaxRangeAggregationFunction.java
index 156a244..f0bcf93 100644
---
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/MinMaxRangeAggregationFunction.java
+++
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/MinMaxRangeAggregationFunction.java
@@ -180,11 +180,6 @@ public class MinMaxRangeAggregationFunction extends
BaseSingleInputAggregationFu
}
@Override
- public boolean isIntermediateResultComparable() {
- return true;
- }
-
- @Override
public ColumnDataType getIntermediateResultColumnType() {
return ColumnDataType.OBJECT;
}
diff --git
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/ModeAggregationFunction.java
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/ModeAggregationFunction.java
index fbbca04..ffc14e4 100644
---
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/ModeAggregationFunction.java
+++
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/ModeAggregationFunction.java
@@ -455,11 +455,6 @@ public class ModeAggregationFunction extends
BaseSingleInputAggregationFunction<
}
@Override
- public boolean isIntermediateResultComparable() {
- return false;
- }
-
- @Override
public ColumnDataType getIntermediateResultColumnType() {
return ColumnDataType.OBJECT;
}
diff --git
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/PercentileAggregationFunction.java
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/PercentileAggregationFunction.java
index 57f9eb1..8bfca2e 100644
---
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/PercentileAggregationFunction.java
+++
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/PercentileAggregationFunction.java
@@ -139,11 +139,6 @@ public class PercentileAggregationFunction extends
BaseSingleInputAggregationFun
}
@Override
- public boolean isIntermediateResultComparable() {
- return false;
- }
-
- @Override
public ColumnDataType getIntermediateResultColumnType() {
return ColumnDataType.OBJECT;
}
diff --git
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/PercentileEstAggregationFunction.java
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/PercentileEstAggregationFunction.java
index d7d828a..ba815c4 100644
---
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/PercentileEstAggregationFunction.java
+++
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/PercentileEstAggregationFunction.java
@@ -197,11 +197,6 @@ public class PercentileEstAggregationFunction extends
BaseSingleInputAggregation
}
@Override
- public boolean isIntermediateResultComparable() {
- return false;
- }
-
- @Override
public ColumnDataType getIntermediateResultColumnType() {
return ColumnDataType.OBJECT;
}
diff --git
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/PercentileRawEstAggregationFunction.java
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/PercentileRawEstAggregationFunction.java
index dc5d435..1922d74 100644
---
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/PercentileRawEstAggregationFunction.java
+++
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/PercentileRawEstAggregationFunction.java
@@ -120,11 +120,6 @@ public class PercentileRawEstAggregationFunction
}
@Override
- public boolean isIntermediateResultComparable() {
- return _percentileEstAggregationFunction.isIntermediateResultComparable();
- }
-
- @Override
public ColumnDataType getIntermediateResultColumnType() {
return _percentileEstAggregationFunction.getIntermediateResultColumnType();
}
diff --git
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/PercentileRawTDigestAggregationFunction.java
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/PercentileRawTDigestAggregationFunction.java
index 2724b21..0efbef2 100644
---
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/PercentileRawTDigestAggregationFunction.java
+++
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/PercentileRawTDigestAggregationFunction.java
@@ -121,11 +121,6 @@ public class PercentileRawTDigestAggregationFunction
}
@Override
- public boolean isIntermediateResultComparable() {
- return
_percentileTDigestAggregationFunction.isIntermediateResultComparable();
- }
-
- @Override
public ColumnDataType getIntermediateResultColumnType() {
return
_percentileTDigestAggregationFunction.getIntermediateResultColumnType();
}
diff --git
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/PercentileTDigestAggregationFunction.java
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/PercentileTDigestAggregationFunction.java
index 56eb9c0..9ba5101 100644
---
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/PercentileTDigestAggregationFunction.java
+++
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/PercentileTDigestAggregationFunction.java
@@ -200,11 +200,6 @@ public class PercentileTDigestAggregationFunction extends
BaseSingleInputAggrega
}
@Override
- public boolean isIntermediateResultComparable() {
- return false;
- }
-
- @Override
public ColumnDataType getIntermediateResultColumnType() {
return ColumnDataType.OBJECT;
}
diff --git
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/SegmentPartitionedDistinctCountAggregationFunction.java
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/SegmentPartitionedDistinctCountAggregationFunction.java
index 086d786..f273fa8 100644
---
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/SegmentPartitionedDistinctCountAggregationFunction.java
+++
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/SegmentPartitionedDistinctCountAggregationFunction.java
@@ -313,11 +313,6 @@ public class
SegmentPartitionedDistinctCountAggregationFunction extends BaseSing
}
@Override
- public boolean isIntermediateResultComparable() {
- return true;
- }
-
- @Override
public ColumnDataType getIntermediateResultColumnType() {
return ColumnDataType.LONG;
}
diff --git
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/StUnionAggregationFunction.java
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/StUnionAggregationFunction.java
index a3ef12e..0e0ff6f 100644
---
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/StUnionAggregationFunction.java
+++
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/StUnionAggregationFunction.java
@@ -114,11 +114,6 @@ public class StUnionAggregationFunction extends
BaseSingleInputAggregationFuncti
}
@Override
- public boolean isIntermediateResultComparable() {
- return false;
- }
-
- @Override
public DataSchema.ColumnDataType getIntermediateResultColumnType() {
return DataSchema.ColumnDataType.OBJECT;
}
diff --git
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/SumAggregationFunction.java
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/SumAggregationFunction.java
index 157c5ca..b5b3b01 100644
---
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/SumAggregationFunction.java
+++
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/SumAggregationFunction.java
@@ -100,11 +100,6 @@ public class SumAggregationFunction extends
BaseSingleInputAggregationFunction<D
}
@Override
- public boolean isIntermediateResultComparable() {
- return true;
- }
-
- @Override
public ColumnDataType getIntermediateResultColumnType() {
return ColumnDataType.DOUBLE;
}
diff --git
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/SumPrecisionAggregationFunction.java
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/SumPrecisionAggregationFunction.java
index 798ee50..20fb335 100644
---
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/SumPrecisionAggregationFunction.java
+++
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/SumPrecisionAggregationFunction.java
@@ -240,11 +240,6 @@ public class SumPrecisionAggregationFunction extends
BaseSingleInputAggregationF
}
@Override
- public boolean isIntermediateResultComparable() {
- return true;
- }
-
- @Override
public ColumnDataType getIntermediateResultColumnType() {
return ColumnDataType.OBJECT;
}
diff --git
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/groupby/AggregationGroupByTrimmingService.java
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/groupby/AggregationGroupByTrimmingService.java
index 23fdd59..d253389 100644
---
a/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/groupby/AggregationGroupByTrimmingService.java
+++
b/pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/groupby/AggregationGroupByTrimmingService.java
@@ -82,7 +82,8 @@ public class AggregationGroupByTrimmingService {
Sorter[] sorters = new Sorter[numAggregationFunctions];
for (int i = 0; i < numAggregationFunctions; i++) {
AggregationFunction aggregationFunction = _aggregationFunctions[i];
- sorters[i] = getSorter(_trimSize, aggregationFunction,
aggregationFunction.isIntermediateResultComparable());
+ // Assume the intermediate result may not be comparable.
+ sorters[i] = getSorter(_trimSize, aggregationFunction, false);
}
// Add results into sorters
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
