This is an automated email from the ASF dual-hosted git repository.
kishoreg pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git.
from 2552c0f Refactor pinot record reader dependency (#4872)
add a93f129 Simplifying interface related to StreamLevelConsumer (#4883)
No new revisions were added by this update.
Summary of changes:
.../realtime/impl/kafka/KafkaConsumerFactory.java | 9 +++-----
.../impl/kafka/KafkaHighLevelStreamConfig.java | 7 +++---
.../impl/kafka/KafkaStreamLevelConsumer.java | 27 ++++------------------
.../realtime/impl/kafka2/KafkaConsumerFactory.java | 6 ++---
.../impl/kafka2/KafkaStreamLevelConsumer.java | 22 +++---------------
.../impl/kafka2/KafkaStreamLevelStreamConfig.java | 7 +++---
.../realtime/HLRealtimeSegmentDataManager.java | 15 +++++++++++-
.../realtime/LLRealtimeSegmentDataManager.java | 2 +-
.../core/indexsegment/mutable/MutableSegment.java | 2 +-
.../indexsegment/mutable/MutableSegmentImpl.java | 2 +-
.../pinot/core/realtime/stream/MessageBatch.java | 1 -
.../pinot/core/realtime/stream}/RowMetadata.java | 2 +-
.../realtime/stream/StreamConsumerFactory.java | 5 ++--
.../realtime/stream/StreamMessageMetadata.java | 3 ---
.../impl/fakestream/FakeStreamConsumerFactory.java | 2 +-
...lakyConsumerRealtimeClusterIntegrationTest.java | 12 ++++------
16 files changed, 44 insertions(+), 80 deletions(-)
rename {pinot-common/src/main/java/org/apache/pinot/common/metadata =>
pinot-core/src/main/java/org/apache/pinot/core/realtime/stream}/RowMetadata.java
(97%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
