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: commits-unsubscr...@pinot.apache.org For additional commands, e-mail: commits-h...@pinot.apache.org