This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/maven/org.mockito-mockito-bom-5.21.0
in repository https://gitbox.apache.org/repos/asf/pinot.git
omit fb667c796ea Bump org.mockito:mockito-bom from 5.17.0 to 5.21.0
add d1497bf7766 [MSE] Add Row() value expression support in comparison
(#17317)
add 218fdb9b4fd Bump software.amazon.awssdk:bom from 2.40.4 to 2.40.5
(#17344)
add cc776070c56 Always use singleton worker for final sort stage to ensure
hotspot server rotation (#17347)
add 25afc0b9bd2 Enable deep store upload retry for Pauseless by default
(#17241)
add 1091e87acc3 Instrument UNION / UNION ALL operators with calls to
checkTerminationAndSampleUsage (#17322)
add 07a8b895a2d Handle SUM rewrite under null handling (#17338)
add ac818fed738 lead/lag window functions should not fill beyond num rows
(#17348)
add df089db2e30 Adds Disaster Recover Mode as Controller/Cluster config
(#17243)
add 9cf9095c68c Improve CustomDataQueryClusterIntegrationTest to use 2
servers and 2 segments to ensure the behavior of merge is expected. (#17284)
add 4728cb711ce Move DimTable disablePreload default value from Static to
cluster config based (#17313)
add f0cb288cc4f Bump net.openhft:chronicle-bom from 2.27ea93 to 2.27ea94
(#17349)
add d2dc32d0de6 Bump com.gradle:develocity-maven-extension from 2.2.1 to
2.3 (#17351)
add 74f8ccd6f5f Bump software.amazon.awssdk:bom from 2.40.5 to 2.40.6
(#17350)
add 222384fe3b4 make rule timings log debug (#17354)
add 61f35baebee Add operator factory provider for query runtime (#17353)
add 49338d72804 Add usage sampling and query termination in
NonScanBasedAggregationOperator (#17355)
add 52db36c816f Adds ability to pause consumption in batches (#17194)
add 168d39c9a64 Add FlameGraph visualization for query stage stats (#17263)
add 58e5c4afa8e Set merging segment creation time = max(creationTime) + 1
(#17356)
add 68b87b4bcaf Bump software.amazon.awssdk:bom from 2.40.6 to 2.40.7
(#17361)
add ecec72c8ffb Bump net.alchim31.maven:scala-maven-plugin from 4.9.7 to
4.9.8 (#17360)
add 624b90b6d15 Fix ExpressionTransformer collection handling (#17363)
add d19ea952379 Automatically generate package-info.java with not null
annotations (#17327)
add e07e0b0503a Fix typo in PinotFSBenchmarkDriver (#17365)
add c2879f012de Bump com.uber:h3 from 4.3.2 to 4.4.0 (#17370)
add 7761e6fa8a5 Sort servers in WorkerManager to ensure deterministic
workerId <-> server mapping across stages in an MSE query (#17342)
add 9e8cd1ed390 Correctly set tier for IndexLoadingConfig used in
needReload API (#17373)
add f45f1aecd8d Increase scope to allow access for extended classes
(#17343)
add 42715fcc4af Deterministic data-only CRC (1/2) - add data-only CRC
computation for new segments and persist to ZK with new data CRC key (#17264)
add 57dc351e330 Fix query UI partial result flag (#17368)
add d47ea27b4ee Make query routing strategy pluggable (#17364)
add 5f71b152316 Bump org.jetbrains.kotlin:kotlin-bom from 2.2.21 to 2.3.0
(#17383)
add ef7c830abfe Bump software.amazon.awssdk:bom from 2.40.7 to 2.40.9
(#17384)
add 0ae7f87552b Bump org.ow2.asm:asm from 9.9 to 9.9.1 (#17385)
add 3be9fbe1590 Guard against NPE for MSE filtered aggregations (#17386)
add e876ee9895a Bump net.openhft:chronicle-bom from 2.27ea94 to 2.27ea95
(#17388)
add 6bd00f93ff7 Bump maven.version from 3.9.11 to 3.9.12 (#17389)
add d76ce8762ba Bump com.google.cloud:libraries-bom from 26.72.0 to
26.73.0 (#17390)
add 385b197534a Bump software.amazon.awssdk:bom from 2.40.9 to 2.40.10
(#17391)
add 4cd9494bcf3 Bump log4j.version from 2.25.2 to 2.25.3 (#17392)
add 2962dd445fb [bugfix] Initialize LogicalTableMetadataCache with
existing logical tables (#17374)
add a9f36e438ce Followups on column reader changes (#17293)
add 23c36b9621a [timeseries] Adding support for partial results in time
series engine (#17278)
add 58aef210b7b Bump software.amazon.awssdk:bom from 2.40.10 to 2.40.11
(#17397)
add 8fd34ecbf5e Add Query Fingerprint Feature (#17177)
add 33d0ec1dd61 Remove text Index from index map when storeInSegmentFile
flag is true. (#17396)
add bdd834797a7 Fixing ColumnReader interface to return validity bitset in
case of multi-value primitive type (#17387)
add a1e9d302727 Bump software.amazon.awssdk:bom from 2.40.11 to 2.40.12
(#17402)
add 7e7d7eaf243 Allow reload with force download for RT table (#17400)
add c141c8de570 [bugfixing] Fix /debug/routingTable always returning same
replica-group (strictReplicaGroup) (#17403)
add 3b1b33db5d2 Add String functions for regex and distance (#17372)
add 71fbedb313b Pulsar consumer does not need to query for partitions
(#17379)
add 227de91da73 Bump org.asynchttpclient:async-http-client from 3.0.4 to
3.0.5 (#17401)
add 72be4e685d3 Improve error handling in MSE (#17306)
add 3456a598920 Bump software.amazon.awssdk:bom from 2.40.12 to 2.40.13
(#17407)
add 07984249609 Bump org.webjars:swagger-ui from 5.30.3 to 5.31.0 (#17406)
add 95d43c0d317 [federation] Add multi-cluster routing support for
federated broker queries (#17296)
add 7dacea4297f Bump org.codehaus.mojo:exec-maven-plugin from 3.6.2 to
3.6.3 (#17408)
add 6d4df46e788 refactor: remove threshold for sort-exchange copy
transformation (#17328)
add ee5456d83cb Revert "Use stats cache on error instead of the chained
mechanism (#15992)" (#17305)
add e5dba1966c9 Refactor broker routing managers into routing.manager
package and introduce BaseBrokerRoutingManager (#17413)
add e8d5c57488c Add broker metric for query response size bytes (#17412)
add 0f3bbcbb60b Bump software.amazon.awssdk:bom from 2.40.13 to 2.40.14
(#17417)
add 851ac53c674 [timeseries] Replaced prometheus API with broker response
API for Controller UI (#17414)
add dc636e14298 Bump net.openhft:chronicle-bom from 2.27ea95 to 2.27ea96
(#17418)
add c1c06f99010 optimize user login (#17242)
add 29b74252e44 Refactor: Rename BasicAuthUtils to better reflect
responsibilities in each module (#17425)
add 4e8ebf364f0 Bump software.amazon.awssdk:bom from 2.40.14 to 2.40.15
(#17427)
add dae2574f0ed Bump io.grpc:grpc-bom from 1.77.0 to 1.78.0 (#17426)
add c61d3dc10a9 [Query Engine] ANY VALUE Support (#16678)
add 2eeecc5b6d3 Fix GRPC_BYTES_SENT broker metric for gRPC query server
(#17422)
add cf71cc02148 [timeseries] Added query stats panel to timeseries UI
(#17423)
add 5af90157801 [federation] Introduced MultiClusterHelixBrokerStarter to
start broker in federated mode (#17421)
add 9f248c52aff Add InMemoryColumnReader for testing and update
PinotSegmentColumnReaderFactory to support configurable default value readers
(#17415)
add 09bc151104e Add single column transformer (#17304)
add 31724a7690b fix org.codehaus.mojo:animal-sniffer-annotations version
to 1.26 (#17429)
add 6182bed154e Bump software.amazon.awssdk:bom from 2.40.15 to 2.40.16
(#17436)
add 5b2b90d939d [federation] Add multi-cluster routing support for SSE
queries (#17439)
add 2b62eb1fadb Revert Upsert Metadata of a segment during Inconsistencies
(#17324)
add 605cd8a1a97 The Pinot UI should distinguish between a server being up
and being healthy #16775 (#17248)
add 7b26b01608d Bump software.amazon.awssdk:bom from 2.40.16 to 2.41.0
(#17445)
add 26af49e31f7 Bump org.asynchttpclient:async-http-client from 3.0.5 to
3.0.6 (#17448)
add 668bf02520d Create lucene doc Id mapping for offline segments when
storeInSegmentFile is true (#17437)
add 6c87d2e55a0 Bump io.github.hakky54:ayza-bom from 10.0.2 to 10.0.3
(#17451)
add 0023095fae2 Refactor Expression transformer to move sort logic to
utils (#17442)
add 042549dd645 Pinot ui distinguishes between instance liveness and
health (#17450)
add cf07fea14c7 [federation] Add multi-cluster routing support for MSE
queries (#17444)
add c7a8f5c3b59 [timeseries] Added TimeSeriesBlock based exception
propagation (#17440)
add 82b7d2a6632 [timeseries] Adding support for query options (#17454)
add 7d40b9fba49 Broker: add SLA-style per-query error metrics (#17457)
add 7ca198408ce Add consensus check before selecting a segment for
compaction or deletion (#17352)
add b313aa89fc5 Changes in Pinot segment column reader, data source, and
factory to support nulls better and support valid doc IDs. (#17443)
add 301c29bd8ee Refactor PinotTaskManager to dedup code and improve
readability (#17459)
add 477ea83e9d7 Bump net.openhft:chronicle-bom from 2.27ea96 to 2.27ea98
(#17472)
add d33f32763e8 Add Support to tag a minion as Drained (#17375)
add cd08555e186 [Query Engine] Improve DistinctCountSmartHLL for
dictionary-encoded columns (#17411)
add 406c9530f81 Bump org.checkerframework:checker-qual from 3.52.1 to
3.53.0 (#17468)
add 384807d98c5 Bump immutables.version from 2.12.0 to 2.12.1 (#17469)
add 5676cb6107f Bump software.amazon.awssdk:bom from 2.41.0 to 2.41.3
(#17470)
add 6ac2e83eb75 Bump org.apache:apache from 35 to 36 (#17471)
add 6364dd885b1 Bump bouncycastle.version from 1.78.1 to 1.83 (#17461)
add 441765d509a [Minor] Fix mal-formated files (#17473)
add f01e2c80e92 QueryLogger consistently logs received/completed
respecting rate limiter (#17452)
add 714c9358978 Bump orc.version from 1.9.7 to 1.9.8 (#17476)
add ec9b0c6417a [timeseries] Decouple query dispatcher (#17474)
add b6af304039d Bump software.amazon.awssdk:bom from 2.41.3 to 2.41.4
(#17477)
add e4625b797b2 fix field spec sort order (#17467)
add 6b8d273beb8 Bump com.nimbusds:nimbus-jose-jwt from 10.6 to 10.7
(#17479)
add 5421129d3e1 Bump com.google.errorprone:error_prone_annotations from
2.45.0 to 2.46.0 (#17480)
add cf0ce99092e Add new mse metrics (#17419)
add 613274643aa [timeseries] Add support for query event listeners (#17464)
add c23a1e971dc Add GET /minions/status API endpoint (#17475)
add 809426f2944 [Flaky-test] Make simple aggregate query cheaper for
accountant test (#17478)
add 85795a47c5b [bugfix] Removing unnecessary RESOURCE_CONFIG change type
for MultiClusterHelixBrokerStarter (#17482)
add f29f5f673ef fix maven-dependency-plugin to 3.8.1 (#17483)
add 8d52024aa4f Add AGENTS guide for Apache Pinot repo (#17449)
add e16b2d9c5a1 Perf Optimize JSON message decoding by parsing directly to
Map, avoiding intermediate JsonNode (#17485)
add 41898e03fab Remove the reload and force commit checks for Partial
Upserts and dropOutOfOrder=true Upsert Tables (#17458)
add 81418989bb1 support display zookeeper browser when using QuickStart
(#17490)
add a755a7d8f2d Bump org.apache.maven.plugins:maven-dependency-plugin
(#17493)
add bbecbc1aab4 Bump net.openhft:chronicle-bom from 2.27ea98 to 2.27ea99
(#17492)
add 532391dfada Bump software.amazon.awssdk:bom from 2.41.4 to 2.41.5
(#17491)
add e6f40694ea1 fix off-heap memory spike issue (#17489)
add 90bf116554b Increase scope for createTaskManager to allow overriding
it (#17495)
add c5f2982a008 Add header links next to cluster name (#17499)
add eedc894a9a3 Fix duplicate Zookeeper Browser nav entry (#17500)
add 093efdf949c Bump software.amazon.awssdk:bom from 2.41.5 to 2.41.6
(#17496)
add 15e7f18446d Bump org.apache:apache from 36 to 37 (#17498)
add 75b39bc2d4a [logical] Introducing physical optimizer support for
logical tables (#17447)
add c244cd38fa9 [Timeseries-storage] add DeltaDelta/Delta compressionCodec
table config validation (#17252)
add 0da08f20276 remove version fix on maven-dependency-plugin (#17505)
add dea5e9c254b Improve exception handling in ControllerLeaderLocator
(#17366)
add c38e56da58e [timeseries] Adding support for logical explain plans
(#17484)
add 0ea4d1f3ebc Deterministic data-only CRC (2/2) - use data-only CRC for
realtime committing segments during replace (#17380)
add d0a6aba30bd [multistage] Reset GRPC connection backoff when server is
re-enabled (#17466)
add f29600d48bd Bump parquet from 1.16.0 to 1.17.0 (#17504)
add 0170477e6da Bump software.amazon.awssdk:bom from 2.41.6 to 2.41.7
(#17507)
add 1796657af9c Add StateTransitionThreadPoolManager to override
getExecutor in SegmentOnlineOfflineStateModelFactory (#17453)
add f3bef4caad0 [federation] Add warnings for unavailable remote clusters
in BrokerResponse for multi-cluster routing (#17510)
add 6097668b27c Bump software.amazon.awssdk:bom from 2.41.7 to 2.41.8
(#17513)
add 9a845dbfb6b Bump com.gradle:develocity-maven-extension from 2.3 to
2.3.1 (#17514)
add 4cf67652b6d [Real-time Table Replication X clusters][1/n] Creating new
tables with designated consuming segments (#17235)
add 7a96b429bfd Not able to delete existing table & schema from Pinot UI
(#17294)
add 5a73105c79b Improve error messages for schema backward incompatibility
(#17509)
add 36bdd7e8cf7 Bump software.amazon.awssdk:bom from 2.41.8 to 2.41.9
(#17518)
add 5f9241c05ff [timeseries] Introduced query options and explain plan
support for Controller UI (#17511)
add c899956b2d0 [federation] Introducing multi-cluster routing support for
physical optimizer (#17516)
add b949b1d7487 [ui] Fixing segment search bar width issue in table page
(#17520)
add e179ee77332 Bump org.codehaus.mojo:animal-sniffer-annotations from
1.26 to 1.27 (#17525)
add 79068b9fac0 Bump org.codehaus.mojo:buildnumber-maven-plugin from 3.2.0
to 3.3.0 (#17526)
add a4d156c65d2 Bump software.amazon.awssdk:bom from 2.41.9 to 2.41.10
(#17527)
add fbcf23b842d Bump dnsjava:dnsjava from 3.6.3 to 3.6.4 (#17528)
add 3f3da7bd0eb Bump com.fasterxml.jackson:jackson-bom from 2.20.1 to
2.21.0 (#17529)
add 9d0d13a4096 Bump org.codehaus.mojo:javacc-maven-plugin from 3.1.1 to
3.2.0 (#17531)
add e498d91af6a Bump com.google.cloud:libraries-bom from 26.73.0 to
26.74.0 (#17537)
add bb41e3ffd01 Bump spark3.version from 3.5.7 to 3.5.8 (#17517)
add 1550f84949d Bump diff from 4.0.2 to 4.0.4 in
/pinot-controller/src/main/resources (#17539)
add 3ade049fc4b Bump org.codehaus.mojo:versions-maven-plugin from 2.20.1
to 2.21.0 (#17530)
add 92b6182aac1 Explicitly configure gRPC to use pooled direct buffers
(#17540)
add b6b83181051 Bump net.openhft:chronicle-bom from 2.27ea99 to 2.27ea100
(#17545)
add d66e09494c8 Bump software.amazon.awssdk:bom from 2.41.10 to 2.41.11
(#17544)
add 5c926510a35 Bump org.mockito:mockito-bom from 5.17.0 to 5.21.0
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 (fb667c796ea)
\
N -- N -- N
refs/heads/dependabot/maven/org.mockito-mockito-bom-5.21.0 (5c926510a35)
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:
.mvn/extensions.xml | 2 +-
AGENTS.md | 130 ++++
.../broker/api/resources/PinotBrokerDebug.java | 9 +-
.../broker/api/resources/PinotBrokerRouting.java | 2 +-
.../broker/api/resources/PinotClientRequest.java | 106 ++-
.../api/resources/ResponseStoreResource.java | 2 +-
.../broker/BasicAuthAccessControlFactory.java | 8 +-
.../broker/broker/BrokerAdminApiApplication.java | 2 +-
.../broker/ZkBasicAuthAccessControlFactory.java | 46 +-
.../broker/broker/helix/BaseBrokerStarter.java | 156 ++--
...okerResourceOnlineOfflineStateModelFactory.java | 2 +-
.../BrokerUserDefinedMessageHandlerFactory.java | 2 +-
.../helix/MultiClusterHelixBrokerStarter.java | 381 ++++++++++
.../apache/pinot/broker/grpc/BrokerGrpcServer.java | 9 +
.../apache/pinot/broker/querylog/QueryLogger.java | 45 +-
.../requesthandler/BaseBrokerRequestHandler.java | 34 +-
.../BaseSingleStageBrokerRequestHandler.java | 79 +-
.../requesthandler/BrokerRequestHandler.java | 9 +
.../BrokerRequestHandlerDelegate.java | 9 +
.../requesthandler/GrpcBrokerRequestHandler.java | 6 +-
.../MultiStageBrokerRequestHandler.java | 104 ++-
.../SingleConnectionBrokerRequestHandler.java | 6 +-
.../requesthandler/TimeSeriesRequestHandler.java | 99 ++-
.../instanceselector/BalancedInstanceSelector.java | 13 +-
.../instanceselector/BaseInstanceSelector.java | 42 +-
.../routing/instanceselector/InstanceSelector.java | 11 +-
.../instanceselector/InstanceSelectorFactory.java | 86 ++-
.../MultiStageReplicaGroupSelector.java | 18 +-
.../ReplicaGroupInstanceSelector.java | 130 +++-
.../StrictReplicaGroupInstanceSelector.java | 129 +---
.../BaseBrokerRoutingManager.java} | 42 +-
.../routing/manager/BrokerRoutingManager.java | 26 +-
.../manager/MultiClusterRoutingManager.java | 212 ++++++
.../manager/RemoteClusterBrokerRoutingManager.java | 130 ++++
.../broker/api/resources/PinotBrokerDebugTest.java | 110 +++
.../api/resources/PinotClientRequestTest.java | 91 ++-
.../broker/broker/HelixBrokerStarterTest.java | 2 +-
.../pinot/broker/grpc/BrokerGrpcServerTest.java | 229 ++++++
.../pinot/broker/querylog/QueryLoggerTest.java | 154 +++-
.../BaseSingleStageBrokerRequestHandlerTest.java | 45 +-
.../LiteralOnlyBrokerRequestTest.java | 6 +-
.../instanceselector/InstanceSelectorTest.java | 157 ++--
.../MultiStageReplicaGroupSelectorTest.java | 34 +-
.../BrokerRoutingManagerConcurrencyTest.java | 15 +-
.../routing/manager/BrokerRoutingManagerTest.java | 220 ++++++
.../manager/MultiClusterRoutingManagerTest.java | 269 +++++++
.../RemoteClusterBrokerRoutingManagerTest.java | 395 ++++++++++
.../org/apache/pinot/client/utils/DriverUtils.java | 4 +-
.../pinot/common/auth/AuthProviderUtils.java | 2 +-
...asicAuthUtils.java => BasicAuthTokenUtils.java} | 4 +-
.../config/provider/LogicalTableMetadataCache.java | 8 +
.../org/apache/pinot/common/datatable/StatMap.java | 41 +-
.../common/function/scalar/StringFunctions.java | 49 ++
.../common/metadata/segment/SegmentZKMetadata.java | 24 +
.../metadata/segment/SegmentZKMetadataUtils.java | 9 +-
.../apache/pinot/common/metrics/BrokerMeter.java | 29 +-
.../apache/pinot/common/metrics/BrokerTimer.java | 4 +-
.../pinot/common/metrics/ControllerMeter.java | 4 +-
.../apache/pinot/common/metrics/ServerMeter.java | 24 +-
.../pinot/common/response/BrokerResponse.java | 14 +
.../response/PinotBrokerTimeSeriesResponse.java | 16 +-
.../response/mapper/TimeSeriesResponseMapper.java | 30 +
.../resources/TableLLCSegmentUploadResponse.java | 11 +-
.../common/utils/LogicalTableConfigUtils.java | 32 +-
.../utils/config/AccessControlUserConfigUtils.java | 92 +--
.../common/utils/config/QueryOptionsUtils.java | 22 +
.../common/utils/grpc/BaseGrpcQueryClient.java | 16 +-
.../utils/request/QueryFingerprintUtils.java | 72 ++
.../utils/request/QueryFingerprintVisitor.java | 337 +++++++++
.../sql/parsers/rewriter/AggregationOptimizer.java | 47 +-
.../function/scalar/StringFunctionsTest.java | 64 ++
.../common/metadata/SegmentZKMetadataTest.java | 3 +
.../common/utils/config/QueryOptionsUtilsTest.java | 21 +
.../utils/request/QueryFingerprintUtilsTest.java | 313 ++++++++
.../utils/request/QueryFingerprintVisitorTest.java | 560 ++++++++++++++
.../parsers/rewriter/AggregationOptimizerTest.java | 452 ++++++++----
.../pinot/controller/BaseControllerStarter.java | 5 +-
.../apache/pinot/controller/ControllerConf.java | 18 +-
.../api/access/AuthenticationFilter.java | 2 +-
.../api/access/BasicAuthAccessControlFactory.java | 14 +-
.../access/ZkBasicAuthAccessControlFactory.java | 50 +-
.../api/exception/UserAlreadyExistsException.java | 13 +-
...orceCommitBatchConfig.java => BatchConfig.java} | 8 +-
.../pinot/controller/api/resources/Constants.java | 1 +
.../controller/api/resources/CopyTablePayload.java | 88 +++
.../api/resources/CopyTableResponse.java | 99 +++
.../api/resources/MinionStatusResponse.java | 125 ++++
.../PinotAccessControlUserRestletResource.java | 308 ++++----
.../api/resources/PinotControllerAuthResource.java | 26 +
.../resources/PinotInstanceRestletResource.java | 26 +-
...Schema.java => PinotMinionRestletResource.java} | 50 +-
.../api/resources/PinotQueryResource.java | 93 ++-
.../api/resources/PinotRealtimeTableResource.java | 50 +-
.../api/resources/PinotTableRestletResource.java | 148 +++-
.../pinot/controller/api/resources/StateType.java | 2 +-
.../helix/core/PinotHelixResourceManager.java | 251 ++++++-
.../helix/core/WatermarkInductionResult.java | 111 +++
.../core/minion/PinotHelixTaskResourceManager.java | 132 +++-
.../helix/core/minion/PinotTaskManager.java | 386 ++++++----
.../core/minion/generator/TaskGeneratorUtils.java | 2 +-
.../realtime/PinotLLCRealtimeSegmentManager.java | 144 +++-
.../SizeBasedSegmentFlushThresholdComputer.java | 12 +-
.../helix/core/rebalance/RebalanceConfig.java | 14 +-
.../helix/core/rebalance/TableRebalancer.java | 6 +-
.../realtime/provisioning/MemoryEstimator.java | 1 +
.../RealtimeSegmentValidationManager.java | 57 +-
pinot-controller/src/main/resources/app/App.tsx | 2 +-
.../src/main/resources/app/components/Header.tsx | 78 +-
.../src/main/resources/app/components/Layout.tsx | 33 +-
.../components/Query/FlamegraphQueryStageStats.tsx | 156 ++++
.../app/components/Query/TimeseriesQueryPage.tsx | 439 +++++++----
.../resources/app/components/SimpleAccordion.tsx | 5 +
.../src/main/resources/app/components/Table.tsx | 15 +-
.../main/resources/app/components/TableToolbar.tsx | 4 +-
.../src/main/resources/app/interfaces/types.d.ts | 16 +-
.../src/main/resources/app/pages/Query.tsx | 95 ++-
.../src/main/resources/app/requests/index.ts | 4 +-
.../main/resources/app/utils/PinotMethodUtils.ts | 233 ++++--
.../main/resources/app/utils/TimeseriesUtils.ts | 105 ++-
.../src/main/resources/package-lock.json | 93 ++-
pinot-controller/src/main/resources/package.json | 1 +
.../pinot/controller/ControllerConfTest.java | 13 +
.../api/PinotInstanceRestletResourceTest.java | 153 ++++
.../api/PinotMinionRestletResourceTest.java | 153 ++++
...itBatchConfigTest.java => BatchConfigTest.java} | 12 +-
.../resources/PinotRealtimeTableResourceTest.java | 117 +++
.../resources/PinotTableRestletResourceTest.java | 49 ++
.../controller/api/upload/ZKOperatorTest.java | 3 +
.../PinotHelixResourceManagerMinionDrainTest.java | 495 +++++++++++++
.../PinotHelixResourceManagerMinionStatusTest.java | 812 +++++++++++++++++++++
.../PinotHelixResourceManagerStatelessTest.java | 119 +++
.../PinotLLCRealtimeSegmentManagerTest.java | 138 ++--
.../controller/utils/SegmentMetadataMockUtils.java | 3 +
.../RealtimeSegmentValidationManagerTest.java | 18 +-
.../table_config_with_instance_assignment.json | 15 +
...AuthUtils.java => BasicAuthPrincipalUtils.java} | 13 +-
.../pinot/core/auth/FineGrainedAccessControl.java | 11 +
.../pinot/core/auth/ZkBasicAuthPrincipal.java | 55 +-
.../core/data/manager/BaseTableDataManager.java | 37 +-
.../manager/offline/DimensionTableDataManager.java | 3 +-
.../realtime/RealtimeSegmentDataManager.java | 8 +-
.../realtime/UpsertInconsistentStateConfig.java | 102 +++
.../blocks/results/AggregationResultsBlock.java | 11 +-
.../query/NonScanBasedAggregationOperator.java | 17 +
.../function/AggregationFunctionFactory.java | 2 +
.../function/AggregationFunctionUtils.java | 6 +
.../function/AnyValueAggregationFunction.java | 370 ++++++++++
...istinctCountSmartSketchAggregationFunction.java | 84 ++-
.../DistinctCountSmartHLLAggregationFunction.java | 90 ++-
.../DistinctCountULLAggregationFunction.java | 26 +-
.../function/StUnionAggregationFunction.java | 37 +-
.../array/SumArrayDoubleAggregationFunction.java | 5 +-
.../array/SumArrayLongAggregationFunction.java | 5 +-
.../pinot/core/query/logger/ServerQueryLogger.java | 3 +-
.../core/query/request/ServerQueryRequest.java | 13 +-
.../core/routing/LogicalTableRouteProvider.java | 50 +-
.../core/routing/MultiClusterRoutingContext.java | 111 +++
.../processing/timehandler/EpochTimeHandler.java | 3 +-
.../processing/utils/SegmentProcessorUtils.java | 4 +-
.../server/access/BasicAuthAccessFactory.java | 8 +-
.../server/access/ZkBasicAuthAccessFactory.java | 12 +-
.../server/realtime/ControllerLeaderLocator.java | 39 +-
.../org/apache/pinot/core/auth/BasicAuthTest.java | 9 +-
.../data/manager/BaseTableDataManagerTest.java | 70 ++
.../function/AnyValueAggregationFunctionTest.java | 315 ++++++++
...stinctCountSmartHLLAggregationFunctionTest.java | 179 +++++
.../function/StUnionAggregationFunctionTest.java | 106 +++
.../org/apache/pinot/core/util/CrcUtilsTest.java | 207 +++++-
.../data/test_crc_complex_sample_data.csv | 20 +
.../resources/data/test_crc_complex_schema.json | 27 +
.../resources/data/test_crc_complex_table.json | 83 +++
pinot-dependency-verifier/pom.xml | 4 +
.../pinot/integration/tests/ClusterTest.java | 35 +-
.../tests/BaseClusterIntegrationTestSet.java | 154 ++--
.../tests/BaseQueryKillingIntegrationTest.java | 2 +-
.../tests/CLPEncodingRealtimeIntegrationTest.java | 4 +-
.../tests/OfflineClusterIntegrationTest.java | 75 ++
.../OfflineTimestampIndexIntegrationTest.java | 5 +-
...pRealtimeIngestionSegmentCommitFailureTest.java | 16 +-
.../tests/RowExpressionIntegrationTest.java | 435 +++++++++++
.../tests/TimeSeriesIntegrationTest.java | 129 ++++
.../pinot/integration/tests/custom/ArrayTest.java | 146 ++--
.../integration/tests/custom/BytesTypeTest.java | 10 +-
.../integration/tests/custom/CpcSketchTest.java | 15 +-
.../CustomDataQueryClusterIntegrationTest.java | 55 ++
.../tests/custom/FloatingPointDataTypeTest.java | 15 +-
.../integration/tests/custom/GeoSpatialTest.java | 12 +-
.../integration/tests/custom/JsonPathTest.java | 58 +-
.../tests/custom/MapFieldTypeRealtimeTest.java | 10 +-
.../integration/tests/custom/MapFieldTypeTest.java | 71 +-
.../integration/tests/custom/MapTypeTest.java | 93 +--
.../tests/custom/MultiColumnTextIndicesTest.java | 10 +-
.../integration/tests/custom/SumPrecisionTest.java | 19 +-
.../integration/tests/custom/TextIndicesTest.java | 10 +-
.../integration/tests/custom/ThetaSketchTest.java | 22 +-
.../integration/tests/custom/TimestampTest.java | 17 +-
.../integration/tests/custom/TupleSketchTest.java | 15 +-
.../pinot/integration/tests/custom/ULLTest.java | 34 +-
.../tests/custom/UnnestIntegrationTest.java | 42 +-
.../pinot/integration/tests/custom/VectorTest.java | 15 +-
.../integration/tests/custom/WindowFunnelTest.java | 3 +-
.../BaseLogicalTableIntegrationTest.java | 54 ++
.../models/DummyTableUpsertMetadataManager.java | 13 +
.../multicluster/MultiClusterIntegrationTest.java | 741 +++++++++++++++++++
.../tests/tpch/generator/TPCHQueryGeneratorV2.java | 78 +-
pinot-perf/pom.xml | 8 +
.../apache/pinot/perf/BenchmarkJsonParsing.java | 282 +++++++
.../BenchmarkDistinctCountHLLThreshold.java | 361 +++++++++
.../pinot/plugin/filesystem/HadoopPinotFS.java | 12 +-
.../pinot/plugin/filesystem/HadoopPinotFSTest.java | 302 ++++++++
.../inputformat/clplog/CLPLogMessageDecoder.java | 6 +-
.../inputformat/json/JSONMessageDecoder.java | 6 +-
.../parquet/ParquetAvroRecordExtractor.java | 20 +-
.../pinot/plugin/minion/tasks/MinionTaskUtils.java | 46 +-
.../UpsertCompactMergeTaskExecutor.java | 4 +-
.../UpsertCompactMergeTaskGenerator.java | 43 +-
.../UpsertCompactMergeTaskGeneratorTest.java | 4 +-
.../pulsar/PulsarPartitionLevelConsumer.java | 5 +-
.../pinot-timeseries-m3ql/pom.xml | 2 +-
.../pinot/tsdb/m3ql/M3TimeSeriesPlanner.java | 1 +
.../tsdb/m3ql/plan/TransformNullPlanNode.java | 2 +-
.../rel/rules/ImmutableSortExchangeCopyRule.java | 415 -----------
.../calcite/rel/rules/PinotQueryRuleSets.java | 73 +-
.../rel/rules/PinotSortExchangeCopyRule.java | 29 +-
.../pinot/calcite/sql/fun/PinotOperatorTable.java | 1 +
.../calcite/sql2rel/PinotConvertletTable.java | 28 +
.../calcite/sql2rel/RowComparisonConvertlet.java | 244 +++++++
.../org/apache/pinot/query/QueryEnvironment.java | 32 +-
.../query/context/PhysicalPlannerContext.java | 15 +-
.../query/context/RuleTimingPlannerListener.java | 2 +-
.../planner/physical/DispatchablePlanVisitor.java | 11 +-
.../planner/physical/PinotDispatchPlanner.java | 5 +-
.../v2/PlanFragmentAndMailboxAssignment.java | 11 +-
.../planner/physical/v2/TableScanMetadata.java | 60 +-
.../opt/rules/LeafStageWorkerAssignmentRule.java | 208 +++++-
.../apache/pinot/query/routing/WorkerManager.java | 65 +-
.../validate/RowExpressionValidationVisitor.java | 182 +++++
.../apache/pinot/query/QueryCompilationTest.java | 39 +
.../rules/LeafStageWorkerAssignmentRuleTest.java | 318 ++++++++
.../v2/validation/LiteModeJoinValidationTest.java | 3 +-
.../resources/queries/ExplainPhysicalPlans.json | 564 +++++++-------
.../src/test/resources/queries/OrderByPlans.json | 23 +
.../query/mailbox/InMemorySendingMailbox.java | 3 +-
.../query/mailbox/channel/ChannelManager.java | 25 +-
.../mailbox/channel/MailboxContentObserver.java | 2 +-
.../apache/pinot/query/runtime/QueryRunner.java | 1 +
.../pinot/query/runtime/blocks/ErrorMseBlock.java | 14 +
.../pinot/query/runtime/context/BrokerContext.java | 55 ++
.../query/runtime/context/ControllerContext.java | 20 +-
.../pinot/query/runtime/context/ServerContext.java | 55 ++
.../runtime/executor/OpChainSchedulerService.java | 53 +-
.../query/runtime/operator/AggregateOperator.java | 6 +-
.../query/runtime/operator/BaseJoinOperator.java | 2 +-
.../operator/BaseMailboxReceiveOperator.java | 2 +-
.../query/runtime/operator/ErrorOperator.java | 2 +-
.../query/runtime/operator/FilterOperator.java | 2 +-
.../pinot/query/runtime/operator/LeafOperator.java | 2 +-
.../runtime/operator/LiteralValueOperator.java | 2 +-
.../query/runtime/operator/LookupJoinOperator.java | 2 +-
.../runtime/operator/MailboxSendOperator.java | 2 +-
.../query/runtime/operator/MultiStageOperator.java | 2 +-
.../pinot/query/runtime/operator/SortOperator.java | 2 +-
.../query/runtime/operator/TransformOperator.java | 2 +-
.../query/runtime/operator/UnnestOperator.java | 2 +-
.../runtime/operator/WindowAggregateOperator.java | 2 +-
.../operator/factory/AggregateOperatorFactory.java | 29 +-
.../factory/DefaultAggregateOperatorFactory.java | 45 ++
.../factory/DefaultJoinOperatorFactory.java | 81 ++
.../DefaultQueryOperatorFactoryProvider.java | 30 +-
.../operator/factory/JoinOperatorFactory.java | 29 +-
.../factory/QueryOperatorFactoryProvider.java | 15 +-
.../query/runtime/operator/set/SetOperator.java | 2 +-
.../runtime/operator/set/UnionAllOperator.java | 1 +
.../query/runtime/operator/set/UnionOperator.java | 1 +
.../window/value/LagValueWindowFunction.java | 5 +-
.../window/value/LeadValueWindowFunction.java | 5 +-
.../runtime/plan/OpChainExecutionContext.java | 25 +
.../query/runtime/plan/PlanNodeToOpChain.java | 55 +-
.../plan/pipeline/PipelineBreakerOperator.java | 2 +-
.../runtime/timeseries/LeafTimeSeriesOperator.java | 31 +-
.../TimeSeriesExchangeReceiveOperator.java | 59 +-
.../timeseries/serde/TimeSeriesBlockSerde.java | 37 +-
.../query/service/dispatch/DispatchClient.java | 16 +-
.../query/service/dispatch/QueryDispatcher.java | 139 +---
.../timeseries/TimeSeriesDispatchClient.java | 16 +-
.../timeseries/TimeSeriesQueryDispatcher.java | 121 +++
.../executor/OpChainSchedulerServiceTest.java | 3 +
.../runtime/operator/AggregateOperatorTest.java | 28 +
.../operator/BlockListMultiStageOperator.java | 2 +-
.../pinot/query/runtime/operator/OpChainTest.java | 2 +-
.../operator/WindowAggregateOperatorTest.java | 57 ++
.../plan/pipeline/PipelineBreakerExecutorTest.java | 2 +-
.../query/runtime/queries/QueryRunnerTestBase.java | 2 +-
.../service/dispatch/QueryDispatcherTest.java | 7 +-
.../DataTypeColumnTransformer.java | 101 +++
.../NullValueColumnTransformer.java | 59 ++
.../recordtransformer/DataTypeTransformer.java | 132 +---
.../recordtransformer/ExpressionTransformer.java | 70 +-
.../recordtransformer/NullValueTransformer.java | 54 +-
.../segment/creator/impl/BaseSegmentCreator.java | 44 +-
.../creator/impl/text/LuceneTextIndexCombined.java | 43 +-
.../creator/impl/text/LuceneTextIndexCreator.java | 28 +-
.../loader/invertedindex/TextIndexHandler.java | 3 +
.../index/readers/text/LuceneTextIndexReader.java | 11 +-
.../segment/readers/DefaultValueColumnReader.java | 46 +-
.../readers/PinotSegmentColumnReaderFactory.java | 51 +-
.../readers/PinotSegmentColumnReaderImpl.java | 101 ++-
.../readers/PinotSegmentColumnarDataSource.java | 73 ++
.../segment/store/SingleFileIndexDirectory.java | 1 -
.../upsert/BasePartitionUpsertMetadataManager.java | 121 ++-
...oncurrentMapPartitionUpsertMetadataManager.java | 90 ++-
...nUpsertMetadataManagerForConsistentDeletes.java | 98 ++-
.../apache/pinot/segment/local/utils/CrcUtils.java | 71 +-
.../local/utils/DataTypeTransformerUtils.java | 180 +++++
.../local/utils/ExpressionTransformerUtils.java | 105 +++
.../local/utils/NullValueTransformerUtils.java | 123 ++++
.../segment/local/utils/TableConfigUtils.java | 44 +-
.../DataTypeColumnTransformerTest.java | 543 ++++++++++++++
.../NullValueColumnTransformerTest.java | 444 +++++++++++
.../recordtransformer/DataTypeTransformerTest.java | 69 +-
.../ExpressionTransformerTest.java | 56 ++
.../readers/DefaultValueColumnReaderTest.java | 42 +-
.../segment/readers/InMemoryColumnReader.java | 258 +++++++
.../readers/PinotSegmentColumnReaderImplTest.java | 54 +-
.../BasePartitionUpsertMetadataManagerTest.java | 13 +
...ertMetadataManagerForConsistentDeletesTest.java | 112 +++
...rrentMapPartitionUpsertMetadataManagerTest.java | 609 +++++++++++++++-
.../segment/local/utils/TableConfigUtilsTest.java | 20 +
.../pinot/segment/spi/AggregationFunctionType.java | 1 +
.../apache/pinot/segment/spi/SegmentMetadata.java | 2 +
.../spi/index/metadata/SegmentMetadataImpl.java | 27 +-
.../pinot/server/api/resources/TablesResource.java | 9 +-
.../server/starter/helix/BaseServerStarter.java | 33 +-
.../starter/helix/HelixInstanceDataManager.java | 28 +-
.../helix/HelixInstanceDataManagerConfig.java | 10 +
.../SegmentOnlineOfflineStateModelFactory.java | 50 +-
.../helix/StateTransitionThreadPoolManager.java | 57 ++
.../apache/pinot/server/api/AccessControlTest.java | 10 +-
.../pinot/server/api/TablesResourceTest.java | 4 +-
pinot-spi/pom.xml | 4 +
.../spi/columntransformer/ColumnTransformer.java | 21 +-
.../config/instance/InstanceDataManagerConfig.java | 2 +
.../pinot/spi/config/table/RoutingConfig.java | 3 +-
.../apache/pinot/spi/config/user/AccessType.java | 2 +-
.../pinot/spi/config/user/ComponentType.java | 2 +-
.../org/apache/pinot/spi/config/user/RoleType.java | 2 +-
.../apache/pinot/spi/config/user/UserConfig.java | 233 +++---
.../apache/pinot/spi/data/PhysicalTableConfig.java | 15 +
.../pinot/spi/data/readers/ColumnReader.java | 83 ++-
.../spi/data/readers/ColumnReaderFactory.java | 6 +-
.../pinot/spi/data/readers/ColumnarDataSource.java | 84 +++
.../pinot/spi/data/readers/MultiValueResult.java | 123 ++++
.../apache/pinot/spi/exception/QueryErrorCode.java | 27 +
.../apache/pinot/spi/filesystem/BasePinotFS.java | 7 +-
.../pinot/spi/query/QueryExecutionContext.java | 19 +-
.../apache/pinot/spi/query/QueryThreadContext.java | 5 +
.../pinot/spi/trace/DefaultRequestContext.java | 11 +
.../apache/pinot/spi/trace/LoggerConstants.java | 2 +
.../apache/pinot/spi/trace/QueryFingerprint.java | 48 +-
.../org/apache/pinot/spi/trace/RequestContext.java | 4 +
.../apache/pinot/spi/utils/CommonConstants.java | 48 ++
.../java/org/apache/pinot/spi/utils/JsonUtils.java | 14 +
.../utils/builder/ControllerRequestURLBuilder.java | 20 +
.../pinot/spi/utils/builder/UserConfigBuilder.java | 80 +-
.../pinot/spi/trace/QueryFingerprintTest.java | 169 +++++
.../org/apache/pinot/spi/utils/JsonUtilsTest.java | 496 +++++++++++++
.../builder/ControllerRequestURLBuilderTest.java | 14 +-
.../tsdb/planner/TimeSeriesQueryEnvironment.java | 2 +-
.../tsdb/planner/physical/TableScanVisitor.java | 6 +-
.../pinot/tsdb/spi/RangeTimeSeriesRequest.java | 10 +-
.../pinot/tsdb/spi/series/TimeSeriesBlock.java | 19 +-
.../org/apache/pinot/tools/AuthQuickstart.java | 4 +-
.../apache/pinot/tools/AuthZkBasicQuickstart.java | 4 +-
.../tools/TimeSeriesEngineAuthQuickStart.java | 4 +-
.../tools/filesystem/PinotFSBenchmarkDriver.java | 2 +-
pinot-tools/src/main/resources/log4j2.xml | 2 +-
pom.xml | 102 ++-
377 files changed, 22579 insertions(+), 4056 deletions(-)
create mode 100644 AGENTS.md
create mode 100644
pinot-broker/src/main/java/org/apache/pinot/broker/broker/helix/MultiClusterHelixBrokerStarter.java
rename
pinot-broker/src/main/java/org/apache/pinot/broker/routing/{BrokerRoutingManager.java
=> manager/BaseBrokerRoutingManager.java} (97%)
copy pinot-common/src/main/java/org/apache/pinot/common/auth/AuthConfig.java
=>
pinot-broker/src/main/java/org/apache/pinot/broker/routing/manager/BrokerRoutingManager.java
(51%)
create mode 100644
pinot-broker/src/main/java/org/apache/pinot/broker/routing/manager/MultiClusterRoutingManager.java
create mode 100644
pinot-broker/src/main/java/org/apache/pinot/broker/routing/manager/RemoteClusterBrokerRoutingManager.java
create mode 100644
pinot-broker/src/test/java/org/apache/pinot/broker/api/resources/PinotBrokerDebugTest.java
create mode 100644
pinot-broker/src/test/java/org/apache/pinot/broker/grpc/BrokerGrpcServerTest.java
rename pinot-broker/src/test/java/org/apache/pinot/broker/routing/{ =>
manager}/BrokerRoutingManagerConcurrencyTest.java (99%)
create mode 100644
pinot-broker/src/test/java/org/apache/pinot/broker/routing/manager/BrokerRoutingManagerTest.java
create mode 100644
pinot-broker/src/test/java/org/apache/pinot/broker/routing/manager/MultiClusterRoutingManagerTest.java
create mode 100644
pinot-broker/src/test/java/org/apache/pinot/broker/routing/manager/RemoteClusterBrokerRoutingManagerTest.java
rename
pinot-common/src/main/java/org/apache/pinot/common/auth/{BasicAuthUtils.java =>
BasicAuthTokenUtils.java} (97%)
create mode 100644
pinot-common/src/main/java/org/apache/pinot/common/utils/request/QueryFingerprintUtils.java
create mode 100644
pinot-common/src/main/java/org/apache/pinot/common/utils/request/QueryFingerprintVisitor.java
create mode 100644
pinot-common/src/test/java/org/apache/pinot/common/utils/request/QueryFingerprintUtilsTest.java
create mode 100644
pinot-common/src/test/java/org/apache/pinot/common/utils/request/QueryFingerprintVisitorTest.java
rename
pinot-controller/src/main/java/org/apache/pinot/controller/api/resources/{ForceCommitBatchConfig.java
=> BatchConfig.java} (84%)
create mode 100644
pinot-controller/src/main/java/org/apache/pinot/controller/api/resources/CopyTablePayload.java
create mode 100644
pinot-controller/src/main/java/org/apache/pinot/controller/api/resources/CopyTableResponse.java
create mode 100644
pinot-controller/src/main/java/org/apache/pinot/controller/api/resources/MinionStatusResponse.java
copy
pinot-controller/src/main/java/org/apache/pinot/controller/api/resources/{PinotTableSchema.java
=> PinotMinionRestletResource.java} (63%)
create mode 100644
pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/WatermarkInductionResult.java
create mode 100644
pinot-controller/src/main/resources/app/components/Query/FlamegraphQueryStageStats.tsx
create mode 100644
pinot-controller/src/test/java/org/apache/pinot/controller/api/PinotMinionRestletResourceTest.java
rename
pinot-controller/src/test/java/org/apache/pinot/controller/api/resources/{ForceCommitBatchConfigTest.java
=> BatchConfigTest.java} (78%)
create mode 100644
pinot-controller/src/test/java/org/apache/pinot/controller/api/resources/PinotRealtimeTableResourceTest.java
create mode 100644
pinot-controller/src/test/java/org/apache/pinot/controller/api/resources/PinotTableRestletResourceTest.java
create mode 100644
pinot-controller/src/test/java/org/apache/pinot/controller/helix/core/PinotHelixResourceManagerMinionDrainTest.java
create mode 100644
pinot-controller/src/test/java/org/apache/pinot/controller/helix/core/PinotHelixResourceManagerMinionStatusTest.java
create mode 100644
pinot-controller/src/test/resources/table/table_config_with_instance_assignment.json
rename
pinot-core/src/main/java/org/apache/pinot/core/auth/{BasicAuthUtils.java =>
BasicAuthPrincipalUtils.java} (91%)
create mode 100644
pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/UpsertInconsistentStateConfig.java
create mode 100644
pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/AnyValueAggregationFunction.java
create mode 100644
pinot-core/src/main/java/org/apache/pinot/core/routing/MultiClusterRoutingContext.java
create mode 100644
pinot-core/src/test/java/org/apache/pinot/core/query/aggregation/function/AnyValueAggregationFunctionTest.java
create mode 100644
pinot-core/src/test/java/org/apache/pinot/core/query/aggregation/function/DistinctCountSmartHLLAggregationFunctionTest.java
create mode 100644
pinot-core/src/test/java/org/apache/pinot/core/query/aggregation/function/StUnionAggregationFunctionTest.java
create mode 100644
pinot-core/src/test/resources/data/test_crc_complex_sample_data.csv
create mode 100644
pinot-core/src/test/resources/data/test_crc_complex_schema.json
create mode 100644
pinot-core/src/test/resources/data/test_crc_complex_table.json
rename
pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/{custom
=> }/OfflineTimestampIndexIntegrationTest.java (97%)
create mode 100644
pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/RowExpressionIntegrationTest.java
create mode 100644
pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/multicluster/MultiClusterIntegrationTest.java
create mode 100644
pinot-perf/src/main/java/org/apache/pinot/perf/BenchmarkJsonParsing.java
create mode 100644
pinot-perf/src/main/java/org/apache/pinot/perf/aggregation/BenchmarkDistinctCountHLLThreshold.java
delete mode 100644
pinot-query-planner/src/main/java/org/apache/pinot/calcite/rel/rules/ImmutableSortExchangeCopyRule.java
create mode 100644
pinot-query-planner/src/main/java/org/apache/pinot/calcite/sql2rel/RowComparisonConvertlet.java
create mode 100644
pinot-query-planner/src/main/java/org/apache/pinot/query/validate/RowExpressionValidationVisitor.java
create mode 100644
pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/context/BrokerContext.java
copy
pinot-segment-local/src/main/java/org/apache/pinot/segment/local/segment/index/h3/H3IndexPlugin.java
=>
pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/context/ControllerContext.java
(69%)
create mode 100644
pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/context/ServerContext.java
copy
pinot-query-planner/src/main/java/org/apache/pinot/query/routing/StagePlan.java
=>
pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/factory/AggregateOperatorFactory.java
(54%)
create mode 100644
pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/factory/DefaultAggregateOperatorFactory.java
create mode 100644
pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/factory/DefaultJoinOperatorFactory.java
copy
pinot-core/src/main/java/org/apache/pinot/core/query/reduce/filter/ColumnValueExtractor.java
=>
pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/factory/DefaultQueryOperatorFactoryProvider.java
(52%)
copy
pinot-query-planner/src/main/java/org/apache/pinot/query/routing/StagePlan.java
=>
pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/factory/JoinOperatorFactory.java
(51%)
copy
pinot-core/src/main/java/org/apache/pinot/core/query/executor/ResultsBlockStreamer.java
=>
pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/factory/QueryOperatorFactoryProvider.java
(73%)
create mode 100644
pinot-query-runtime/src/main/java/org/apache/pinot/query/service/dispatch/timeseries/TimeSeriesQueryDispatcher.java
create mode 100644
pinot-segment-local/src/main/java/org/apache/pinot/segment/local/columntransformer/DataTypeColumnTransformer.java
create mode 100644
pinot-segment-local/src/main/java/org/apache/pinot/segment/local/columntransformer/NullValueColumnTransformer.java
create mode 100644
pinot-segment-local/src/main/java/org/apache/pinot/segment/local/segment/readers/PinotSegmentColumnarDataSource.java
create mode 100644
pinot-segment-local/src/main/java/org/apache/pinot/segment/local/utils/DataTypeTransformerUtils.java
create mode 100644
pinot-segment-local/src/main/java/org/apache/pinot/segment/local/utils/ExpressionTransformerUtils.java
create mode 100644
pinot-segment-local/src/main/java/org/apache/pinot/segment/local/utils/NullValueTransformerUtils.java
create mode 100644
pinot-segment-local/src/test/java/org/apache/pinot/segment/local/columntransformer/DataTypeColumnTransformerTest.java
create mode 100644
pinot-segment-local/src/test/java/org/apache/pinot/segment/local/columntransformer/NullValueColumnTransformerTest.java
create mode 100644
pinot-segment-local/src/test/java/org/apache/pinot/segment/local/segment/readers/InMemoryColumnReader.java
create mode 100644
pinot-server/src/main/java/org/apache/pinot/server/starter/helix/StateTransitionThreadPoolManager.java
copy
pinot-query-planner/src/main/java/org/apache/pinot/calcite/rel/rules/TableOptions.java
=>
pinot-spi/src/main/java/org/apache/pinot/spi/columntransformer/ColumnTransformer.java
(70%)
create mode 100644
pinot-spi/src/main/java/org/apache/pinot/spi/data/readers/ColumnarDataSource.java
create mode 100644
pinot-spi/src/main/java/org/apache/pinot/spi/data/readers/MultiValueResult.java
copy
pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/OpChainId.java
=> pinot-spi/src/main/java/org/apache/pinot/spi/trace/QueryFingerprint.java
(57%)
create mode 100644
pinot-spi/src/test/java/org/apache/pinot/spi/trace/QueryFingerprintTest.java
copy
pinot-common/src/test/java/org/apache/pinot/common/request/context/FilterContextTest.java
=>
pinot-spi/src/test/java/org/apache/pinot/spi/utils/builder/ControllerRequestURLBuilderTest.java
(63%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
