This is an automated email from the ASF dual-hosted git repository.
jackie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git.
from db5561a Improve the segment aggregated metadata controller/server API
(#7157)
add 738a584 Extract time handling for SegmentProcessorFramework (#7158)
No new revisions were added by this update.
Summary of changes:
.../apache/pinot/core/common/MinionConstants.java | 12 +-
.../framework/SegmentProcessorConfig.java | 100 ++---
.../segment/processing/mapper/SegmentMapper.java | 52 +--
.../partitioner/ColumnValuePartitioner.java | 1 -
.../processing/partitioner/NoOpPartitioner.java | 1 -
.../processing/partitioner}/Partitioner.java | 2 +-
.../processing/partitioner/PartitionerFactory.java | 1 -
.../partitioner/RoundRobinPartitioner.java | 1 -
.../partitioner/TableConfigPartitioner.java | 1 -
.../partitioner/TransformFunctionPartitioner.java | 1 -
.../processing/timehandler/EpochTimeHandler.java | 69 +++
.../NoOpTimeHandler.java} | 11 +-
.../processing/timehandler/TimeHandler.java | 24 +-
.../processing/timehandler/TimeHandlerConfig.java | 106 +++++
.../processing/timehandler/TimeHandlerFactory.java | 57 +++
.../processing/framework/PartitionerTest.java | 2 +-
.../processing/framework/SegmentMapperTest.java | 140 +++---
.../framework/SegmentProcessorFrameworkTest.java | 490 ++++++---------------
.../RealtimeToOfflineSegmentsTaskExecutor.java | 188 +++-----
.../RealtimeToOfflineSegmentsTaskGenerator.java | 43 +-
.../RealtimeToOfflineSegmentsTaskExecutorTest.java | 27 +-
...RealtimeToOfflineSegmentsTaskGeneratorTest.java | 8 +-
.../command/SegmentProcessorFrameworkCommand.java | 5 +-
.../processor/SegmentProcessorFrameworkSpec.java | 40 +-
24 files changed, 626 insertions(+), 756 deletions(-)
rename {pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/partition
=>
pinot-core/src/main/java/org/apache/pinot/core/segment/processing/partitioner}/Partitioner.java
(94%)
create mode 100644
pinot-core/src/main/java/org/apache/pinot/core/segment/processing/timehandler/EpochTimeHandler.java
copy
pinot-core/src/main/java/org/apache/pinot/core/segment/processing/{filter/NoOpRecordFilter.java
=> timehandler/NoOpTimeHandler.java} (75%)
copy
pinot-segment-local/src/main/java/org/apache/pinot/segment/local/recordtransformer/RecordTransformer.java
=>
pinot-core/src/main/java/org/apache/pinot/core/segment/processing/timehandler/TimeHandler.java
(58%)
create mode 100644
pinot-core/src/main/java/org/apache/pinot/core/segment/processing/timehandler/TimeHandlerConfig.java
create mode 100644
pinot-core/src/main/java/org/apache/pinot/core/segment/processing/timehandler/TimeHandlerFactory.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
