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/pinot.git.
from dc90161 quick clean to reduce size of later PRs (#7292)
add dbaf658 Unify segment ZK metadata (#7255)
No new revisions were added by this update.
Summary of changes:
.../broker/broker/HelixBrokerStarterTest.java | 6 +-
.../routing/segmentpruner/SegmentPrunerTest.java | 97 ++---
.../timeboundary/TimeBoundaryManagerTest.java | 28 +-
.../pinot/common/metadata/ZKMetadataProvider.java | 161 ++-----
.../segment/LLCRealtimeSegmentZKMetadata.java | 151 -------
.../metadata/segment/OfflineSegmentZKMetadata.java | 135 ------
.../segment/RealtimeSegmentZKMetadata.java | 144 ------
.../common/metadata/segment/SegmentZKMetadata.java | 485 ++++++++++++---------
.../common/tier/TimeBasedTierSegmentSelector.java | 12 +-
.../apache/pinot/common/utils/SegmentUtils.java | 28 +-
.../metadata/MetadataEqualsHashCodeTest.java | 9 -
.../common/metadata/SegmentZKMetadataTest.java | 72 ++-
.../pinot/common/tier/TierSegmentSelectorTest.java | 11 +-
.../api/resources/PinotSegmentRestletResource.java | 15 +-
.../pinot/controller/api/upload/ZKOperator.java | 23 +-
.../controller/helix/SegmentStatusChecker.java | 6 +-
.../helix/core/PinotHelixResourceManager.java | 57 ++-
.../segment/OfflineSegmentAssignment.java | 21 +-
.../helix/core/minion/ClusterInfoAccessor.java | 39 +-
.../realtime/PinotLLCRealtimeSegmentManager.java | 47 +-
.../core/realtime/PinotRealtimeSegmentManager.java | 43 +-
.../core/realtime/SegmentCompletionManager.java | 37 +-
.../segment/DefaultFlushThresholdUpdater.java | 8 +-
.../realtime/segment/FlushThresholdUpdater.java | 8 +-
.../SegmentSizeBasedFlushThresholdUpdater.java | 6 +-
.../helix/core/retention/RetentionManager.java | 29 +-
.../retention/strategy/TimeRetentionStrategy.java | 4 +-
.../helix/core/util/ZKMetadataUtils.java | 3 +-
.../realtime/provisioning/MemoryEstimator.java | 56 +--
.../controller/util/TableRetentionValidator.java | 46 +-
.../validation/OfflineSegmentIntervalChecker.java | 31 +-
.../RealtimeSegmentValidationManager.java | 19 +-
.../controller/api/upload/ZKOperatorTest.java | 22 +-
.../controller/helix/PinotResourceManagerTest.java | 5 +-
.../controller/helix/SegmentStatusCheckerTest.java | 40 +-
.../helix/core/PinotHelixResourceManagerTest.java | 37 +-
.../OfflineReplicaGroupSegmentAssignmentTest.java | 5 +-
.../PinotLLCRealtimeSegmentManagerTest.java | 58 ++-
.../helix/core/realtime/SegmentCompletionTest.java | 14 +-
.../segment/FlushThresholdUpdaterTest.java | 36 +-
.../helix/core/retention/RetentionManagerTest.java | 61 ++-
.../strategy/TimeRetentionStrategyTest.java | 29 +-
.../controller/utils/SegmentMetadataMockUtils.java | 14 +-
.../validation/ValidationManagerTest.java | 45 +-
.../realtime/HLRealtimeSegmentDataManager.java | 21 +-
.../realtime/LLRealtimeSegmentDataManager.java | 37 +-
.../manager/realtime/RealtimeTableDataManager.java | 37 +-
.../realtime/LLRealtimeSegmentDataManagerTest.java | 30 +-
.../converter/RealtimeSegmentConverterTest.java | 14 +-
...vertToRawIndexMinionClusterIntegrationTest.java | 7 +-
.../tests/LLCRealtimeClusterIntegrationTest.java | 16 +-
.../tests/OfflineClusterIntegrationTest.java | 32 +-
...rDownloadLLCRealtimeClusterIntegrationTest.java | 45 +-
...fflineSegmentsMinionClusterIntegrationTest.java | 44 +-
...PartitionLLCRealtimeClusterIntegrationTest.java | 23 +-
.../plugin/minion/tasks/BaseTaskExecutor.java | 9 +-
.../ConvertToRawIndexTaskGenerator.java | 13 +-
.../merge_rollup/MergeRollupTaskGenerator.java | 42 +-
.../RealtimeToOfflineSegmentsTaskGenerator.java | 42 +-
.../SegmentGenerationAndPushTaskGenerator.java | 22 +-
.../merge_rollup/MergeRollupTaskGeneratorTest.java | 162 ++++---
...RealtimeToOfflineSegmentsTaskGeneratorTest.java | 136 +++---
.../indexsegment/mutable/MutableSegmentImpl.java | 42 +-
.../local/realtime/impl/RealtimeSegmentConfig.java | 20 +-
.../mutable/MutableSegmentImplTestUtils.java | 4 +-
.../starter/helix/SegmentFetcherAndLoader.java | 8 +-
.../SegmentOnlineOfflineStateModelFactory.java | 9 +-
.../apache/pinot/spi/utils/CommonConstants.java | 26 +-
.../OfflineSegmentIntervalCheckerCommand.java | 14 +-
69 files changed, 1221 insertions(+), 1837 deletions(-)
delete mode 100644
pinot-common/src/main/java/org/apache/pinot/common/metadata/segment/LLCRealtimeSegmentZKMetadata.java
delete mode 100644
pinot-common/src/main/java/org/apache/pinot/common/metadata/segment/OfflineSegmentZKMetadata.java
delete mode 100644
pinot-common/src/main/java/org/apache/pinot/common/metadata/segment/RealtimeSegmentZKMetadata.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
