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/pinot.git.
from 7a44f4a Manually trigger PeriodicTask (#7174)
add 58d86a6 reformat
pinot-perf/pinot-tools/pinot-integration-tests/pinot-minion (#7335)
No new revisions were added by this update.
Summary of changes:
pinot-integration-tests/pom.xml | 2 -
.../pinot/compat/tests/ClusterDescriptor.java | 21 +-
.../org/apache/pinot/compat/tests/SegmentOp.java | 3 +-
.../pinot/compat/tests/SqlResultComparator.java | 2 +
.../org/apache/pinot/compat/tests/StreamOp.java | 3 +-
.../org/apache/pinot/compat/tests/TableOp.java | 2 +
.../java/org/apache/pinot/compat/tests/Utils.java | 2 +
.../tests/BaseClusterIntegrationTest.java | 4 +-
.../tests/BaseClusterIntegrationTestSet.java | 9 +-
.../tests/ChaosMonkeyIntegrationTest.java | 5 +-
.../tests/ClusterIntegrationTestUtils.java | 7 +-
.../pinot/integration/tests/ClusterTest.java | 7 +-
.../tests/JsonPathClusterIntegrationTest.java | 25 +-
.../MergeRollupMinionClusterIntegrationTest.java | 2 +-
.../tests/OfflineClusterIntegrationTest.java | 2 +-
...rDownloadLLCRealtimeClusterIntegrationTest.java | 8 +-
.../pinot/integration/tests/QueryGenerator.java | 22 +-
.../tests/RealtimeKinesisIntegrationTest.java | 56 +-
...fflineSegmentsMinionClusterIntegrationTest.java | 8 +-
pinot-minion/pom.xml | 3 -
pinot-perf/pom.xml | 3 -
.../apache/pinot/perf/BenchmarkCombineGroupBy.java | 4 +-
.../pinot/perf/BenchmarkGeospatialSerde.java | 168 +++---
.../BenchmarkNoDictionaryIntegerCompression.java | 14 +-
.../perf/BenchmarkNoDictionaryLongCompression.java | 14 +-
.../BenchmarkNoDictionaryStringCompression.java | 14 +-
...BenchmarkOffheapBitmapInvertedIndexCreator.java | 29 +-
.../apache/pinot/perf/BenchmarkQueryEngine.java | 10 +-
.../org/apache/pinot/perf/DictionaryDumper.java | 2 +
.../pinot/perf/ForwardIndexWriterBenchmark.java | 5 +-
pinot-tools/pom.xml | 3 -
.../apache/pinot/tools/ClusterStateVerifier.java | 6 +-
.../apache/pinot/tools/PinotNumReplicaChanger.java | 12 +-
.../apache/pinot/tools/PinotTableRebalancer.java | 4 +-
.../org/apache/pinot/tools/PinotZKChanger.java | 26 +-
.../org/apache/pinot/tools/QuickStartBase.java | 2 +-
.../apache/pinot/tools/QuickstartTableRequest.java | 28 +-
.../java/org/apache/pinot/tools/SpeedTest.java | 68 +--
.../apache/pinot/tools/StarTreeIndexViewer.java | 6 +-
.../org/apache/pinot/tools/UpdateSegmentState.java | 20 +-
.../org/apache/pinot/tools/admin/PinotBroker.java | 3 +
.../apache/pinot/tools/admin/PinotController.java | 3 +
.../org/apache/pinot/tools/admin/PinotMinion.java | 3 +
.../org/apache/pinot/tools/admin/PinotServer.java | 3 +
.../tools/admin/PinotServiceManagerStarter.java | 3 +
.../admin/command/ChangeNumReplicasCommand.java | 6 +-
.../tools/admin/command/ImportDataCommand.java | 2 +
.../tools/admin/command/MoveReplicaGroup.java | 132 ++---
.../command/RealtimeProvisioningHelperCommand.java | 1 -
.../command/SegmentProcessorFrameworkCommand.java | 7 +-
.../admin/command/ShowClusterInfoCommand.java | 92 +--
.../tools/admin/command/StartServerCommand.java | 2 +-
.../admin/command/StartServiceManagerCommand.java | 4 +-
.../tools/admin/command/StartZookeeperCommand.java | 2 +-
.../admin/command/StreamAvroIntoKafkaCommand.java | 1 +
.../tools/admin/command/VerifySegmentState.java | 20 +-
.../anonymizer/ArrayBasedGlobalDictionaries.java | 1 +
.../anonymizer/PinotDataAndQueryAnonymizer.java | 6 +-
.../pinot/tools/backfill/BackfillSegmentUtils.java | 2 +-
.../pinot/tools/perf/PerfBenchmarkDriverConf.java | 157 +++---
.../query/comparison/SegmentInfoProvider.java | 3 +
.../tools/query/comparison/StatsGenerator.java | 3 +
.../apache/pinot/tools/scan/query/Aggregation.java | 2 +-
.../tools/scan/query/AggregationFuncFactory.java | 3 +
.../apache/pinot/tools/scan/query/AvgFunction.java | 6 +-
.../pinot/tools/scan/query/CountFunction.java | 6 +-
.../tools/scan/query/DistinctCountFunction.java | 6 +-
.../pinot/tools/scan/query/GroupByOperator.java | 2 +-
.../apache/pinot/tools/scan/query/MaxFunction.java | 4 +-
.../apache/pinot/tools/scan/query/MinFunction.java | 4 +-
.../tools/scan/query/MinMaxRangeFunction.java | 6 +-
.../tools/scan/query/SegmentQueryProcessor.java | 3 +-
.../apache/pinot/tools/scan/query/SumFunction.java | 4 +-
.../org/apache/pinot/tools/scan/query/Utils.java | 2 +
.../pinot/tools/service/PinotServiceManager.java | 6 +-
.../PinotServiceManagerInstanceResource.java | 2 +
.../pinot/tools/streams/AirlineDataStream.java | 76 +--
.../streams/githubevents/GitHubAPICaller.java | 26 +-
.../PullRequestMergedEventsStream.java | 29 +-
.../pinot/tools/utils/KafkaStarterUtils.java | 5 +-
.../apache/pinot/tools/utils/PinotConfigUtils.java | 2 +
...bEvents_offline_complexTypeHandling_schema.json | 81 +--
...s_offline_complexTypeHandling_table_config.json | 4 +-
.../starbucksStores_offline_table_config.json | 4 +-
.../starbucksStores/starbucksStores_schema.json | 1 -
...eHandling_meetupRsvp_realtime_table_config.json | 4 +-
.../complexTypeHandling_meetupRsvp_schema.json | 67 ++-
.../upsert_meetupRsvp_realtime_table_config.json | 4 +-
.../meetupRsvp/upsert_meetupRsvp_schema.json | 4 +-
...t_partial_meetupRsvp_realtime_table_config.json | 6 +-
.../upsert_partial_meetupRsvp_schema.json | 4 +-
pinot-tools/src/main/resources/generator/README.md | 18 +-
.../resources/generator/complexWebsite_config.json | 22 +-
.../generator/complexWebsite_generator.json | 624 +++++++++++++++++++--
.../resources/generator/simpleWebsite_config.json | 22 +-
.../generator/simpleWebsite_generator.json | 22 +-
.../pinot/tools/TestCreateSegmentCommand.java | 15 +-
.../pinot/tools/TestDataAndQueryAnonymizer.java | 4 +-
.../resources/test_data/test_invalid_data.json | 11 +-
99 files changed, 1415 insertions(+), 783 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
