This is an automated email from the ASF dual-hosted git repository.
xiangfu0 pushed a change to branch xiangfu0/agg-rewrite/03-mode
in repository https://gitbox.apache.org/repos/asf/pinot.git
from 2423329bf60 Support MODE on STRING, BOOLEAN and TIMESTAMP inputs
add 8170af55d32 Bump follow-redirects in
/pinot-controller/src/main/resources (#19979)
add 1f977d977f8 Bump org.ow2.asm:asm from 9.11 to 9.11.1 (#19971)
add b1d6f042e3f Add onlyIfNeeded option in segment reload (#19861)
add 3007f88d181 Bump vite from 8.0.16 to 8.3.4 in
/pinot-controller/src/main/resources (#19989)
add 71299210708 Remove redundant snake_case scalar function aliases
(#19984)
add e8647425026 Remove the warning on multiple PinotMetricsFactory classes
(#19985)
add 2630b03651d Add null-ignoring variants of array union, concat and push
scalar functions (#19981)
add 881a1f74dc6 Honor nullableParameters for scalar functions in the
single-stage engine (#19983)
add 97ddb8ea5c0 Support FIRST_WITH_TIME and LAST_WITH_TIME without a data
type
add 25fa06fb5f3 Infer STRING for JSON data columns in FIRST/LAST_WITH_TIME
rewrite
add 7725620917e Support all single-value data types in FIRST/LAST_WITH_TIME
add 6b6b7b939c4 Merge xiangfu0/agg-rewrite/01-first-last-with-time into
xiangfu0/agg-rewrite/03-mode
No new revisions were added by this update.
Summary of changes:
.../function/scalar/ArithmeticFunctions.java | 2 +-
.../common/function/scalar/ArrayFunctions.java | 188 ++++++++++
.../common/function/scalar/IpAddressFunctions.java | 10 +-
.../common/function/scalar/StringFunctions.java | 30 +-
.../common/messages/SegmentReloadMessage.java | 22 ++
.../function/scalar/StringFunctionsTest.java | 6 +
.../common/messages/SegmentReloadMessageTest.java | 13 +
.../api/resources/PinotTableReloadResource.java | 11 +-
.../helix/core/PinotHelixResourceManager.java | 42 ++-
.../services/PinotTableReloadService.java | 24 +-
.../src/main/resources/package-lock.json | 400 ++++++++++-----------
pinot-controller/src/main/resources/package.json | 2 +-
.../services/PinotTableReloadServiceTest.java | 94 +++--
.../apache/pinot/core/common/ObjectSerDeUtils.java | 47 ++-
.../core/data/manager/BaseTableDataManager.java | 169 +++++++--
.../core/data/manager/InstanceDataManager.java | 29 +-
.../function/ScalarTransformFunctionWrapper.java | 250 ++++++++++++-
.../function/AggregationFunctionUtils.java | 3 +
...igDecimalValueWithTimeAggregationFunction.java} | 50 +--
...irstBytesValueWithTimeAggregationFunction.java} | 65 ++--
...rstLastWithTimeAggregationFunctionProvider.java | 18 +
.../function/FirstWithTimeAggregationFunction.java | 12 +-
...igDecimalValueWithTimeAggregationFunction.java} | 50 +--
...LastBytesValueWithTimeAggregationFunction.java} | 65 ++--
.../function/LastWithTimeAggregationFunction.java | 12 +-
.../AggregateFunctionRewriteOptimizer.java | 5 +-
.../pinot/core/common/ObjectSerDeUtilsTest.java | 34 ++
.../core/data/function/ArrayFunctionsTest.java | 92 +++++
.../data/manager/BaseTableDataManagerTest.java | 198 ++++++++++
.../ScalarTransformFunctionWrapperTest.java | 65 ++++
.../function/AggregationFunctionUtilsTest.java | 25 +-
.../AggregateFunctionRewriteOptimizerTest.java | 6 +-
.../pinot/queries/FirstWithTimeQueriesTest.java | 78 +++-
.../pinot/queries/LastWithTimeQueriesTest.java | 78 +++-
.../queries/NullHandlingEnabledQueriesTest.java | 24 ++
.../resources/udf-test-results/all-functions.yaml | 68 ++++
.../PinotAggregateTypeArgumentRewriteRule.java | 7 +
.../src/test/resources/queries/AggregatePlans.json | 19 +-
.../src/test/resources/queries/UDFAggregates.json | 29 +-
...StringLongPair.java => BigDecimalLongPair.java} | 27 +-
.../{StringLongPair.java => BytesLongPair.java} | 26 +-
.../local/data/manager/TableDataManager.java | 32 +-
.../pinot/segment/local/utils/ReloadJobStatus.java | 20 ++
.../local/utils/ServerReloadJobStatusCache.java | 12 +
.../utils/ServerReloadJobStatusCacheTest.java | 20 ++
.../pinot/segment/spi/AggregationFunctionType.java | 3 +-
.../api/resources/ControllerJobStatusResource.java | 19 +-
.../starter/helix/HelixInstanceDataManager.java | 14 +-
.../helix/SegmentMessageHandlerFactory.java | 10 +-
.../resources/ControllerJobStatusResourceTest.java | 97 +++++
.../apache/pinot/spi/metrics/PinotMetricUtils.java | 7 +-
pom.xml | 2 +-
52 files changed, 2103 insertions(+), 528 deletions(-)
copy
pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/{FirstStringValueWithTimeAggregationFunction.java
=> FirstBigDecimalValueWithTimeAggregationFunction.java} (64%)
copy
pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/{FirstLongValueWithTimeAggregationFunction.java
=> FirstBytesValueWithTimeAggregationFunction.java} (61%)
copy
pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/{LastDoubleValueWithTimeAggregationFunction.java
=> LastBigDecimalValueWithTimeAggregationFunction.java} (64%)
copy
pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/{LastLongValueWithTimeAggregationFunction.java
=> LastBytesValueWithTimeAggregationFunction.java} (61%)
copy
pinot-segment-local/src/main/java/org/apache/pinot/segment/local/customobject/{StringLongPair.java
=> BigDecimalLongPair.java} (59%)
copy
pinot-segment-local/src/main/java/org/apache/pinot/segment/local/customobject/{StringLongPair.java
=> BytesLongPair.java} (62%)
create mode 100644
pinot-server/src/test/java/org/apache/pinot/server/api/resources/ControllerJobStatusResourceTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
