This is an automated email from the ASF dual-hosted git repository.
xiangfu0 pushed a change to branch xiangfu0/agg-rewrite/01-first-last-with-time
in repository https://gitbox.apache.org/repos/asf/pinot.git
omit 2b499339456 Infer STRING for JSON data columns in FIRST/LAST_WITH_TIME
rewrite
omit 3664aab77db Support FIRST_WITH_TIME and LAST_WITH_TIME without a data
type
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
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (2b499339456)
\
N -- N -- N
refs/heads/xiangfu0/agg-rewrite/01-first-last-with-time (7725620917e)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
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]
