This is an automated email from the ASF dual-hosted git repository.
xiangfu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git.
from d15b33a [TE] Bug fix in the rca dashboard/summary endpoint (#4880)
add 2552c0f Refactor pinot record reader dependency (#4872)
No new revisions were added by this update.
Summary of changes:
docs/record_reader.rst | 2 +-
pinot-core/pom.xml | 27 ++++
.../core/data/readers/RecordReaderFactory.java | 6 +
.../generator/SegmentGeneratorConfig.java | 4 +-
.../stream/AvroRecordToPinotRowGenerator.java | 2 +-
.../core/data/readers/CSVRecordReaderTest.java | 75 ---------
.../core/data/readers/JSONRecordReaderTest.java | 69 ---------
.../data/readers/RecordReaderSampleDataTest.java | 3 +
.../pinot/core/data/readers/RecordReaderTest.java | 54 -------
.../MutableSegmentImplNullValueVectorTest.java | 2 +-
.../mutable/MutableSegmentImplTest.java | 4 +-
.../fakestream/FakePartitionLevelConsumer.java | 2 +-
.../SegmentGenerationWithBytesTypeTest.java | 2 +-
.../pinot/segments/v1/creator/BlocksTest.java | 2 +-
.../segments/v1/creator/DictionariesTest.java | 2 +-
.../pinot/segments/v1/creator/IntArraysTest.java | 2 +-
.../hadoop/job/mappers/SegmentCreationMapper.java | 4 +-
.../spark/jobs/SparkSegmentCreationFunction.java | 4 +-
pinot-ingestion-jobs/pom.xml | 11 --
.../tests/ClusterIntegrationTestUtils.java | 2 +-
.../pinot/integration/tests/ClusterTest.java | 2 +-
.../tests/MapTypeClusterIntegrationTest.java | 2 +-
.../data/readers/ParquetRecordReaderTest.java | 96 ------------
.../pinot-avro}/pom.xml | 55 ++++---
.../pinot/avro}/data/readers/AvroRecordReader.java | 4 +-
.../pinot/avro/data/readers}/AvroSchemaUtil.java | 2 +-
.../apache/pinot/avro/data/readers}/AvroUtils.java | 48 +++++-
.../avro/data/readers/AvroRecordReaderTest.java | 60 ++++++++
.../pinot-csv}/pom.xml | 56 +++----
.../CSVRecordReader.java | 3 +-
.../CSVRecordReaderConfig.java | 2 +-
.../CSVRecordReaderTest.java | 67 +++++++++
.../pinot-json}/pom.xml | 52 +++----
.../JSONRecordReader.java | 3 +-
.../JSONRecordReaderTest.java | 53 +++++++
.../pinot-orc}/pom.xml | 4 +-
.../pinot/orc/data/readers/ORCRecordReader.java | 0
.../orc/data/readers/ORCRecordReaderTest.java | 0
.../pinot-parquet}/pom.xml | 30 ++--
.../parquet/data/readers/ParquetRecordReader.java | 5 +-
.../pinot/parquet/data/readers/ParquetUtils.java | 1 +
.../data/readers/ParquetRecordReaderTest.java | 66 ++++++++
.../pinot-thrift}/pom.xml | 56 +++----
.../ThriftRecordReader.java | 3 +-
.../ThriftRecordReaderConfig.java | 2 +-
.../ThriftRecordReaderTest.java | 6 +-
.../ThriftSampleData.java | 2 +-
.../apache/pinot/server/util/SegmentTestUtils.java | 2 +-
pinot-spi/pom.xml | 4 +
.../pinot/spi}/data/readers/RecordReaderUtils.java | 6 +-
.../spi/data/readers/AbstractRecordReaderTest.java | 167 +++++++++++++++++++++
.../spi}/data/readers/RecordReaderUtilsTest.java | 2 +-
.../admin/command/AvroSchemaToPinotSchema.java | 2 +-
.../admin/command/StreamAvroIntoKafkaCommand.java | 2 +-
.../converter/PinotSegmentToAvroConverter.java | 2 +-
pom.xml | 13 +-
56 files changed, 682 insertions(+), 477 deletions(-)
delete mode 100644
pinot-core/src/test/java/org/apache/pinot/core/data/readers/CSVRecordReaderTest.java
delete mode 100644
pinot-core/src/test/java/org/apache/pinot/core/data/readers/JSONRecordReaderTest.java
delete mode 100644
pinot-core/src/test/java/org/apache/pinot/core/data/readers/RecordReaderTest.java
delete mode 100644
pinot-parquet/src/test/java/org/apache/pinot/parquet/data/readers/ParquetRecordReaderTest.java
copy {pinot-hadoop-filesystem => pinot-record-readers/pinot-avro}/pom.xml (72%)
rename {pinot-core/src/main/java/org/apache/pinot/core =>
pinot-record-readers/pinot-avro/src/main/java/org/apache/pinot/avro}/data/readers/AvroRecordReader.java
(96%)
copy {pinot-common/src/main/java/org/apache/pinot/common/utils =>
pinot-record-readers/pinot-avro/src/main/java/org/apache/pinot/avro/data/readers}/AvroSchemaUtil.java
(98%)
rename {pinot-core/src/main/java/org/apache/pinot/core/util =>
pinot-record-readers/pinot-avro/src/main/java/org/apache/pinot/avro/data/readers}/AvroUtils.java
(91%)
create mode 100644
pinot-record-readers/pinot-avro/src/test/java/org/apache/pinot/avro/data/readers/AvroRecordReaderTest.java
copy {pinot-hadoop-filesystem => pinot-record-readers/pinot-csv}/pom.xml (67%)
rename {pinot-core/src/main/java/org/apache/pinot/core/data/readers =>
pinot-record-readers/pinot-csv/src/main/java/org.apache.pinot.csv.data.readers}/CSVRecordReader.java
(97%)
rename {pinot-core/src/main/java/org/apache/pinot/core/data/readers =>
pinot-record-readers/pinot-csv/src/main/java/org.apache.pinot.csv.data.readers}/CSVRecordReaderConfig.java
(97%)
create mode 100644
pinot-record-readers/pinot-csv/src/test/java/org.apache.pinot.csv.data.readers/CSVRecordReaderTest.java
copy {pinot-hadoop-filesystem => pinot-record-readers/pinot-json}/pom.xml (67%)
rename {pinot-core/src/main/java/org/apache/pinot/core/data/readers =>
pinot-record-readers/pinot-json/src/main/java/org.apache.pinot.json.data.readers}/JSONRecordReader.java
(96%)
create mode 100644
pinot-record-readers/pinot-json/src/test/java/org.apache.pinot.json.data.readers/JSONRecordReaderTest.java
rename {pinot-orc => pinot-record-readers/pinot-orc}/pom.xml (96%)
rename {pinot-orc =>
pinot-record-readers/pinot-orc}/src/main/java/org/apache/pinot/orc/data/readers/ORCRecordReader.java
(100%)
rename {pinot-orc =>
pinot-record-readers/pinot-orc}/src/test/java/org/apache/pinot/orc/data/readers/ORCRecordReaderTest.java
(100%)
rename {pinot-parquet => pinot-record-readers/pinot-parquet}/pom.xml (86%)
rename {pinot-parquet =>
pinot-record-readers/pinot-parquet}/src/main/java/org/apache/pinot/parquet/data/readers/ParquetRecordReader.java
(96%)
rename {pinot-parquet =>
pinot-record-readers/pinot-parquet}/src/main/java/org/apache/pinot/parquet/data/readers/ParquetUtils.java
(98%)
create mode 100644
pinot-record-readers/pinot-parquet/src/test/java/org/apache/pinot/parquet/data/readers/ParquetRecordReaderTest.java
copy {pinot-hadoop-filesystem => pinot-record-readers/pinot-thrift}/pom.xml
(67%)
rename {pinot-core/src/main/java/org/apache/pinot/core/data/readers =>
pinot-record-readers/pinot-thrift/src/main/java/org.apache.pinot.thrift.data.readers}/ThriftRecordReader.java
(97%)
rename {pinot-core/src/main/java/org/apache/pinot/core/data/readers =>
pinot-record-readers/pinot-thrift/src/main/java/org.apache.pinot.thrift.data.readers}/ThriftRecordReaderConfig.java
(96%)
rename {pinot-core/src/test/java/org/apache/pinot/core/data/readers =>
pinot-record-readers/pinot-thrift/src/test/java/org.apache.pinot.thrift.data.readers}/ThriftRecordReaderTest.java
(95%)
rename {pinot-core/src/test/java/org/apache/pinot/core/data/readers =>
pinot-record-readers/pinot-thrift/src/test/java/org.apache.pinot.thrift.data.readers}/ThriftSampleData.java
(99%)
rename {pinot-core/src/main/java/org/apache/pinot/core =>
pinot-spi/src/main/java/org/apache/pinot/spi}/data/readers/RecordReaderUtils.java
(97%)
create mode 100644
pinot-spi/src/test/java/org/apache/pinot/spi/data/readers/AbstractRecordReaderTest.java
rename {pinot-core/src/test/java/org/apache/pinot/core =>
pinot-spi/src/test/java/org/apache/pinot/spi}/data/readers/RecordReaderUtilsTest.java
(98%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
