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 4935e417f3a [timeseries] Adding error banner for timeseries error
handling in Controller UI (#16406)
add bd333b4ff73 Cleanup stream message related APIs (#16388)
No new revisions were added by this update.
Summary of changes:
.../manager/realtime/IngestionDelayTracker.java | 8 +-
.../realtime/RealtimeSegmentDataManager.java | 21 ++---
.../manager/realtime/RealtimeTableDataManager.java | 8 +-
.../kafka20/KafkaStreamMetadataProvider.java | 4 +-
.../kafka20/KafkaPartitionLevelConsumerTest.java | 5 -
.../kafka30/KafkaStreamMetadataProvider.java | 4 +-
.../kafka30/KafkaPartitionLevelConsumerTest.java | 5 -
.../stream/kafka/KafkaStreamMessageMetadata.java | 15 +--
.../plugin/stream/kinesis/KinesisConsumer.java | 4 +-
.../kinesis/KinesisStreamMessageMetadata.java | 21 +----
.../kinesis/KinesisStreamMetadataProvider.java | 4 +-
.../stream/kinesis/KinesisMessageBatchTest.java | 1 -
.../pulsar/PulsarPartitionLevelConsumer.java | 6 +-
.../stream/pulsar/PulsarStreamMessageMetadata.java | 21 +----
.../plugin/stream/pulsar/PulsarConsumerTest.java | 4 -
.../indexsegment/mutable/MutableSegmentImpl.java | 8 +-
.../writer/StatelessRealtimeSegmentWriter.java | 7 +-
.../indexsegment/mutable/IndexingFailureTest.java | 14 +--
.../MutableSegmentEntriesAboveThresholdTest.java | 12 +--
.../MutableSegmentImplAggregateMetricsTest.java | 6 +-
...MutableSegmentImplIngestionAggregationTest.java | 19 ++--
.../mutable/MutableSegmentImplRawMVTest.java | 13 ++-
.../mutable/MutableSegmentImplTest.java | 17 ++--
.../apache/pinot/segment/spi/MutableSegment.java | 6 +-
.../pinot/spi/stream/BytesStreamMessage.java | 8 +-
.../pinot/spi/stream/ConsumerPartitionState.java | 7 +-
.../org/apache/pinot/spi/stream/MessageBatch.java | 49 +---------
.../org/apache/pinot/spi/stream/RowMetadata.java | 102 ---------------------
.../pinot/spi/stream/StreamDataDecoderImpl.java | 18 ++--
.../org/apache/pinot/spi/stream/StreamMessage.java | 23 +----
.../pinot/spi/stream/StreamMessageMetadata.java | 51 +++--------
.../spi/stream/StreamDataDecoderImplTest.java | 29 +++---
32 files changed, 135 insertions(+), 385 deletions(-)
delete mode 100644
pinot-spi/src/main/java/org/apache/pinot/spi/stream/RowMetadata.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
