This is an automated email from the ASF dual-hosted git repository.
Jackie-Jiang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
from a2f96c487ec Always support nulls in DataTable serialization (#19201)
add 411bdc804c5 Document and enforce the AggregationFunction null contract
(#19158)
No new revisions were added by this update.
Summary of changes:
.../requesthandler/EmptyResponseUtilsTest.java | 24 ++
.../apache/pinot/core/data/table/IndexedTable.java | 8 +-
.../pinot/core/data/table/SortedRecordsMerger.java | 4 +-
.../merger/AggregationResultsBlockMerger.java | 4 +-
.../aggregation/function/AggregationFunction.java | 148 ++++++-
.../function/AggregationFunctionFactory.java | 41 +-
.../function/AggregationFunctionUtils.java | 30 ++
.../function/AnyValueAggregationFunction.java | 9 +-
.../function/AvgAggregationFunction.java | 31 +-
.../function/AvgMVAggregationFunction.java | 40 --
...ValueIntegerTupleSketchAggregationFunction.java | 8 +-
.../function/BaseBooleanAggregationFunction.java | 36 +-
.../BaseDistinctAggregateAggregationFunction.java | 9 +-
.../function/ChildAggregationFunction.java | 3 +-
.../function/CovarianceAggregationFunction.java | 12 +-
.../function/DistinctAvgAggregationFunction.java | 18 +-
.../function/DistinctAvgMVAggregationFunction.java | 48 +--
.../function/DistinctCountAggregationFunction.java | 9 +-
.../DistinctCountBitmapAggregationFunction.java | 1 -
.../DistinctCountBitmapMVAggregationFunction.java | 30 --
.../DistinctCountCPCSketchAggregationFunction.java | 5 +-
.../DistinctCountHLLAggregationFunction.java | 1 -
.../DistinctCountHLLMVAggregationFunction.java | 27 --
.../DistinctCountHLLPlusAggregationFunction.java | 1 -
.../DistinctCountHLLPlusMVAggregationFunction.java | 27 --
.../DistinctCountMVAggregationFunction.java | 49 +--
.../DistinctCountOffHeapAggregationFunction.java | 4 +-
...stinctCountSmartHLLPlusAggregationFunction.java | 17 +-
.../DistinctCountSmartULLAggregationFunction.java | 3 +-
...istinctCountThetaSketchAggregationFunction.java | 1 -
.../DistinctCountULLAggregationFunction.java | 10 +-
.../function/DistinctSumAggregationFunction.java | 18 +-
.../function/DistinctSumMVAggregationFunction.java | 53 +--
.../function/FastHLLAggregationFunction.java | 6 +-
.../function/FirstWithTimeAggregationFunction.java | 7 +-
.../function/FourthMomentAggregationFunction.java | 4 +-
.../FrequentLongsSketchAggregationFunction.java | 17 +-
.../FrequentStringsSketchAggregationFunction.java | 17 +-
.../function/HistogramAggregationFunction.java | 5 +-
.../function/IdSetAggregationFunction.java | 8 +-
.../IntegerTupleSketchAggregationFunction.java | 5 +-
.../function/LastWithTimeAggregationFunction.java | 7 +-
.../function/MaxAggregationFunction.java | 15 +-
.../function/MaxLongAggregationFunction.java | 15 +-
.../function/MaxMVAggregationFunction.java | 22 --
.../function/MaxStringAggregationFunction.java | 13 +-
.../function/MinAggregationFunction.java | 15 +-
.../function/MinLongAggregationFunction.java | 15 +-
.../function/MinMVAggregationFunction.java | 22 --
.../function/MinMaxRangeAggregationFunction.java | 33 +-
.../function/MinMaxRangeMVAggregationFunction.java | 28 --
.../function/MinStringAggregationFunction.java | 13 +-
.../function/ModeAggregationFunction.java | 9 +-
.../ParentExprMinMaxAggregationFunction.java | 5 +-
.../function/PercentileAggregationFunction.java | 43 +-
.../function/PercentileEstAggregationFunction.java | 25 +-
.../PercentileEstMVAggregationFunction.java | 32 +-
.../function/PercentileKLLAggregationFunction.java | 17 +-
.../PercentileKLLMVAggregationFunction.java | 27 +-
.../function/PercentileMVAggregationFunction.java | 31 +-
.../PercentileRawEstAggregationFunction.java | 12 +-
.../PercentileRawEstMVAggregationFunction.java | 14 +-
.../PercentileRawKLLAggregationFunction.java | 9 +-
.../PercentileRawKLLMVAggregationFunction.java | 13 +-
.../PercentileRawTDigestAggregationFunction.java | 14 +-
.../PercentileRawTDigestMVAggregationFunction.java | 19 +-
.../PercentileSmartTDigestAggregationFunction.java | 32 +-
.../PercentileTDigestAggregationFunction.java | 24 +-
.../PercentileTDigestMVAggregationFunction.java | 36 +-
.../function/StUnionAggregationFunction.java | 8 +-
.../function/SumAggregationFunction.java | 14 +-
.../function/SumIntAggregationFunction.java | 21 +-
.../function/SumLongAggregationFunction.java | 21 +-
.../function/SumMVAggregationFunction.java | 45 ---
.../function/SumPrecisionAggregationFunction.java | 14 +-
...aluesIntegerTupleSketchAggregationFunction.java | 8 +-
.../function/TimeSeriesAggregationFunction.java | 10 +-
.../function/VarianceAggregationFunction.java | 25 +-
.../function/array/BaseArrayAggFunction.java | 3 +
.../function/array/ListAggFunction.java | 12 +-
.../array/SumArrayDoubleAggregationFunction.java | 6 +-
.../array/SumArrayLongAggregationFunction.java | 6 +-
.../funnel/FunnelCountAggregationFunction.java | 9 +-
.../window/FunnelBaseAggregationFunction.java | 10 +-
.../FunnelCompleteCountAggregationFunction.java | 3 +-
...unnelEventsFunctionEvalAggregationFunction.java | 18 +-
.../window/FunnelMatchStepAggregationFunction.java | 3 +-
.../window/FunnelMaxStepAggregationFunction.java | 3 +-
...FunnelStepDurationStatsAggregationFunction.java | 6 +-
.../query/reduce/AggregationDataTableReducer.java | 16 +-
.../pinot/core/common/SyntheticBlockValSets.java | 150 +++++++
.../AggregationFunctionNullContractTest.java | 435 +++++++++++++++++++++
.../function/MaxStringAggregationFunctionTest.java | 6 -
.../function/MinStringAggregationFunctionTest.java | 6 -
...centileSmartTDigestAggregationFunctionTest.java | 9 -
.../PercentileTDigestAggregationFunctionTest.java | 7 +-
.../pinot/queries/BooleanAggQueriesTest.java | 112 +++++-
...erSegmentAggregationSingleValueQueriesTest.java | 13 +-
.../operator/MultistageAggregationExecutor.java | 13 +-
.../operator/MultistageGroupByExecutor.java | 27 +-
100 files changed, 1389 insertions(+), 1008 deletions(-)
create mode 100644
pinot-core/src/test/java/org/apache/pinot/core/query/aggregation/function/AggregationFunctionNullContractTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
