This is an automated email from the ASF dual-hosted git repository.
saurabhd336 pushed a change to branch release-1.0.0-rc
in repository https://gitbox.apache.org/repos/asf/pinot.git
discard b6478ca91f [maven-release-plugin] prepare for next development
iteration
omit d2feb81e6b [maven-release-plugin] prepare release release-1.0.0-rc0
add c6dd50aed7 refactor argmin/max to exprmin/max and make it calcite
compliant (#11296)
add d6b1b4feba Tenant rebalance and status tracking APIs (#11128)
add c229f97a1c Remove the redundant OrderByExpressionContext::isDesc.
(#11316)
add dea2cacea9 Fix a bug in NULL ordering using ordinal. (#11320)
add 93a5a7eb46 separate tags with commas as indicated in action doc
(#11303)
add 5290b80c9b Add Server API to get tenant pools (#11273)
add 8a86c7b1f2 Fix a NullPointerException bug in
ScalarTransformFunctionWrapper. (#11309)
add 4325cf87ec By default ignore virtual columns for select * queries in
v2 (#11327)
add 51da2f5f67 Remove commons-httpclient 3.1 library dependency. (#11277)
add 169797a40b [UI] Show size of table is with replication (#11331)
add cbfb06f777 UI: remove V2 Multi-Stage Query Engine warning (#11336)
add 165008567e [UI] add multi value column in schema table (#11335)
add 807052305c [UI] change UI to show 'Use Multi-Stage Engine' instead of
'Use V2 Engine' (#11338)
add 2d95baa100 Enhance Minion task management (#11315)
add 6764244bf6 Fix CASE WHEN expression operands ordering. (#11328)
add f25f3ed1f2 Cleanup HLC code (#11326)
add 153aeacbd1 Add a test for CASE WHEN scalar function. (#11340)
add 916ac181a8 increase the parquet dependency version (#11337)
add 8318650f2f Add new broker query point for querying multi-stage engine
(#11341)
add 80d3d48d16 [refactor] improve disk read for partial upsert handler
(#10927)
add 8b71e3560e Bump org.codehaus.mojo:sonar-maven-plugin from 2.5 to 2.7.1
(#11352)
add 29e08beda2 Consolidate per function/data type integration test (#11319)
add ddb12dcd28 Fix the wrong query time when the response is empty (#11349)
add 75ab18bfcc Adding vector search example into QuickStart (#11351)
add 4c307e1bb2 Fix the flaky SimpleMinionClusterIntegrationTest (#11357)
add e4220ecea5 getMessageAtIndex should actually return the value in the
streamMessage for compatibility (#11355)
add f82d61b6b7 Provide more detailed/consolidated exceptions (#11363)
add 344f3e0023 Fix a flaky test PinotFSSegmentUploaderTest. (#11366)
add b0c360aae1 [multistage] Early terminate SortOperator if there is a
limit (#11334)
add 3b8390784d [multistage] Support TIMESTAMP type and date ops functions
(#11350)
add 088599f7be Remove presto jdk8 related dependencies (#11285)
add 575398dae0 Remove special routing handling for multiple consuming
segments (#11371)
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (b6478ca91f)
\
N -- N -- N refs/heads/release-1.0.0-rc (575398dae0)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/workflows/pinot_tests.yml | 22 +-
.github/workflows/scripts/.pinot_test.sh | 30 +-
LICENSE-binary | 15 +-
contrib/pinot-fmpp-maven-plugin/pom.xml | 6 +-
pinot-broker/pom.xml | 5 +-
.../broker/api/resources/PinotClientRequest.java | 80 +++-
.../broker/broker/BrokerAdminApiApplication.java | 15 +-
.../requesthandler/BaseBrokerRequestHandler.java | 34 +-
.../requesthandler/BrokerRequestHandler.java | 4 +-
.../BrokerRequestHandlerDelegate.java | 4 +-
.../MultiStageBrokerRequestHandler.java | 10 +-
.../instanceselector/BaseInstanceSelector.java | 20 +-
.../StrictReplicaGroupInstanceSelector.java | 24 +-
...ntSelector.java => DefaultSegmentSelector.java} | 10 +-
.../segmentselector/RealtimeSegmentSelector.java | 163 -------
.../routing/segmentselector/SegmentSelector.java | 12 -
.../segmentselector/SegmentSelectorFactory.java | 7 +-
.../broker/broker/FakeStreamConsumerFactory.java | 9 -
.../segmentselector/SegmentSelectorTest.java | 134 ------
pinot-clients/pinot-java-client/pom.xml | 5 +-
.../java/org/apache/pinot/client/Connection.java | 3 +-
.../client/JsonAsyncHttpPinotClientTransport.java | 58 +--
.../JsonAsyncHttpPinotClientTransportFactory.java | 6 +-
pinot-clients/pinot-jdbc-client/pom.xml | 8 +-
pinot-clients/pom.xml | 6 +-
pinot-common/pom.xml | 53 +--
.../common/function/TransformFunctionType.java | 20 +
.../apache/pinot/common/http/MultiHttpRequest.java | 107 ++---
.../common/http/MultiHttpRequestResponse.java | 31 +-
.../metadata/controllerjob/ControllerJobType.java | 2 +-
.../apache/pinot/common/minion/MinionClient.java | 18 +-
.../common/request/context/LiteralContext.java | 6 +-
.../request/context/OrderByExpressionContext.java | 4 -
.../org/apache/pinot/common/utils/DataSchema.java | 11 +-
.../apache/pinot/common/utils/ExceptionUtils.java | 62 +++
.../org/apache/pinot/common/utils/SchemaUtils.java | 54 ++-
.../org/apache/pinot/common/utils/TlsUtils.java | 57 ---
.../common/utils/config/QueryOptionsUtils.java | 6 -
.../common/utils/webhdfs/WebHdfsV1Client.java | 36 +-
.../apache/pinot/sql/parsers/CalciteSqlParser.java | 28 +-
...MinMaxRewriter.java => ExprMinMaxRewriter.java} | 116 ++---
.../sql/parsers/rewriter/OrdinalsUpdater.java | 15 +-
.../pinot/common/http/MultiHttpRequestTest.java | 29 +-
.../pinot/common/minion/MinionClientTest.java | 7 +-
.../common/utils/config/TableConfigUtilsTest.java | 7 -
.../pinot/sql/parsers/CalciteSqlCompilerTest.java | 12 +-
.../parsers/rewriter/ArgMinMaxRewriterTest.java | 76 ----
.../parsers/rewriter/ExprMinMaxRewriterTest.java | 76 ++++
pinot-compatibility-verifier/pom.xml | 5 +-
pinot-connectors/pinot-flink-connector/pom.xml | 8 +-
pinot-connectors/pinot-spark-2-connector/pom.xml | 5 +-
pinot-connectors/pinot-spark-3-connector/pom.xml | 5 +-
pinot-connectors/pinot-spark-common/pom.xml | 5 +-
pinot-connectors/pom.xml | 18 +-
.../pinot-common-jdk8/pom.xml | 438 ------------------
.../pinot-common-jdk8/src | 1 -
.../pinot-segment-spi-jdk8/pom.xml | 90 ----
.../pinot-segment-spi-jdk8/src | 1 -
.../pinot-spi-jdk8/pom.xml | 138 ------
.../prestodb-pinot-dependencies/pinot-spi-jdk8/src | 1 -
.../prestodb-pinot-dependencies/pom.xml | 78 ----
pinot-controller/pom.xml | 5 +-
.../pinot/controller/BaseControllerStarter.java | 24 +-
.../controller/api/resources/DebugResource.java | 4 +-
.../api/resources/PinotRealtimeTableResource.java | 4 +-
.../api/resources/PinotRunningQueryResource.java | 62 +--
.../api/resources/PinotSegmentRestletResource.java | 4 +-
.../PinotSegmentUploadDownloadRestletResource.java | 4 +-
.../api/resources/PinotTableRestletResource.java | 4 +-
.../api/resources/PinotTaskRestletResource.java | 6 +-
.../api/resources/PinotTenantRestletResource.java | 55 +++
.../api/resources/ServerTableSizeReader.java | 6 +-
.../pinot/controller/api/resources/TableSize.java | 4 +-
.../TenantRebalanceJobStatusResponse.java | 43 ++
.../api/upload/SegmentValidationUtils.java | 4 +-
.../controller/helix/RealtimeConsumerMonitor.java | 5 +-
.../controller/helix/SegmentStatusChecker.java | 4 +-
.../helix/core/minion/ClusterInfoAccessor.java | 8 +-
.../core/minion/PinotHelixTaskResourceManager.java | 343 ++++++++-------
.../helix/core/minion/PinotTaskManager.java | 4 +-
.../core/minion/generator/TaskGeneratorUtils.java | 51 +--
.../helix/core/rebalance/RebalanceContext.java | 138 ++++++
.../helix/core/rebalance/RebalanceResult.java | 5 +
.../rebalance/tenant/DefaultTenantRebalancer.java | 234 ++++++++++
.../rebalance/tenant/TenantRebalanceContext.java | 81 ++++
.../rebalance/tenant/TenantRebalanceObserver.java} | 28 +-
.../tenant/TenantRebalanceProgressStats.java | 114 +++++
.../rebalance/tenant/TenantRebalanceResult.java | 59 +++
.../core/rebalance/tenant/TenantRebalancer.java} | 18 +-
.../tenant/ZkBasedTenantRebalanceObserver.java | 116 +++++
.../helix/core/relocation/SegmentRelocator.java | 6 +-
.../controller/util/CompletionServiceHelper.java | 35 +-
.../util/ConsumingSegmentInfoReader.java | 6 +-
.../util/ServerSegmentMetadataReader.java | 6 +-
.../controller/util/ServerTableTierReader.java | 6 +-
.../util/TableIngestionStatusHelper.java | 5 +-
.../pinot/controller/util/TableMetadataReader.java | 6 +-
.../pinot/controller/util/TableSizeReader.java | 6 +-
.../pinot/controller/util/TableTierReader.java | 6 +-
.../src/main/resources/app/pages/Query.tsx | 6 +-
.../main/resources/app/pages/SchemaPageDetails.tsx | 2 +-
.../main/resources/app/pages/TablesListingPage.tsx | 4 +-
.../src/main/resources/app/pages/TenantDetails.tsx | 6 +-
.../src/main/resources/app/pages/Tenants.tsx | 4 +-
.../src/main/resources/app/utils/Utils.tsx | 16 +-
.../ConsumingSegmentInfoReaderStatelessTest.java | 6 +-
.../controller/api/PinotSegmentsMetadataTest.java | 6 +-
.../controller/api/ServerTableSizeReaderTest.java | 5 +-
.../pinot/controller/api/TableSizeReaderTest.java | 6 +-
.../pinot/controller/api/TableTierReaderTest.java | 6 +-
.../minion/PinotHelixTaskResourceManagerTest.java | 124 +++---
.../rebalance/tenant/TenantRebalancerTest.java | 191 ++++++++
.../core/relocation/SegmentRelocatorTest.java | 6 +-
pinot-core/pom.xml | 5 +-
.../java/org/apache/pinot/core/auth/Actions.java | 1 +
.../apache/pinot/core/common/ObjectSerDeUtils.java | 18 +-
.../core/common/datablock/DataBlockBuilder.java | 13 +-
.../realtime/HLRealtimeSegmentDataManager.java | 489 ---------------------
.../manager/realtime/RealtimeTableDataManager.java | 61 +--
.../SelectionPartiallyOrderedByDescOperation.java | 4 +-
.../function/ArrayLiteralTransformFunction.java | 165 ++++++-
.../function/ScalarTransformFunctionWrapper.java | 28 +-
.../function/AggregationFunctionFactory.java | 20 +-
.../function/ChildAggregationFunction.java | 6 +-
...ava => ChildExprMinMaxAggregationFunction.java} | 6 +-
...va => ParentExprMinMaxAggregationFunction.java} | 178 ++++----
.../ExprMinMaxMeasuringValSetWrapper.java} | 6 +-
.../ExprMinMaxObject.java} | 28 +-
.../ExprMinMaxProjectionValSetWrapper.java} | 6 +-
.../ExprMinMaxWrapperValSet.java} | 6 +-
.../core/query/executor/sql/SqlQueryExecutor.java | 3 +-
.../context/utils/QueryContextConverterUtils.java | 24 +-
.../realtime/PinotFSSegmentUploaderTest.java | 2 +-
.../BrokerRequestToQueryContextConverterTest.java | 8 +-
.../impl/fakestream/FakeStreamConsumerFactory.java | 8 -
.../{ArgMinMaxTest.java => ExprMinMaxTest.java} | 149 ++++---
.../queries/NullHandlingEnabledQueriesTest.java | 65 +++
pinot-distribution/pom.xml | 7 +-
pinot-integration-test-base/pom.xml | 5 +-
.../tests/BaseClusterIntegrationTest.java | 13 +-
.../tests/ClusterIntegrationTestUtils.java | 32 +-
.../pinot/integration/tests/ClusterTest.java | 27 +-
pinot-integration-tests/pom.xml | 89 +++-
.../tests/NullHandlingIntegrationTest.java | 11 +
.../tests/SimpleMinionClusterIntegrationTest.java | 9 +-
.../CustomDataQueryClusterIntegrationTest.java | 131 ++++++
.../GeoSpatialTest.java} | 83 +---
.../JsonPathTest.java} | 121 ++---
.../MapTypeTest.java} | 95 ++--
.../SumPrecisionTest.java} | 111 ++---
.../TextIndicesTest.java} | 96 ++--
.../ThetaSketchTest.java} | 297 ++++++-------
.../integration/tests/custom/TimestampTest.java | 326 ++++++++++++++
.../TupleSketchTest.java} | 83 +---
.../VectorTest.java} | 94 ++--
.../custom-cluster-integration-test-suite.xml | 26 +-
pinot-minion/pom.xml | 5 +-
pinot-perf/pom.xml | 5 +-
.../pinot-batch-ingestion-common/pom.xml | 6 +-
.../pinot-batch-ingestion-hadoop/pom.xml | 6 +-
.../pinot-batch-ingestion-spark-2.4/pom.xml | 6 +-
.../pinot-batch-ingestion-spark-3.2/pom.xml | 6 +-
.../pinot-batch-ingestion-standalone/pom.xml | 6 +-
pinot-plugins/pinot-batch-ingestion/pom.xml | 6 +-
.../pinot-environment/pinot-azure/pom.xml | 6 +-
pinot-plugins/pinot-environment/pom.xml | 6 +-
pinot-plugins/pinot-file-system/pinot-adls/pom.xml | 5 +-
pinot-plugins/pinot-file-system/pinot-gcs/pom.xml | 6 +-
pinot-plugins/pinot-file-system/pinot-hdfs/pom.xml | 5 +-
pinot-plugins/pinot-file-system/pinot-s3/pom.xml | 9 +-
pinot-plugins/pinot-file-system/pom.xml | 6 +-
.../pinot-input-format/pinot-avro-base/pom.xml | 5 +-
.../pinot-input-format/pinot-avro/pom.xml | 5 +-
.../pinot-input-format/pinot-clp-log/pom.xml | 5 +-
.../pinot-confluent-avro/pom.xml | 5 +-
pinot-plugins/pinot-input-format/pinot-csv/pom.xml | 5 +-
.../pinot-input-format/pinot-json/pom.xml | 5 +-
pinot-plugins/pinot-input-format/pinot-orc/pom.xml | 6 +-
.../pinot-input-format/pinot-parquet/pom.xml | 5 +-
.../pinot-input-format/pinot-protobuf/pom.xml | 5 +-
.../pinot-input-format/pinot-thrift/pom.xml | 5 +-
pinot-plugins/pinot-input-format/pom.xml | 6 +-
.../pinot-metrics/pinot-dropwizard/pom.xml | 5 +-
pinot-plugins/pinot-metrics/pinot-yammer/pom.xml | 5 +-
pinot-plugins/pinot-metrics/pom.xml | 6 +-
.../pinot-minion-builtin-tasks/pom.xml | 5 +-
pinot-plugins/pinot-minion-tasks/pom.xml | 6 +-
.../pinot-segment-uploader-default/pom.xml | 6 +-
pinot-plugins/pinot-segment-uploader/pom.xml | 6 +-
.../pinot-segment-writer-file-based/pom.xml | 6 +-
pinot-plugins/pinot-segment-writer/pom.xml | 6 +-
.../pinot-stream-ingestion/pinot-kafka-2.0/pom.xml | 6 +-
.../stream/kafka20/KafkaConsumerFactory.java | 8 -
.../stream/kafka20/KafkaStreamLevelConsumer.java | 158 -------
.../kafka20/KafkaStreamLevelConsumerManager.java | 199 ---------
.../kafka20/KafkaStreamLevelStreamConfig.java | 133 ------
.../pinot-kafka-base/pom.xml | 6 +-
.../pinot-stream-ingestion/pinot-kinesis/pom.xml | 12 +-
.../stream/kinesis/KinesisConsumerFactory.java | 9 -
.../pinot-stream-ingestion/pinot-pulsar/pom.xml | 6 +-
.../stream/pulsar/PulsarConsumerFactory.java | 8 -
.../plugin/stream/pulsar/PulsarMessageBatch.java | 6 +
.../stream/pulsar/PulsarStreamLevelConsumer.java | 114 -----
.../pulsar/PulsarStreamLevelConsumerManager.java | 193 --------
pinot-plugins/pinot-stream-ingestion/pom.xml | 6 +-
pinot-plugins/pom.xml | 11 +-
pinot-query-planner/pom.xml | 5 +-
.../apache/pinot/query/catalog/PinotCatalog.java | 5 +-
.../query/parser/CalciteRexExpressionParser.java | 5 +
.../planner/logical/RelToPlanNodeConverter.java | 13 +
.../pinot/query/planner/logical/RexExpression.java | 5 +
.../query/planner/logical/RexExpressionUtils.java | 9 +
.../pinot/query/planner/plannode/ValueNode.java | 12 +
.../org/apache/pinot/query/validate/Validator.java | 89 ++++
.../src/test/resources/queries/JoinPlans.json | 19 +
pinot-query-runtime/pom.xml | 5 +-
.../pinot/query/mailbox/GrpcSendingMailbox.java | 46 +-
.../query/mailbox/InMemorySendingMailbox.java | 28 +-
.../pinot/query/mailbox/ReceivingMailbox.java | 28 +-
.../apache/pinot/query/mailbox/SendingMailbox.java | 6 +
.../mailbox/channel/MailboxContentObserver.java | 28 +-
.../query/runtime/blocks/TransferableBlock.java | 7 -
.../runtime/operator/MailboxSendOperator.java | 51 ++-
.../pinot/query/runtime/operator/SortOperator.java | 15 +-
.../runtime/operator/exchange/BlockExchange.java | 19 +-
.../query/service/dispatch/QueryDispatcher.java | 9 +-
.../pinot/query/mailbox/MailboxServiceTest.java | 16 +-
.../pinot/query/runtime/QueryRunnerTestBase.java | 2 +
pinot-segment-local/pom.xml | 5 +-
...oncurrentMapPartitionUpsertMetadataManager.java | 11 +-
.../segment/local/upsert/PartialUpsertHandler.java | 66 ++-
.../local/upsert/PartialUpsertHandlerTest.java | 143 +++---
pinot-segment-spi/pom.xml | 5 +-
.../pinot/segment/spi/AggregationFunctionType.java | 34 +-
pinot-server/pom.xml | 5 +-
.../server/api/resources/InstanceResource.java | 23 +
pinot-spi/pom.xml | 5 +-
.../pinot/spi/stream/StreamConsumerFactory.java | 8 +-
.../apache/pinot/spi/utils/CommonConstants.java | 2 +-
.../spi/data/readers/AbstractRecordReaderTest.java | 2 +-
pinot-tools/pom.xml | 5 +-
.../org/apache/pinot/tools/BootstrapTableTool.java | 3 +-
.../pinot/tools/MultistageEngineQuickStart.java | 203 +++++++++
.../org/apache/pinot/tools/QuickStartBase.java | 1 +
.../java/org/apache/pinot/tools/Quickstart.java | 202 +++++++++
.../tools/admin/command/ChangeTableState.java | 33 +-
.../fineFoodReviews_offline_table_config.json | 21 +
.../fineFoodReviews/fineFoodReviews_schema.json | 40 ++
.../batch/fineFoodReviews/ingestionJobSpec.yaml | 130 ++++++
...ne_food_reviews_with_embeddings_1k.parquet.gzip | Bin 0 -> 6954296 bytes
pom.xml | 105 +----
251 files changed, 4976 insertions(+), 4748 deletions(-)
rename
pinot-broker/src/main/java/org/apache/pinot/broker/routing/segmentselector/{OfflineSegmentSelector.java
=> DefaultSegmentSelector.java} (82%)
delete mode 100644
pinot-broker/src/main/java/org/apache/pinot/broker/routing/segmentselector/RealtimeSegmentSelector.java
delete mode 100644
pinot-broker/src/test/java/org/apache/pinot/broker/routing/segmentselector/SegmentSelectorTest.java
copy
pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/ChildArgMinMaxAggregationFunction.java
=>
pinot-common/src/main/java/org/apache/pinot/common/http/MultiHttpRequestResponse.java
(58%)
create mode 100644
pinot-common/src/main/java/org/apache/pinot/common/utils/ExceptionUtils.java
rename
pinot-common/src/main/java/org/apache/pinot/sql/parsers/rewriter/{ArgMinMaxRewriter.java
=> ExprMinMaxRewriter.java} (52%)
delete mode 100644
pinot-common/src/test/java/org/apache/pinot/sql/parsers/rewriter/ArgMinMaxRewriterTest.java
create mode 100644
pinot-common/src/test/java/org/apache/pinot/sql/parsers/rewriter/ExprMinMaxRewriterTest.java
delete mode 100644
pinot-connectors/prestodb-pinot-dependencies/pinot-common-jdk8/pom.xml
delete mode 120000
pinot-connectors/prestodb-pinot-dependencies/pinot-common-jdk8/src
delete mode 100644
pinot-connectors/prestodb-pinot-dependencies/pinot-segment-spi-jdk8/pom.xml
delete mode 120000
pinot-connectors/prestodb-pinot-dependencies/pinot-segment-spi-jdk8/src
delete mode 100644
pinot-connectors/prestodb-pinot-dependencies/pinot-spi-jdk8/pom.xml
delete mode 120000
pinot-connectors/prestodb-pinot-dependencies/pinot-spi-jdk8/src
delete mode 100644 pinot-connectors/prestodb-pinot-dependencies/pom.xml
create mode 100644
pinot-controller/src/main/java/org/apache/pinot/controller/api/resources/TenantRebalanceJobStatusResponse.java
create mode 100644
pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/rebalance/RebalanceContext.java
create mode 100644
pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/rebalance/tenant/DefaultTenantRebalancer.java
create mode 100644
pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/rebalance/tenant/TenantRebalanceContext.java
copy
pinot-controller/src/main/java/org/apache/pinot/controller/{api/CallableHttpGet.java
=> helix/core/rebalance/tenant/TenantRebalanceObserver.java} (59%)
create mode 100644
pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/rebalance/tenant/TenantRebalanceProgressStats.java
create mode 100644
pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/rebalance/tenant/TenantRebalanceResult.java
rename
pinot-controller/src/main/java/org/apache/pinot/controller/{api/CallableHttpGet.java
=> helix/core/rebalance/tenant/TenantRebalancer.java} (62%)
create mode 100644
pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/rebalance/tenant/ZkBasedTenantRebalanceObserver.java
create mode 100644
pinot-controller/src/test/java/org/apache/pinot/controller/helix/core/rebalance/tenant/TenantRebalancerTest.java
delete mode 100644
pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/HLRealtimeSegmentDataManager.java
rename
pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/{ChildArgMinMaxAggregationFunction.java
=> ChildExprMinMaxAggregationFunction.java} (81%)
rename
pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/{ParentArgMinMaxAggregationFunction.java
=> ParentExprMinMaxAggregationFunction.java} (64%)
rename
pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/utils/{argminmax/ArgMinMaxMeasuringValSetWrapper.java
=> exprminmax/ExprMinMaxMeasuringValSetWrapper.java} (90%)
rename
pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/utils/{argminmax/ArgMinMaxObject.java
=> exprminmax/ExprMinMaxObject.java} (91%)
rename
pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/utils/{argminmax/ArgMinMaxProjectionValSetWrapper.java
=> exprminmax/ExprMinMaxProjectionValSetWrapper.java} (89%)
rename
pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/utils/{argminmax/ArgMinMaxWrapperValSet.java
=> exprminmax/ExprMinMaxWrapperValSet.java} (95%)
rename pinot-core/src/test/java/org/apache/pinot/queries/{ArgMinMaxTest.java
=> ExprMinMaxTest.java} (80%)
create mode 100644
pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/custom/CustomDataQueryClusterIntegrationTest.java
rename
pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/{GeoSpatialClusterIntegrationTest.java
=> custom/GeoSpatialTest.java} (88%)
rename
pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/{JsonPathClusterIntegrationTest.java
=> custom/JsonPathTest.java} (83%)
rename
pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/{MapTypeClusterIntegrationTest.java
=> custom/MapTypeTest.java} (90%)
rename
pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/{SumPrecisionIntegrationTest.java
=> custom/SumPrecisionTest.java} (64%)
rename
pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/{TextIndicesRealtimeClusterIntegrationTest.java
=> custom/TextIndicesTest.java} (75%)
rename
pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/{ThetaSketchIntegrationTest.java
=> custom/ThetaSketchTest.java} (84%)
create mode 100644
pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/custom/TimestampTest.java
rename
pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/{TupleSketchIntegrationTest.java
=> custom/TupleSketchTest.java} (67%)
rename
pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/{VectorIntegrationTest.java
=> custom/VectorTest.java} (79%)
copy pinot-plugins/pinot-batch-ingestion/pinot-batch-ingestion-common/pom.xml
=>
pinot-integration-tests/src/test/resources/custom-cluster-integration-test-suite.xml
(52%)
delete mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-kafka-2.0/src/main/java/org/apache/pinot/plugin/stream/kafka20/KafkaStreamLevelConsumer.java
delete mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-kafka-2.0/src/main/java/org/apache/pinot/plugin/stream/kafka20/KafkaStreamLevelConsumerManager.java
delete mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-kafka-2.0/src/main/java/org/apache/pinot/plugin/stream/kafka20/KafkaStreamLevelStreamConfig.java
delete mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-pulsar/src/main/java/org/apache/pinot/plugin/stream/pulsar/PulsarStreamLevelConsumer.java
delete mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-pulsar/src/main/java/org/apache/pinot/plugin/stream/pulsar/PulsarStreamLevelConsumerManager.java
create mode 100644
pinot-tools/src/main/resources/examples/batch/fineFoodReviews/fineFoodReviews_offline_table_config.json
create mode 100644
pinot-tools/src/main/resources/examples/batch/fineFoodReviews/fineFoodReviews_schema.json
create mode 100644
pinot-tools/src/main/resources/examples/batch/fineFoodReviews/ingestionJobSpec.yaml
create mode 100644
pinot-tools/src/main/resources/examples/batch/fineFoodReviews/rawdata/fine_food_reviews_with_embeddings_1k.parquet.gzip
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org
For additional commands, e-mail: commits-h...@pinot.apache.org
