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 b4cd708 Clean up BitmapInvertedIndexReader (#4934)
add 5b5dfe8 Restructuring Pinot Plugin Modules (#4946)
No new revisions were added by this update.
Summary of changes:
pinot-distribution/pom.xml | 5 +++--
pinot-integration-tests/pom.xml | 2 +-
pinot-perf/pom.xml | 2 +-
.../pinot-batch-ingestion-base}/pom.xml | 7 +++----
.../java/org/apache/pinot/ingestion/common/Constants.java | 0
.../apache/pinot/ingestion/common/PinotClusterSpec.java | 0
.../org/apache/pinot/ingestion/common/PinotFSSpec.java | 0
.../org/apache/pinot/ingestion/common/PushJobSpec.java | 0
.../apache/pinot/ingestion/common/RecordReaderSpec.java | 0
.../pinot/ingestion/common/SegmentGenerationJobSpec.java | 0
.../ingestion/common/SegmentGenerationTaskRunner.java | 0
.../pinot/ingestion/common/SegmentGenerationTaskSpec.java | 0
.../pinot/ingestion/common/SegmentNameGeneratorSpec.java | 0
.../java/org/apache/pinot/ingestion/common/TableSpec.java | 0
.../ingestion/standalone/SegmentGenerationJobRunner.java | 0
.../ingestion/standalone/SegmentTarPushJobRunner.java | 0
.../ingestion/standalone/SegmentUriPushJobRunner.java | 0
.../standalone/StandaloneIngestionJobLauncher.java | 0
.../main/resources/segmentCreationAndTarPushJobSpec.yaml | 0
.../main/resources/segmentCreationAndUriPushJobSpec.yaml | 0
.../src/main/resources/segmentCreationJobSpec.yaml | 0
.../src/main/resources/segmentTarPushJobSpec.yaml | 0
.../src/main/resources/segmentUriPushJobSpec.yaml | 0
.../pinot-batch-ingestion}/pom.xml | 11 ++++-------
.../v0_deprecated}/pinot-hadoop/README.md | 0
.../v0_deprecated}/pinot-hadoop/pom.xml | 4 ++--
.../org/apache/pinot/hadoop/PinotHadoopJobLauncher.java | 0
.../apache/pinot/hadoop/io/CombineAvroKeyInputFormat.java | 0
.../main/java/org/apache/pinot/hadoop/io/FileHandler.java | 0
.../org/apache/pinot/hadoop/io/JsonPinotOutputFormat.java | 0
.../org/apache/pinot/hadoop/io/PinotOutputFormat.java | 0
.../main/java/org/apache/pinot/hadoop/io/PinotRecord.java | 0
.../apache/pinot/hadoop/io/PinotRecordSerialization.java | 0
.../org/apache/pinot/hadoop/io/PinotRecordWriter.java | 0
.../apache/pinot/hadoop/job/HadoopSegmentCreationJob.java | 0
.../pinot/hadoop/job/HadoopSegmentPreprocessingJob.java | 0
.../apache/pinot/hadoop/job/InternalConfigConstants.java | 0
.../pinot/hadoop/job/mappers/SegmentCreationMapper.java | 0
.../hadoop/job/mappers/SegmentPreprocessingMapper.java | 0
.../pinot/hadoop/job/partitioners/GenericPartitioner.java | 0
.../hadoop/job/partitioners/PartitionFunctionFactory.java | 0
.../hadoop/job/reducers/SegmentPreprocessingReducer.java | 0
.../hadoop/utils/PinotHadoopJobPreparationHelper.java | 0
.../pinot/hadoop/io/DeleteExtraPushedSegmentsTest.java | 0
.../org/apache/pinot/hadoop/io/PinotOutputFormatTest.java | 0
.../pinot/hadoop/job/mappers/SegmentCreationTest.java | 0
.../v0_deprecated}/pinot-ingestion-common/pom.xml | 5 ++---
.../apache/pinot/ingestion/common/ControllerRestApi.java | 0
.../pinot/ingestion/common/DefaultControllerRestApi.java | 0
.../apache/pinot/ingestion/common/JobConfigConstants.java | 0
.../pinot/ingestion/common/PinotIngestionJobType.java | 0
.../org/apache/pinot/ingestion/jobs/BaseSegmentJob.java | 0
.../apache/pinot/ingestion/jobs/SegmentCreationJob.java | 0
.../pinot/ingestion/jobs/SegmentPreprocessingJob.java | 0
.../apache/pinot/ingestion/jobs/SegmentTarPushJob.java | 0
.../apache/pinot/ingestion/jobs/SegmentUriPushJob.java | 0
.../pinot/ingestion/utils/JobPreparationHelper.java | 0
.../org/apache/pinot/ingestion/utils/PushLocation.java | 0
.../v0_deprecated}/pinot-spark/README.md | 0
.../v0_deprecated}/pinot-spark/pom.xml | 4 ++--
.../org/apache/pinot/spark/PinotSparkJobLauncher.java | 0
.../pinot/spark/jobs/SparkSegmentCreationFunction.java | 0
.../apache/pinot/spark/jobs/SparkSegmentCreationJob.java | 0
.../apache/pinot/spark/jobs/SparkSegmentTarPushJob.java | 0
.../apache/pinot/spark/jobs/SparkSegmentUriPushJob.java | 0
.../pinot/spark/utils/PinotSparkJobPreparationHelper.java | 0
.../pinot-batch-ingestion/v0_deprecated}/pom.xml | 7 +++----
.../pinot-file-system/pinot-adls}/pom.xml | 9 +++++----
.../java/org/apache/pinot/filesystem/AzurePinotFS.java | 0
.../azure/datalake/store/MockADLFileInputStream.java | 0
.../apache/pinot/filesystem/test/AzurePinotFSTest.java | 0
.../pinot-file-system/pinot-gcs}/pom.xml | 14 +++++++-------
.../main/java/org/apache/pinot/filesystem/GcsPinotFS.java | 0
.../pinot-file-system/pinot-hdfs}/pom.xml | 6 +++---
.../java/org/apache/pinot/filesystem/HadoopPinotFS.java | 0
.../pinot-file-system}/pom.xml | 14 +++++++-------
.../pinot-input-format}/pinot-avro/pom.xml | 4 ++--
.../apache/pinot/avro/data/readers/AvroRecordReader.java | 0
.../apache/pinot/avro/data/readers/AvroSchemaUtil.java | 0
.../org/apache/pinot/avro/data/readers/AvroUtils.java | 0
.../pinot/avro/data/readers/AvroRecordReaderTest.java | 0
.../pinot-input-format}/pinot-csv/pom.xml | 4 ++--
.../apache/pinot/csv/data/readers/CSVRecordReader.java | 0
.../pinot/csv/data/readers/CSVRecordReaderConfig.java | 0
.../pinot/csv/data/readers/CSVRecordReaderTest.java | 0
.../pinot-input-format}/pinot-json/pom.xml | 4 ++--
.../apache/pinot/json/data/readers/JSONRecordReader.java | 0
.../pinot/json/data/readers/JSONRecordReaderTest.java | 0
.../pinot-input-format}/pinot-orc/pom.xml | 4 ++--
.../apache/pinot/orc/data/readers/ORCRecordReader.java | 0
.../pinot/orc/data/readers/ORCRecordReaderTest.java | 0
.../pinot-input-format}/pinot-parquet/pom.xml | 4 ++--
.../pinot/parquet/data/readers/ParquetRecordReader.java | 0
.../apache/pinot/parquet/data/readers/ParquetUtils.java | 0
.../parquet/data/readers/ParquetRecordReaderTest.java | 0
.../pinot-input-format}/pinot-thrift/pom.xml | 4 ++--
.../pinot/thrift/data/readers/ThriftRecordReader.java | 0
.../thrift/data/readers/ThriftRecordReaderConfig.java | 0
.../pinot/thrift/data/readers/ThriftRecordReaderTest.java | 0
.../pinot/thrift/data/readers/ThriftSampleData.java | 0
.../pinot-input-format}/pom.xml | 8 ++++----
.../pinot-stream-ingestion}/README.md | 0
.../pinot-stream-ingestion/pinot-kafka-0.9}/README.md | 0
.../pinot-stream-ingestion/pinot-kafka-0.9}/pom.xml | 11 +++++------
.../core/realtime/impl/kafka/ConsumerAndIterator.java | 0
.../core/realtime/impl/kafka/KafkaBrokerWrapper.java | 0
.../core/realtime/impl/kafka/KafkaConnectionHandler.java | 0
.../core/realtime/impl/kafka/KafkaConsumerFactory.java | 0
.../core/realtime/impl/kafka/KafkaConsumerManager.java | 0
.../realtime/impl/kafka/KafkaHighLevelStreamConfig.java | 0
.../realtime/impl/kafka/KafkaLowLevelStreamConfig.java | 0
.../realtime/impl/kafka/KafkaPartitionLevelConsumer.java | 0
.../realtime/impl/kafka/KafkaSimpleConsumerFactory.java | 0
.../impl/kafka/KafkaSimpleConsumerFactoryImpl.java | 0
.../realtime/impl/kafka/KafkaStreamLevelConsumer.java | 0
.../realtime/impl/kafka/KafkaStreamMetadataProvider.java | 0
.../core/realtime/impl/kafka/SimpleConsumerFactory.java | 0
.../realtime/impl/kafka/SimpleConsumerMessageBatch.java | 0
.../realtime/impl/kafka/server/KafkaDataProducer.java | 0
.../impl/kafka/server/KafkaDataServerStartable.java | 0
.../org.apache.pinot.spi.stream.StreamConsumerFactory | 0
.../impl/kafka/KafkaLowLevelStreamConfigTest.java | 0
.../impl/kafka/KafkaPartitionLevelConsumerTest.java | 0
.../pinot-stream-ingestion/pinot-kafka-2.0}/README.md | 0
.../pinot-stream-ingestion/pinot-kafka-2.0}/pom.xml | 11 +++++------
.../core/realtime/impl/kafka2/KafkaConsumerFactory.java | 0
.../core/realtime/impl/kafka2/KafkaMessageBatch.java | 0
.../impl/kafka2/KafkaPartitionLevelConnectionHandler.java | 0
.../realtime/impl/kafka2/KafkaPartitionLevelConsumer.java | 0
.../impl/kafka2/KafkaPartitionLevelStreamConfig.java | 0
.../realtime/impl/kafka2/KafkaStreamLevelConsumer.java | 0
.../impl/kafka2/KafkaStreamLevelConsumerManager.java | 0
.../impl/kafka2/KafkaStreamLevelStreamConfig.java | 0
.../realtime/impl/kafka2/KafkaStreamMetadataProvider.java | 0
.../realtime/impl/kafka2/server/KafkaDataProducer.java | 0
.../impl/kafka2/server/KafkaDataServerStartable.java | 0
.../org.apache.pinot.spi.stream.StreamConsumerFactory | 0
.../impl/kafka2/KafkaPartitionLevelConsumerTest.java | 0
.../impl/kafka2/KafkaPartitionLevelStreamConfigTest.java | 0
.../realtime/impl/kafka2/utils/EmbeddedZooKeeper.java | 0
.../core/realtime/impl/kafka2/utils/MiniKafkaCluster.java | 0
.../pinot-stream-ingestion/pinot-kafka-base}/README.md | 0
.../pinot-stream-ingestion/pinot-kafka-base}/pom.xml | 9 ++++-----
.../core/realtime/impl/kafka/KafkaAvroMessageDecoder.java | 0
.../core/realtime/impl/kafka/KafkaJSONMessageDecoder.java | 0
.../pinot/core/realtime/impl/kafka/KafkaStarterUtils.java | 0
.../realtime/impl/kafka/KafkaStreamConfigProperties.java | 0
.../pinot/core/realtime/impl/kafka/MessageAndOffset.java | 0
.../realtime/stream/AvroRecordToPinotRowGenerator.java | 0
.../core/realtime/stream/SimpleAvroMessageDecoder.java | 0
.../realtime/impl/kafka/KafkaJSONMessageDecoderTest.java | 0
.../stream/AvroRecordToPinotRowGeneratorTest.java | 0
.../src/test/resources/data/test_sample_data.json | 0
.../data/test_sample_data_schema_no_time_field.json | 0
.../test_sample_data_schema_with_outgoing_time_spec.json | 0
...est_sample_data_schema_without_outgoing_time_spec.json | 0
.../pinot-stream-ingestion}/pom.xml | 15 +++++++--------
{pinot-record-readers => pinot-plugins}/pom.xml | 15 ++++++---------
pinot-tools/pom.xml | 4 ++--
pom.xml | 9 ++-------
160 files changed, 90 insertions(+), 106 deletions(-)
rename {pinot-batch-ingestion/pinot-standalone =>
pinot-plugins/pinot-batch-ingestion/pinot-batch-ingestion-base}/pom.xml (97%)
rename {pinot-batch-ingestion/pinot-standalone =>
pinot-plugins/pinot-batch-ingestion/pinot-batch-ingestion-base}/src/main/java/org/apache/pinot/ingestion/common/Constants.java
(100%)
rename {pinot-batch-ingestion/pinot-standalone =>
pinot-plugins/pinot-batch-ingestion/pinot-batch-ingestion-base}/src/main/java/org/apache/pinot/ingestion/common/PinotClusterSpec.java
(100%)
rename {pinot-batch-ingestion/pinot-standalone =>
pinot-plugins/pinot-batch-ingestion/pinot-batch-ingestion-base}/src/main/java/org/apache/pinot/ingestion/common/PinotFSSpec.java
(100%)
rename {pinot-batch-ingestion/pinot-standalone =>
pinot-plugins/pinot-batch-ingestion/pinot-batch-ingestion-base}/src/main/java/org/apache/pinot/ingestion/common/PushJobSpec.java
(100%)
rename {pinot-batch-ingestion/pinot-standalone =>
pinot-plugins/pinot-batch-ingestion/pinot-batch-ingestion-base}/src/main/java/org/apache/pinot/ingestion/common/RecordReaderSpec.java
(100%)
rename {pinot-batch-ingestion/pinot-standalone =>
pinot-plugins/pinot-batch-ingestion/pinot-batch-ingestion-base}/src/main/java/org/apache/pinot/ingestion/common/SegmentGenerationJobSpec.java
(100%)
rename {pinot-batch-ingestion/pinot-standalone =>
pinot-plugins/pinot-batch-ingestion/pinot-batch-ingestion-base}/src/main/java/org/apache/pinot/ingestion/common/SegmentGenerationTaskRunner.java
(100%)
rename {pinot-batch-ingestion/pinot-standalone =>
pinot-plugins/pinot-batch-ingestion/pinot-batch-ingestion-base}/src/main/java/org/apache/pinot/ingestion/common/SegmentGenerationTaskSpec.java
(100%)
rename {pinot-batch-ingestion/pinot-standalone =>
pinot-plugins/pinot-batch-ingestion/pinot-batch-ingestion-base}/src/main/java/org/apache/pinot/ingestion/common/SegmentNameGeneratorSpec.java
(100%)
rename {pinot-batch-ingestion/pinot-standalone =>
pinot-plugins/pinot-batch-ingestion/pinot-batch-ingestion-base}/src/main/java/org/apache/pinot/ingestion/common/TableSpec.java
(100%)
rename {pinot-batch-ingestion/pinot-standalone =>
pinot-plugins/pinot-batch-ingestion/pinot-batch-ingestion-base}/src/main/java/org/apache/pinot/ingestion/standalone/SegmentGenerationJobRunner.java
(100%)
rename {pinot-batch-ingestion/pinot-standalone =>
pinot-plugins/pinot-batch-ingestion/pinot-batch-ingestion-base}/src/main/java/org/apache/pinot/ingestion/standalone/SegmentTarPushJobRunner.java
(100%)
rename {pinot-batch-ingestion/pinot-standalone =>
pinot-plugins/pinot-batch-ingestion/pinot-batch-ingestion-base}/src/main/java/org/apache/pinot/ingestion/standalone/SegmentUriPushJobRunner.java
(100%)
rename {pinot-batch-ingestion/pinot-standalone =>
pinot-plugins/pinot-batch-ingestion/pinot-batch-ingestion-base}/src/main/java/org/apache/pinot/ingestion/standalone/StandaloneIngestionJobLauncher.java
(100%)
rename {pinot-batch-ingestion/pinot-standalone =>
pinot-plugins/pinot-batch-ingestion/pinot-batch-ingestion-base}/src/main/resources/segmentCreationAndTarPushJobSpec.yaml
(100%)
rename {pinot-batch-ingestion/pinot-standalone =>
pinot-plugins/pinot-batch-ingestion/pinot-batch-ingestion-base}/src/main/resources/segmentCreationAndUriPushJobSpec.yaml
(100%)
rename {pinot-batch-ingestion/pinot-standalone =>
pinot-plugins/pinot-batch-ingestion/pinot-batch-ingestion-base}/src/main/resources/segmentCreationJobSpec.yaml
(100%)
rename {pinot-batch-ingestion/pinot-standalone =>
pinot-plugins/pinot-batch-ingestion/pinot-batch-ingestion-base}/src/main/resources/segmentTarPushJobSpec.yaml
(100%)
rename {pinot-batch-ingestion/pinot-standalone =>
pinot-plugins/pinot-batch-ingestion/pinot-batch-ingestion-base}/src/main/resources/segmentUriPushJobSpec.yaml
(100%)
copy {pinot-batch-ingestion => pinot-plugins/pinot-batch-ingestion}/pom.xml
(88%)
rename {pinot-batch-ingestion =>
pinot-plugins/pinot-batch-ingestion/v0_deprecated}/pinot-hadoop/README.md (100%)
rename {pinot-batch-ingestion =>
pinot-plugins/pinot-batch-ingestion/v0_deprecated}/pinot-hadoop/pom.xml (98%)
rename {pinot-batch-ingestion =>
pinot-plugins/pinot-batch-ingestion/v0_deprecated}/pinot-hadoop/src/main/java/org/apache/pinot/hadoop/PinotHadoopJobLauncher.java
(100%)
rename {pinot-batch-ingestion =>
pinot-plugins/pinot-batch-ingestion/v0_deprecated}/pinot-hadoop/src/main/java/org/apache/pinot/hadoop/io/CombineAvroKeyInputFormat.java
(100%)
rename {pinot-batch-ingestion =>
pinot-plugins/pinot-batch-ingestion/v0_deprecated}/pinot-hadoop/src/main/java/org/apache/pinot/hadoop/io/FileHandler.java
(100%)
rename {pinot-batch-ingestion =>
pinot-plugins/pinot-batch-ingestion/v0_deprecated}/pinot-hadoop/src/main/java/org/apache/pinot/hadoop/io/JsonPinotOutputFormat.java
(100%)
rename {pinot-batch-ingestion =>
pinot-plugins/pinot-batch-ingestion/v0_deprecated}/pinot-hadoop/src/main/java/org/apache/pinot/hadoop/io/PinotOutputFormat.java
(100%)
rename {pinot-batch-ingestion =>
pinot-plugins/pinot-batch-ingestion/v0_deprecated}/pinot-hadoop/src/main/java/org/apache/pinot/hadoop/io/PinotRecord.java
(100%)
rename {pinot-batch-ingestion =>
pinot-plugins/pinot-batch-ingestion/v0_deprecated}/pinot-hadoop/src/main/java/org/apache/pinot/hadoop/io/PinotRecordSerialization.java
(100%)
rename {pinot-batch-ingestion =>
pinot-plugins/pinot-batch-ingestion/v0_deprecated}/pinot-hadoop/src/main/java/org/apache/pinot/hadoop/io/PinotRecordWriter.java
(100%)
rename {pinot-batch-ingestion =>
pinot-plugins/pinot-batch-ingestion/v0_deprecated}/pinot-hadoop/src/main/java/org/apache/pinot/hadoop/job/HadoopSegmentCreationJob.java
(100%)
rename {pinot-batch-ingestion =>
pinot-plugins/pinot-batch-ingestion/v0_deprecated}/pinot-hadoop/src/main/java/org/apache/pinot/hadoop/job/HadoopSegmentPreprocessingJob.java
(100%)
rename {pinot-batch-ingestion =>
pinot-plugins/pinot-batch-ingestion/v0_deprecated}/pinot-hadoop/src/main/java/org/apache/pinot/hadoop/job/InternalConfigConstants.java
(100%)
rename {pinot-batch-ingestion =>
pinot-plugins/pinot-batch-ingestion/v0_deprecated}/pinot-hadoop/src/main/java/org/apache/pinot/hadoop/job/mappers/SegmentCreationMapper.java
(100%)
rename {pinot-batch-ingestion =>
pinot-plugins/pinot-batch-ingestion/v0_deprecated}/pinot-hadoop/src/main/java/org/apache/pinot/hadoop/job/mappers/SegmentPreprocessingMapper.java
(100%)
rename {pinot-batch-ingestion =>
pinot-plugins/pinot-batch-ingestion/v0_deprecated}/pinot-hadoop/src/main/java/org/apache/pinot/hadoop/job/partitioners/GenericPartitioner.java
(100%)
rename {pinot-batch-ingestion =>
pinot-plugins/pinot-batch-ingestion/v0_deprecated}/pinot-hadoop/src/main/java/org/apache/pinot/hadoop/job/partitioners/PartitionFunctionFactory.java
(100%)
rename {pinot-batch-ingestion =>
pinot-plugins/pinot-batch-ingestion/v0_deprecated}/pinot-hadoop/src/main/java/org/apache/pinot/hadoop/job/reducers/SegmentPreprocessingReducer.java
(100%)
rename {pinot-batch-ingestion =>
pinot-plugins/pinot-batch-ingestion/v0_deprecated}/pinot-hadoop/src/main/java/org/apache/pinot/hadoop/utils/PinotHadoopJobPreparationHelper.java
(100%)
rename {pinot-batch-ingestion =>
pinot-plugins/pinot-batch-ingestion/v0_deprecated}/pinot-hadoop/src/test/java/org/apache/pinot/hadoop/io/DeleteExtraPushedSegmentsTest.java
(100%)
rename {pinot-batch-ingestion =>
pinot-plugins/pinot-batch-ingestion/v0_deprecated}/pinot-hadoop/src/test/java/org/apache/pinot/hadoop/io/PinotOutputFormatTest.java
(100%)
rename {pinot-batch-ingestion =>
pinot-plugins/pinot-batch-ingestion/v0_deprecated}/pinot-hadoop/src/test/java/org/apache/pinot/hadoop/job/mappers/SegmentCreationTest.java
(100%)
rename {pinot-batch-ingestion =>
pinot-plugins/pinot-batch-ingestion/v0_deprecated}/pinot-ingestion-common/pom.xml
(96%)
rename {pinot-batch-ingestion =>
pinot-plugins/pinot-batch-ingestion/v0_deprecated}/pinot-ingestion-common/src/main/java/org/apache/pinot/ingestion/common/ControllerRestApi.java
(100%)
rename {pinot-batch-ingestion =>
pinot-plugins/pinot-batch-ingestion/v0_deprecated}/pinot-ingestion-common/src/main/java/org/apache/pinot/ingestion/common/DefaultControllerRestApi.java
(100%)
rename {pinot-batch-ingestion =>
pinot-plugins/pinot-batch-ingestion/v0_deprecated}/pinot-ingestion-common/src/main/java/org/apache/pinot/ingestion/common/JobConfigConstants.java
(100%)
rename {pinot-batch-ingestion =>
pinot-plugins/pinot-batch-ingestion/v0_deprecated}/pinot-ingestion-common/src/main/java/org/apache/pinot/ingestion/common/PinotIngestionJobType.java
(100%)
rename {pinot-batch-ingestion =>
pinot-plugins/pinot-batch-ingestion/v0_deprecated}/pinot-ingestion-common/src/main/java/org/apache/pinot/ingestion/jobs/BaseSegmentJob.java
(100%)
rename {pinot-batch-ingestion =>
pinot-plugins/pinot-batch-ingestion/v0_deprecated}/pinot-ingestion-common/src/main/java/org/apache/pinot/ingestion/jobs/SegmentCreationJob.java
(100%)
rename {pinot-batch-ingestion =>
pinot-plugins/pinot-batch-ingestion/v0_deprecated}/pinot-ingestion-common/src/main/java/org/apache/pinot/ingestion/jobs/SegmentPreprocessingJob.java
(100%)
rename {pinot-batch-ingestion =>
pinot-plugins/pinot-batch-ingestion/v0_deprecated}/pinot-ingestion-common/src/main/java/org/apache/pinot/ingestion/jobs/SegmentTarPushJob.java
(100%)
rename {pinot-batch-ingestion =>
pinot-plugins/pinot-batch-ingestion/v0_deprecated}/pinot-ingestion-common/src/main/java/org/apache/pinot/ingestion/jobs/SegmentUriPushJob.java
(100%)
rename {pinot-batch-ingestion =>
pinot-plugins/pinot-batch-ingestion/v0_deprecated}/pinot-ingestion-common/src/main/java/org/apache/pinot/ingestion/utils/JobPreparationHelper.java
(100%)
rename {pinot-batch-ingestion =>
pinot-plugins/pinot-batch-ingestion/v0_deprecated}/pinot-ingestion-common/src/main/java/org/apache/pinot/ingestion/utils/PushLocation.java
(100%)
rename {pinot-batch-ingestion =>
pinot-plugins/pinot-batch-ingestion/v0_deprecated}/pinot-spark/README.md (100%)
rename {pinot-batch-ingestion =>
pinot-plugins/pinot-batch-ingestion/v0_deprecated}/pinot-spark/pom.xml (98%)
rename {pinot-batch-ingestion =>
pinot-plugins/pinot-batch-ingestion/v0_deprecated}/pinot-spark/src/main/java/org/apache/pinot/spark/PinotSparkJobLauncher.java
(100%)
rename {pinot-batch-ingestion =>
pinot-plugins/pinot-batch-ingestion/v0_deprecated}/pinot-spark/src/main/java/org/apache/pinot/spark/jobs/SparkSegmentCreationFunction.java
(100%)
rename {pinot-batch-ingestion =>
pinot-plugins/pinot-batch-ingestion/v0_deprecated}/pinot-spark/src/main/java/org/apache/pinot/spark/jobs/SparkSegmentCreationJob.java
(100%)
rename {pinot-batch-ingestion =>
pinot-plugins/pinot-batch-ingestion/v0_deprecated}/pinot-spark/src/main/java/org/apache/pinot/spark/jobs/SparkSegmentTarPushJob.java
(100%)
rename {pinot-batch-ingestion =>
pinot-plugins/pinot-batch-ingestion/v0_deprecated}/pinot-spark/src/main/java/org/apache/pinot/spark/jobs/SparkSegmentUriPushJob.java
(100%)
rename {pinot-batch-ingestion =>
pinot-plugins/pinot-batch-ingestion/v0_deprecated}/pinot-spark/src/main/java/org/apache/pinot/spark/utils/PinotSparkJobPreparationHelper.java
(100%)
rename {pinot-batch-ingestion =>
pinot-plugins/pinot-batch-ingestion/v0_deprecated}/pom.xml (91%)
rename {pinot-azure-filesystem =>
pinot-plugins/pinot-file-system/pinot-adls}/pom.xml (89%)
rename {pinot-azure-filesystem =>
pinot-plugins/pinot-file-system/pinot-adls}/src/main/java/org/apache/pinot/filesystem/AzurePinotFS.java
(100%)
rename {pinot-azure-filesystem =>
pinot-plugins/pinot-file-system/pinot-adls}/src/test/java/com/microsoft/azure/datalake/store/MockADLFileInputStream.java
(100%)
rename {pinot-azure-filesystem =>
pinot-plugins/pinot-file-system/pinot-adls}/src/test/java/org/apache/pinot/filesystem/test/AzurePinotFSTest.java
(100%)
rename {pinot-gcs-filesystem =>
pinot-plugins/pinot-file-system/pinot-gcs}/pom.xml (89%)
rename {pinot-gcs-filesystem =>
pinot-plugins/pinot-file-system/pinot-gcs}/src/main/java/org/apache/pinot/filesystem/GcsPinotFS.java
(100%)
rename {pinot-hadoop-filesystem =>
pinot-plugins/pinot-file-system/pinot-hdfs}/pom.xml (95%)
rename {pinot-hadoop-filesystem =>
pinot-plugins/pinot-file-system/pinot-hdfs}/src/main/java/org/apache/pinot/filesystem/HadoopPinotFS.java
(100%)
copy {pinot-connectors => pinot-plugins/pinot-file-system}/pom.xml (88%)
rename {pinot-record-readers =>
pinot-plugins/pinot-input-format}/pinot-avro/pom.xml (96%)
rename {pinot-record-readers =>
pinot-plugins/pinot-input-format}/pinot-avro/src/main/java/org/apache/pinot/avro/data/readers/AvroRecordReader.java
(100%)
rename {pinot-record-readers =>
pinot-plugins/pinot-input-format}/pinot-avro/src/main/java/org/apache/pinot/avro/data/readers/AvroSchemaUtil.java
(100%)
rename {pinot-record-readers =>
pinot-plugins/pinot-input-format}/pinot-avro/src/main/java/org/apache/pinot/avro/data/readers/AvroUtils.java
(100%)
rename {pinot-record-readers =>
pinot-plugins/pinot-input-format}/pinot-avro/src/test/java/org/apache/pinot/avro/data/readers/AvroRecordReaderTest.java
(100%)
rename {pinot-record-readers =>
pinot-plugins/pinot-input-format}/pinot-csv/pom.xml (96%)
rename {pinot-record-readers =>
pinot-plugins/pinot-input-format}/pinot-csv/src/main/java/org/apache/pinot/csv/data/readers/CSVRecordReader.java
(100%)
rename {pinot-record-readers =>
pinot-plugins/pinot-input-format}/pinot-csv/src/main/java/org/apache/pinot/csv/data/readers/CSVRecordReaderConfig.java
(100%)
rename {pinot-record-readers =>
pinot-plugins/pinot-input-format}/pinot-csv/src/test/java/org/apache/pinot/csv/data/readers/CSVRecordReaderTest.java
(100%)
rename {pinot-record-readers =>
pinot-plugins/pinot-input-format}/pinot-json/pom.xml (96%)
rename {pinot-record-readers =>
pinot-plugins/pinot-input-format}/pinot-json/src/main/java/org/apache/pinot/json/data/readers/JSONRecordReader.java
(100%)
rename {pinot-record-readers =>
pinot-plugins/pinot-input-format}/pinot-json/src/test/java/org/apache/pinot/json/data/readers/JSONRecordReaderTest.java
(100%)
rename {pinot-record-readers =>
pinot-plugins/pinot-input-format}/pinot-orc/pom.xml (96%)
rename {pinot-record-readers =>
pinot-plugins/pinot-input-format}/pinot-orc/src/main/java/org/apache/pinot/orc/data/readers/ORCRecordReader.java
(100%)
rename {pinot-record-readers =>
pinot-plugins/pinot-input-format}/pinot-orc/src/test/java/org/apache/pinot/orc/data/readers/ORCRecordReaderTest.java
(100%)
rename {pinot-record-readers =>
pinot-plugins/pinot-input-format}/pinot-parquet/pom.xml (97%)
rename {pinot-record-readers =>
pinot-plugins/pinot-input-format}/pinot-parquet/src/main/java/org/apache/pinot/parquet/data/readers/ParquetRecordReader.java
(100%)
rename {pinot-record-readers =>
pinot-plugins/pinot-input-format}/pinot-parquet/src/main/java/org/apache/pinot/parquet/data/readers/ParquetUtils.java
(100%)
rename {pinot-record-readers =>
pinot-plugins/pinot-input-format}/pinot-parquet/src/test/java/org/apache/pinot/parquet/data/readers/ParquetRecordReaderTest.java
(100%)
rename {pinot-record-readers =>
pinot-plugins/pinot-input-format}/pinot-thrift/pom.xml (96%)
rename {pinot-record-readers =>
pinot-plugins/pinot-input-format}/pinot-thrift/src/main/java/org/apache/pinot/thrift/data/readers/ThriftRecordReader.java
(100%)
rename {pinot-record-readers =>
pinot-plugins/pinot-input-format}/pinot-thrift/src/main/java/org/apache/pinot/thrift/data/readers/ThriftRecordReaderConfig.java
(100%)
rename {pinot-record-readers =>
pinot-plugins/pinot-input-format}/pinot-thrift/src/test/java/org/apache/pinot/thrift/data/readers/ThriftRecordReaderTest.java
(100%)
rename {pinot-record-readers =>
pinot-plugins/pinot-input-format}/pinot-thrift/src/test/java/org/apache/pinot/thrift/data/readers/ThriftSampleData.java
(100%)
copy {pinot-record-readers => pinot-plugins/pinot-input-format}/pom.xml (91%)
rename {pinot-connectors => pinot-plugins/pinot-stream-ingestion}/README.md
(100%)
rename {pinot-connectors/pinot-connector-kafka-0.9 =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-0.9}/README.md (100%)
rename {pinot-connectors/pinot-connector-kafka-0.9 =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-0.9}/pom.xml (89%)
rename {pinot-connectors/pinot-connector-kafka-0.9 =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-0.9}/src/main/java/org/apache/pinot/core/realtime/impl/kafka/ConsumerAndIterator.java
(100%)
rename {pinot-connectors/pinot-connector-kafka-0.9 =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-0.9}/src/main/java/org/apache/pinot/core/realtime/impl/kafka/KafkaBrokerWrapper.java
(100%)
rename {pinot-connectors/pinot-connector-kafka-0.9 =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-0.9}/src/main/java/org/apache/pinot/core/realtime/impl/kafka/KafkaConnectionHandler.java
(100%)
rename {pinot-connectors/pinot-connector-kafka-0.9 =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-0.9}/src/main/java/org/apache/pinot/core/realtime/impl/kafka/KafkaConsumerFactory.java
(100%)
rename {pinot-connectors/pinot-connector-kafka-0.9 =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-0.9}/src/main/java/org/apache/pinot/core/realtime/impl/kafka/KafkaConsumerManager.java
(100%)
rename {pinot-connectors/pinot-connector-kafka-0.9 =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-0.9}/src/main/java/org/apache/pinot/core/realtime/impl/kafka/KafkaHighLevelStreamConfig.java
(100%)
rename {pinot-connectors/pinot-connector-kafka-0.9 =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-0.9}/src/main/java/org/apache/pinot/core/realtime/impl/kafka/KafkaLowLevelStreamConfig.java
(100%)
rename {pinot-connectors/pinot-connector-kafka-0.9 =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-0.9}/src/main/java/org/apache/pinot/core/realtime/impl/kafka/KafkaPartitionLevelConsumer.java
(100%)
rename {pinot-connectors/pinot-connector-kafka-0.9 =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-0.9}/src/main/java/org/apache/pinot/core/realtime/impl/kafka/KafkaSimpleConsumerFactory.java
(100%)
rename {pinot-connectors/pinot-connector-kafka-0.9 =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-0.9}/src/main/java/org/apache/pinot/core/realtime/impl/kafka/KafkaSimpleConsumerFactoryImpl.java
(100%)
rename {pinot-connectors/pinot-connector-kafka-0.9 =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-0.9}/src/main/java/org/apache/pinot/core/realtime/impl/kafka/KafkaStreamLevelConsumer.java
(100%)
rename {pinot-connectors/pinot-connector-kafka-0.9 =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-0.9}/src/main/java/org/apache/pinot/core/realtime/impl/kafka/KafkaStreamMetadataProvider.java
(100%)
rename {pinot-connectors/pinot-connector-kafka-0.9 =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-0.9}/src/main/java/org/apache/pinot/core/realtime/impl/kafka/SimpleConsumerFactory.java
(100%)
rename {pinot-connectors/pinot-connector-kafka-0.9 =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-0.9}/src/main/java/org/apache/pinot/core/realtime/impl/kafka/SimpleConsumerMessageBatch.java
(100%)
rename {pinot-connectors/pinot-connector-kafka-0.9 =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-0.9}/src/main/java/org/apache/pinot/core/realtime/impl/kafka/server/KafkaDataProducer.java
(100%)
rename {pinot-connectors/pinot-connector-kafka-0.9 =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-0.9}/src/main/java/org/apache/pinot/core/realtime/impl/kafka/server/KafkaDataServerStartable.java
(100%)
rename {pinot-connectors/pinot-connector-kafka-0.9 =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-0.9}/src/main/resources/META-INF/services/org.apache.pinot.spi.stream.StreamConsumerFactory
(100%)
rename {pinot-connectors/pinot-connector-kafka-0.9 =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-0.9}/src/test/java/org/apache/pinot/core/realtime/impl/kafka/KafkaLowLevelStreamConfigTest.java
(100%)
rename {pinot-connectors/pinot-connector-kafka-0.9 =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-0.9}/src/test/java/org/apache/pinot/core/realtime/impl/kafka/KafkaPartitionLevelConsumerTest.java
(100%)
rename {pinot-connectors/pinot-connector-kafka-2.0 =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-2.0}/README.md (100%)
rename {pinot-connectors/pinot-connector-kafka-2.0 =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-2.0}/pom.xml (91%)
rename {pinot-connectors/pinot-connector-kafka-2.0 =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-2.0}/src/main/java/org/apache/pinot/core/realtime/impl/kafka2/KafkaConsumerFactory.java
(100%)
rename {pinot-connectors/pinot-connector-kafka-2.0 =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-2.0}/src/main/java/org/apache/pinot/core/realtime/impl/kafka2/KafkaMessageBatch.java
(100%)
rename {pinot-connectors/pinot-connector-kafka-2.0 =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-2.0}/src/main/java/org/apache/pinot/core/realtime/impl/kafka2/KafkaPartitionLevelConnectionHandler.java
(100%)
rename {pinot-connectors/pinot-connector-kafka-2.0 =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-2.0}/src/main/java/org/apache/pinot/core/realtime/impl/kafka2/KafkaPartitionLevelConsumer.java
(100%)
rename {pinot-connectors/pinot-connector-kafka-2.0 =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-2.0}/src/main/java/org/apache/pinot/core/realtime/impl/kafka2/KafkaPartitionLevelStreamConfig.java
(100%)
rename {pinot-connectors/pinot-connector-kafka-2.0 =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-2.0}/src/main/java/org/apache/pinot/core/realtime/impl/kafka2/KafkaStreamLevelConsumer.java
(100%)
rename {pinot-connectors/pinot-connector-kafka-2.0 =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-2.0}/src/main/java/org/apache/pinot/core/realtime/impl/kafka2/KafkaStreamLevelConsumerManager.java
(100%)
rename {pinot-connectors/pinot-connector-kafka-2.0 =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-2.0}/src/main/java/org/apache/pinot/core/realtime/impl/kafka2/KafkaStreamLevelStreamConfig.java
(100%)
rename {pinot-connectors/pinot-connector-kafka-2.0 =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-2.0}/src/main/java/org/apache/pinot/core/realtime/impl/kafka2/KafkaStreamMetadataProvider.java
(100%)
rename {pinot-connectors/pinot-connector-kafka-2.0 =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-2.0}/src/main/java/org/apache/pinot/core/realtime/impl/kafka2/server/KafkaDataProducer.java
(100%)
rename {pinot-connectors/pinot-connector-kafka-2.0 =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-2.0}/src/main/java/org/apache/pinot/core/realtime/impl/kafka2/server/KafkaDataServerStartable.java
(100%)
rename {pinot-connectors/pinot-connector-kafka-2.0 =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-2.0}/src/main/resources/META-INF/services/org.apache.pinot.spi.stream.StreamConsumerFactory
(100%)
rename {pinot-connectors/pinot-connector-kafka-2.0 =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-2.0}/src/test/java/org/apache/pinot/core/realtime/impl/kafka2/KafkaPartitionLevelConsumerTest.java
(100%)
rename {pinot-connectors/pinot-connector-kafka-2.0 =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-2.0}/src/test/java/org/apache/pinot/core/realtime/impl/kafka2/KafkaPartitionLevelStreamConfigTest.java
(100%)
rename {pinot-connectors/pinot-connector-kafka-2.0 =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-2.0}/src/test/java/org/apache/pinot/core/realtime/impl/kafka2/utils/EmbeddedZooKeeper.java
(100%)
rename {pinot-connectors/pinot-connector-kafka-2.0 =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-2.0}/src/test/java/org/apache/pinot/core/realtime/impl/kafka2/utils/MiniKafkaCluster.java
(100%)
rename {pinot-connectors/pinot-connector-kafka-base =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-base}/README.md (100%)
rename {pinot-connectors/pinot-connector-kafka-base =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-base}/pom.xml (88%)
rename {pinot-connectors/pinot-connector-kafka-base =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-base}/src/main/java/org/apache/pinot/core/realtime/impl/kafka/KafkaAvroMessageDecoder.java
(100%)
rename {pinot-connectors/pinot-connector-kafka-base =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-base}/src/main/java/org/apache/pinot/core/realtime/impl/kafka/KafkaJSONMessageDecoder.java
(100%)
rename {pinot-connectors/pinot-connector-kafka-base =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-base}/src/main/java/org/apache/pinot/core/realtime/impl/kafka/KafkaStarterUtils.java
(100%)
rename {pinot-connectors/pinot-connector-kafka-base =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-base}/src/main/java/org/apache/pinot/core/realtime/impl/kafka/KafkaStreamConfigProperties.java
(100%)
rename {pinot-connectors/pinot-connector-kafka-base =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-base}/src/main/java/org/apache/pinot/core/realtime/impl/kafka/MessageAndOffset.java
(100%)
rename {pinot-connectors/pinot-connector-kafka-base =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-base}/src/main/java/org/apache/pinot/core/realtime/stream/AvroRecordToPinotRowGenerator.java
(100%)
rename {pinot-connectors/pinot-connector-kafka-base =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-base}/src/main/java/org/apache/pinot/core/realtime/stream/SimpleAvroMessageDecoder.java
(100%)
rename {pinot-connectors/pinot-connector-kafka-base =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-base}/src/test/java/org/apache/pinot/core/realtime/impl/kafka/KafkaJSONMessageDecoderTest.java
(100%)
rename {pinot-connectors/pinot-connector-kafka-base =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-base}/src/test/java/org/apache/pinot/core/realtime/stream/AvroRecordToPinotRowGeneratorTest.java
(100%)
rename {pinot-connectors/pinot-connector-kafka-base =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-base}/src/test/resources/data/test_sample_data.json
(100%)
rename {pinot-connectors/pinot-connector-kafka-base =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-base}/src/test/resources/data/test_sample_data_schema_no_time_field.json
(100%)
rename {pinot-connectors/pinot-connector-kafka-base =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-base}/src/test/resources/data/test_sample_data_schema_with_outgoing_time_spec.json
(100%)
rename {pinot-connectors/pinot-connector-kafka-base =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-base}/src/test/resources/data/test_sample_data_schema_without_outgoing_time_spec.json
(100%)
rename {pinot-connectors => pinot-plugins/pinot-stream-ingestion}/pom.xml (88%)
rename {pinot-record-readers => pinot-plugins}/pom.xml (86%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
