This is an automated email from the ASF dual-hosted git repository.
xiangfu0 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
from 7265af3574a Fix controller UI crash on instance listing pages when
instance names lack type prefix (#18805)
add 431d541a03f Support firstWithTime/lastWithTime aggregation types for
MergeRollupTask (#18724)
No new revisions were added by this update.
Summary of changes:
.../apache/pinot/core/common/MinionConstants.java | 19 +-
.../aggregator/FirstWithTimeValueAggregator.java | 42 ++++
.../aggregator/LastWithTimeValueAggregator.java | 42 ++++
.../aggregator/ValueAggregatorFactory.java | 24 +-
.../framework/SegmentProcessorConfig.java | 17 ++
.../genericrow/GenericRowFileManager.java | 25 ++
.../genericrow/GenericRowFileReader.java | 13 +-
.../genericrow/GenericRowFileRecordReader.java | 9 +-
.../segment/processing/mapper/SegmentMapper.java | 7 +-
.../segment/processing/reducer/RollupReducer.java | 40 +++-
.../processing/timehandler/EpochTimeHandler.java | 14 ++
.../processing/timehandler/TimeHandler.java | 6 +
.../processing/timehandler/TimeHandlerFactory.java | 3 +-
.../processing/utils/SegmentProcessorUtils.java | 27 ++-
.../BaseSegmentProcessorFrameworkTest.java | 154 +++++++++++++
.../segment/processing/framework/ReducerTest.java | 245 ++++++++++++++++++++
.../utils/SegmentProcessorUtilsTest.java | 89 +++++++
.../pinot/plugin/minion/tasks/MergeTaskUtils.java | 29 +++
.../mergerollup/MergeRollupTaskGenerator.java | 20 ++
.../RealtimeToOfflineSegmentsTaskGenerator.java | 16 +-
.../plugin/minion/tasks/MergeTaskUtilsTest.java | 48 +++-
.../MergeRollupFirstLastTaskExecutorTest.java | 256 +++++++++++++++++++++
.../mergerollup/MergeRollupTaskGeneratorTest.java | 61 +++++
...RealtimeToOfflineSegmentsTaskGeneratorTest.java | 49 ++++
24 files changed, 1219 insertions(+), 36 deletions(-)
create mode 100644
pinot-core/src/main/java/org/apache/pinot/core/segment/processing/aggregator/FirstWithTimeValueAggregator.java
create mode 100644
pinot-core/src/main/java/org/apache/pinot/core/segment/processing/aggregator/LastWithTimeValueAggregator.java
create mode 100644
pinot-core/src/test/java/org/apache/pinot/core/segment/processing/utils/SegmentProcessorUtilsTest.java
create mode 100644
pinot-plugins/pinot-minion-tasks/pinot-minion-builtin-tasks/src/test/java/org/apache/pinot/plugin/minion/tasks/mergerollup/MergeRollupFirstLastTaskExecutorTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
