This is an automated email from the ASF dual-hosted git repository.
mcvsubbu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git.
from 55b4ddc Change default segment load mode to MMAP. (#5539)
add f1f1c41 Changed the stream and metadata interface (#5542)
No new revisions were added by this update.
Summary of changes:
.../segment/LLCRealtimeSegmentZKMetadata.java | 29 +++++++-----
.../protocols/SegmentCompletionProtocol.java | 1 -
.../realtime/PinotLLCRealtimeSegmentManager.java | 28 +++++------
.../core/realtime/SegmentCompletionManager.java | 7 ++-
.../PinotLLCRealtimeSegmentManagerTest.java | 54 +++++++++++-----------
.../helix/core/realtime/SegmentCompletionTest.java | 2 +-
.../helix/core/retention/RetentionManagerTest.java | 5 +-
.../realtime/LLRealtimeSegmentDataManager.java | 12 ++---
.../realtime/LLRealtimeSegmentDataManagerTest.java | 6 +--
.../fakestream/FakePartitionLevelConsumer.java | 22 ++++++---
.../impl/fakestream/FakeStreamConfigUtils.java | 10 ++--
.../impl/fakestream/FakeStreamConsumerFactory.java | 8 ++--
.../impl/fakestream/FakeStreamMessageBatch.java | 6 ++-
.../fakestream/FakeStreamMetadataProvider.java | 7 ++-
.../kafka09/KafkaPartitionLevelConsumer.java | 12 ++++-
.../kafka09/KafkaStreamMetadataProvider.java | 11 ++++-
.../stream/kafka09/SimpleConsumerMessageBatch.java | 6 ++-
.../kafka09/KafkaPartitionLevelConsumerTest.java | 9 ++--
.../plugin/stream/kafka20/KafkaMessageBatch.java | 6 ++-
.../kafka20/KafkaPartitionLevelConsumer.java | 10 ++++
.../kafka20/KafkaStreamMetadataProvider.java | 15 ++++--
.../kafka20/KafkaPartitionLevelConsumerTest.java | 26 +++++++----
.../pinot/spi/stream/LongMsgOffsetFactory.java | 10 ----
.../org/apache/pinot/spi/stream/MessageBatch.java | 2 +-
.../pinot/spi/stream/PartitionLevelConsumer.java | 20 +++++++-
.../pinot/spi/stream/PartitionOffsetFetcher.java | 6 +--
.../pinot/spi/stream/StreamMetadataProvider.java | 6 ++-
.../pinot/spi/stream/StreamPartitionMsgOffset.java | 29 +++++++++---
.../stream/StreamPartitionMsgOffsetFactory.java | 24 +++++++---
29 files changed, 246 insertions(+), 143 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org
For additional commands, e-mail: commits-h...@pinot.apache.org
