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/incubator-pinot.git.
from 70ac1bd Clean up KafkaPartitionLevelConsumerTest (#6803)
add 7ce8b75 Add spotless maven plugin to enforce java format. (#6782)
No new revisions were added by this update.
Summary of changes:
.../pinot/broker/api/HttpRequesterIdentity.java | 1 -
.../segmentpruner/SegmentPrunerFactory.java | 1 -
.../broker/broker/BasicAuthAccessControlTest.java | 4 +--
.../client/JsonAsyncHttpPinotClientTransport.java | 1 -
.../pinot/client/AggregationResultSetTest.java | 9 +++----
.../apache/pinot/client/ConnectionFactoryTest.java | 1 -
.../pinot/client/DynamicBrokerSelectorTest.java | 13 +++++-----
.../apache/pinot/client/ExecutionStatsTest.java | 11 ++++----
.../pinot/client/ExternalViewReaderTest.java | 9 +++----
.../apache/pinot/client/GroupByResultSetTest.java | 9 +++----
.../pinot/client/ResultTableResultSetTest.java | 12 ++++-----
.../pinot/client/SelectionResultSetTest.java | 9 +++----
.../org/apache/pinot/client/TextTableTest.java | 6 ++---
.../pinot/client/PinotConnectionMetaData.java | 1 -
.../java/org/apache/pinot/client/PinotDriver.java | 1 -
.../org/apache/pinot/client/PinotResultSet.java | 1 -
.../pinot/client/base/AbstractBaseConnection.java | 2 --
.../pinot/client/base/AbstractBaseResultSet.java | 1 -
.../client/base/AbstractBaseResultSetMetadata.java | 2 --
.../controller/PinotControllerTransport.java | 2 --
.../response/ControllerTenantBrokerResponse.java | 2 --
.../client/controller/response/SchemaResponse.java | 2 --
.../org/apache/pinot/client/utils/DriverUtils.java | 2 --
.../pinot/client/DummyPinotClientTransport.java | 1 -
.../apache/pinot/client/PinotConnectionTest.java | 1 -
.../org/apache/pinot/client/PinotDriverTest.java | 2 --
.../pinot/client/PinotPreparedStatementTest.java | 1 -
.../apache/pinot/client/PinotStatementTest.java | 2 --
.../pinot/common/request/AggregationInfo.java | 1 -
.../apache/pinot/common/request/BrokerRequest.java | 1 -
.../apache/pinot/common/request/DataSource.java | 1 -
.../apache/pinot/common/request/Expression.java | 1 -
.../apache/pinot/common/request/FilterQuery.java | 1 -
.../pinot/common/request/FilterQueryMap.java | 1 -
.../org/apache/pinot/common/request/Function.java | 1 -
.../org/apache/pinot/common/request/GroupBy.java | 1 -
.../pinot/common/request/HavingFilterQuery.java | 1 -
.../pinot/common/request/HavingFilterQueryMap.java | 1 -
.../apache/pinot/common/request/Identifier.java | 1 -
.../pinot/common/request/InstanceRequest.java | 1 -
.../apache/pinot/common/request/PinotQuery.java | 1 -
.../apache/pinot/common/request/QuerySource.java | 1 -
.../org/apache/pinot/common/request/QueryType.java | 1 -
.../org/apache/pinot/common/request/Selection.java | 1 -
.../apache/pinot/common/request/SelectionSort.java | 1 -
.../pinot/common/response/ProcessingException.java | 1 -
.../pinot/common/response/broker/ResultTable.java | 1 -
.../common/utils/ClientSSLContextGenerator.java | 2 --
.../common/utils/config/TableConfigUtils.java | 2 +-
.../common/utils/fetcher/HttpSegmentFetcher.java | 2 --
.../pinot/common/utils/fetcher/SegmentFetcher.java | 1 -
.../pinot/common/utils/helix/TableCache.java | 1 -
.../pql/parsers/pql2/ast/OutputColumnAstNode.java | 1 -
.../config/tuner/RealTimeAutoIndexTunerTest.java | 1 -
.../pinot/common/function/JsonFunctionsTest.java | 2 --
.../metadata/MetadataEqualsHashCodeTest.java | 8 +++---
.../pinot/controller/api/access/Authenticate.java | 1 -
.../api/events/MetadataEventNotifierFactory.java | 1 -
.../controller/api/resources/HeaderAdder.java | 1 -
.../api/resources/PinotSegmentRestletResource.java | 1 -
.../controller/api/resources/PinotTableSchema.java | 2 +-
.../api/resources/ZookeeperResource.java | 2 --
.../helix/core/PinotTableIdealStateBuilder.java | 2 +-
.../SegmentSizeBasedFlushThresholdUpdater.java | 2 +-
.../controller/recommender/RecommenderDriver.java | 4 +--
.../recommender/data/generator/AvroWriter.java | 2 +-
.../recommender/data/generator/DataGenerator.java | 13 +++++-----
.../data/generator/GeneratorFactory.java | 3 +--
.../data/generator/NumberGenerator.java | 4 ---
.../data/generator/PatternSeasonalGenerator.java | 7 +++--
.../data/generator/PatternSequenceGenerator.java | 3 +--
.../data/generator/PatternSpikeGenerator.java | 3 +--
.../data/generator/PatternStringGenerator.java | 3 +--
.../controller/recommender/io/InputManager.java | 9 +++----
.../rules/impl/InvertedSortedIndexJointRule.java | 5 ++--
.../controller/util/AutoAddInvertedIndex.java | 1 -
.../util/ServerSegmentMetadataReader.java | 3 ---
.../api/ControllerFilePathProviderTest.java | 9 +++----
.../controller/api/ServerTableSizeReaderTest.java | 2 +-
...otSegmentUploadDownloadRestletResourceTest.java | 7 +++--
.../pinot/controller/helix/ControllerTest.java | 2 +-
.../OfflineDimTableSegmentAssignmentTest.java | 9 +++----
.../controller/util/ListenerConfigUtilTest.java | 1 -
.../table/UnboundedConcurrentIndexedTable.java | 1 -
.../function/NotEqualsTransformFunction.java | 1 -
.../datetime/BaseDateTimeTransformer.java | 2 +-
.../core/query/config/SegmentPrunerConfig.java | 1 -
.../core/query/pruner/SegmentPrunerProvider.java | 1 -
.../query/scheduler/MultiLevelPriorityQueue.java | 8 ++----
.../core/query/scheduler/PriorityScheduler.java | 13 ++++------
.../query/scheduler/QuerySchedulerFactory.java | 5 +---
.../query/scheduler/fcfs/BoundedFCFSScheduler.java | 2 --
.../query/scheduler/fcfs/FCFSQueryScheduler.java | 7 ++---
.../resources/BoundedAccountingExecutor.java | 1 -
.../resources/PolicyBasedResourceManager.java | 3 +--
.../query/scheduler/resources/ResourceManager.java | 10 +++-----
.../tokenbucket/TokenPriorityScheduler.java | 2 --
.../realtime/PinotFSSegmentUploaderTest.java | 2 --
.../scheduler/MultiLevelPriorityQueueTest.java | 10 +++-----
.../query/scheduler/TestSchedulerGroupFactory.java | 5 ++--
.../resources/BoundedAccountingExecutorTest.java | 1 -
.../scheduler/resources/ResourceManagerTest.java | 11 ++++----
.../resources/UnboundedResourceManagerTest.java | 13 +++++-----
.../fakestream/FakePartitionLevelConsumer.java | 1 -
.../pinot/spi/crypt/PinotCrypterFactoryTest.java | 1 -
.../util/IntDoubleIndexedPriorityQueueTest.java | 2 +-
.../tests/AdminConsoleIntegrationTest.java | 2 --
.../IngestionConfigHybridIntegrationTest.java | 2 +-
.../pinot/perf/BenchmarkGeospatialSerde.java | 2 --
.../pinot/perf/BenchmarkOrDocIdIterator.java | 2 +-
.../HadoopSegmentGenerationJobRunnerTest.java | 7 ++---
.../standalone/SegmentGenerationJobRunnerTest.java | 4 +--
.../job/mappers/SegmentPreprocessingMapper.java | 2 +-
.../job/reducers/SegmentPreprocessingReducer.java | 1 -
.../hadoop/data/IngestionSchemaValidatorTest.java | 2 +-
.../pinot/spark/jobs/SparkSegmentCreationJob.java | 2 +-
.../pinot/spark/jobs/SparkSegmentTarPushJob.java | 9 +++----
.../pinot/spark/jobs/SparkSegmentUriPushJob.java | 9 +++----
.../pinot/plugin/filesystem/AzurePinotFS.java | 16 +++++-------
.../apache/pinot/plugin/filesystem/GcsPinotFS.java | 30 ++++++++++------------
.../pinot/plugin/filesystem/HadoopPinotFS.java | 4 +--
.../pinot/plugin/filesystem/HadoopPinotFSTest.java | 1 -
.../avro/AvroIngestionSchemaValidator.java | 2 +-
...aConfluentSchemaRegistryAvroMessageDecoder.java | 1 -
.../inputformat/thrift/ThriftRecordExtractor.java | 2 +-
.../plugin/inputformat/thrift/ComplexTypes.java | 1 -
.../plugin/inputformat/thrift/NestedType.java | 1 -
.../stream/kafka09/KafkaHighLevelStreamConfig.java | 2 +-
.../stream/kafka09/KafkaLowLevelStreamConfig.java | 2 +-
.../kafka20/KafkaPartitionLevelStreamConfig.java | 2 +-
.../kafka20/KafkaStreamLevelStreamConfig.java | 2 +-
.../stream/kafka/KafkaStreamConfigProperties.java | 1 -
.../stream/kafka/KafkaJSONMessageDecoderTest.java | 2 --
.../partition/ByteArrayPartitionFunction.java | 1 -
.../segment/local/segment/store/IndexEntry.java | 1 -
.../local/segment/index/ColumnMetadataTest.java | 1 -
.../apache/pinot/segment/spi/ImmutableSegment.java | 2 +-
.../org/apache/pinot/segment/spi/IndexSegment.java | 4 +--
.../segment/spi/compression/ChunkDecompressor.java | 9 +++----
.../spi/creator/ColumnIndexCreationInfo.java | 2 +-
.../spi/creator/SegmentPreIndexStatsContainer.java | 1 -
.../creator/name/FixedSegmentNameGenerator.java | 1 -
.../creator/name/SimpleSegmentNameGenerator.java | 1 -
.../pinot/segment/spi/datasource/DataSource.java | 6 ++---
.../creator/RawValueBasedInvertedIndexCreator.java | 1 -
.../spi/index/reader/MutableForwardIndex.java | 2 --
.../segment/spi/index/reader/TextIndexReader.java | 2 --
.../spi/creator/SegmentGeneratorConfigTest.java | 1 -
.../NormalizedDateSegmentNameGeneratorTest.java | 2 --
.../name/SimpleSegmentNameGeneratorTest.java | 2 --
.../server/api/access/AllowAllAccessFactory.java | 1 -
.../apache/pinot/spi/config/table/FieldConfig.java | 3 +--
.../apache/pinot/spi/config/table/QueryConfig.java | 3 +--
.../apache/pinot/spi/config/table/QuotaConfig.java | 1 -
.../config/table/ReplicaGroupStrategyConfig.java | 3 +--
.../spi/config/table/SegmentPartitionConfig.java | 3 +--
.../SegmentsValidationAndRetentionConfig.java | 1 -
.../pinot/spi/config/table/TableCustomConfig.java | 3 +--
.../pinot/spi/config/table/TableTaskConfig.java | 3 +--
.../pinot/spi/config/table/TagOverrideConfig.java | 3 +--
.../pinot/spi/config/table/TenantConfig.java | 3 +--
.../table/ingestion/StreamIngestionConfig.java | 1 -
.../config/table/ingestion/TransformConfig.java | 2 --
.../apache/pinot/spi/crypt/NoOpPinotCrypter.java | 1 -
.../org/apache/pinot/spi/crypt/PinotCrypter.java | 1 -
.../pinot/spi/crypt/PinotCrypterFactory.java | 1 -
.../pinot/spi/data/readers/RecordReaderUtils.java | 6 -----
.../pinot/spi/env/CommonsConfigurationUtils.java | 1 -
.../pinot/spi/env/ConfigFilePropertyReader.java | 1 -
.../spi/env/ConfigFilePropertyReaderFactory.java | 1 -
.../apache/pinot/spi/env/PinotConfiguration.java | 3 ---
.../apache/pinot/spi/filesystem/LocalPinotFS.java | 1 -
.../org/apache/pinot/spi/filesystem/PinotFS.java | 1 -
.../pinot/spi/filesystem/PinotFSFactory.java | 4 +--
.../batch/spec/SegmentGenerationJobSpec.java | 2 --
.../org/apache/pinot/spi/plugin/PluginManager.java | 1 -
.../pinot/spi/stream/StreamConfigProperties.java | 1 -
.../spi/utils/builder/TableConfigBuilder.java | 2 +-
.../data/readers/AbstractRecordExtractorTest.java | 2 --
.../pinot/spi/env/PinotConfigurationTest.java | 1 -
.../pinot/spi/filesystem/PinotFSFactoryTest.java | 1 -
.../pinot/spi/ingestion/batch/BatchConfigTest.java | 1 -
.../pinot/spi/utils/retry/RetryPolicyTest.java | 7 -----
.../org/apache/pinot/tools/JoinQuickStart.java | 5 ++--
.../java/org/apache/pinot/tools/Quickstart.java | 1 -
.../pinot/tools/admin/PinotAdministrator.java | 8 +++---
.../admin/command/AbstractBaseAdminCommand.java | 2 --
.../tools/admin/command/GenerateDataCommand.java | 21 ++++++++-------
.../tools/admin/command/ImportDataCommand.java | 1 -
.../command/RealtimeProvisioningHelperCommand.java | 2 +-
.../tools/filesystem/PinotFSBenchmarkDriver.java | 4 +--
.../org/apache/pinot/tools/perf/QueryRunner.java | 1 -
.../tools/scan/query/ScanBasedQueryProcessor.java | 2 +-
.../service/api/resources/PinotInstanceStatus.java | 1 -
.../pinot/tools/streams/AirlineDataStream.java | 3 ---
pom.xml | 25 ++++++++++++++++++
196 files changed, 223 insertions(+), 427 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
