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 f15a7b0 Add error for empty instance list for tenant API (#4969)
add b5d1f42 Remove Kafka and Stream dependency on avro (#4968)
No new revisions were added by this update.
Summary of changes:
pinot-integration-tests/pom.xml | 5 ++
.../pinot/integration/tests/ClusterTest.java | 27 ++++----
.../inputformat/avro/AvroRecordExtractor.java | 31 ++++-----
.../inputformat/avro}/KafkaAvroMessageDecoder.java | 74 ++++++++++++----------
.../avro}/SimpleAvroMessageDecoder.java | 17 +++--
.../avro}/AvroRecordToPinotRowGeneratorTest.java | 7 +-
.../kafka09/KafkaLowLevelStreamConfigTest.java | 8 +--
.../KafkaPartitionLevelStreamConfigTest.java | 5 +-
.../pinot-kafka-base/pom.xml | 4 --
.../stream/AvroRecordToPinotRowGenerator.java | 51 ---------------
.../data/readers/AbstractBaseRecordExtractor.java | 30 ++++-----
...ecordReaderConfig.java => RecordExtractor.java} | 12 +++-
.../pinot/spi/stream/StreamMessageDecoder.java | 2 +
13 files changed, 121 insertions(+), 152 deletions(-)
copy
pinot-core/src/test/java/org/apache/pinot/core/realtime/impl/fakestream/FakeStreamMessageDecoder.java
=>
pinot-plugins/pinot-input-format/pinot-avro/src/main/java/org/apache/pinot/plugin/inputformat/avro/AvroRecordExtractor.java
(59%)
rename
pinot-plugins/{pinot-stream-ingestion/pinot-kafka-base/src/main/java/org/apache/pinot/plugin/stream/kafka
=>
pinot-input-format/pinot-avro/src/main/java/org/apache/pinot/plugin/inputformat/avro}/KafkaAvroMessageDecoder.java
(79%)
rename
pinot-plugins/{pinot-stream-ingestion/pinot-kafka-base/src/main/java/org/apache/pinot/plugin/stream
=>
pinot-input-format/pinot-avro/src/main/java/org/apache/pinot/plugin/inputformat/avro}/SimpleAvroMessageDecoder.java
(81%)
rename
pinot-plugins/{pinot-stream-ingestion/pinot-kafka-base/src/test/java/org/apache/pinot/plugin/stream
=>
pinot-input-format/pinot-avro/src/test/java/org/apache/pinot/plugin/inputformat/avro}/AvroRecordToPinotRowGeneratorTest.java
(87%)
delete mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-kafka-base/src/main/java/org/apache/pinot/plugin/stream/AvroRecordToPinotRowGenerator.java
copy
pinot-core/src/main/java/org/apache/pinot/core/segment/virtualcolumn/VirtualColumnContext.java
=>
pinot-spi/src/main/java/org/apache/pinot/spi/data/readers/AbstractBaseRecordExtractor.java
(54%)
copy
pinot-spi/src/main/java/org/apache/pinot/spi/data/readers/{RecordReaderConfig.java
=> RecordExtractor.java} (77%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
