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/pinot.git
from d4bf8f2b17 SQL compliance: allow INT and FLOAT literal (#13078)
add e71d1c6f56 Clean up BrokerRequestHandler and BrokerResponse (#13179)
No new revisions were added by this update.
Summary of changes:
.../broker/api/resources/PinotClientRequest.java | 16 +-
.../broker/broker/helix/BaseBrokerStarter.java | 55 +-
.../apache/pinot/broker/querylog/QueryLogger.java | 31 +-
.../requesthandler/BaseBrokerRequestHandler.java | 1894 +-------------------
...va => BaseSingleStageBrokerRequestHandler.java} | 213 +--
.../requesthandler/BrokerRequestHandler.java | 17 +-
.../BrokerRequestHandlerDelegate.java | 33 +-
.../requesthandler/GrpcBrokerRequestHandler.java | 32 +-
.../MultiStageBrokerRequestHandler.java | 96 +-
.../SingleConnectionBrokerRequestHandler.java | 42 +-
.../pinot/broker/querylog/QueryLoggerTest.java | 85 +-
...> BaseSingleStageBrokerRequestHandlerTest.java} | 85 +-
.../LiteralOnlyBrokerRequestTest.java | 506 +++---
.../MultiStageBrokerRequestHandlerTest.java | 104 --
.../broker/requesthandler/QueryOverrideTest.java | 27 +-
.../broker/requesthandler/QueryValidationTest.java | 15 +-
.../SelectStarWithOtherColsRewriteTest.java | 18 +-
.../apache/pinot/common/datatable/DataTable.java | 2 +-
.../pinot/common/response/BrokerResponse.java | 243 ++-
.../response/broker/BrokerResponseNative.java | 442 ++---
.../response/broker/BrokerResponseNativeV2.java | 323 ++--
.../response/broker/BrokerResponseStats.java | 129 --
.../common/utils/config/QueryOptionsUtils.java | 4 +
.../apache/pinot/common/datatable/StatMapTest.java | 1 -
.../pinot/request/BrokerResponseNativeTest.java | 16 +-
.../core/query/executor/sql/SqlQueryExecutor.java | 9 +-
.../core/query/reduce/BrokerReduceService.java | 11 +-
.../query/reduce/ExecutionStatsAggregator.java | 151 +-
.../core/query/reduce/GroupByDataTableReducer.java | 2 +-
.../core/query/reduce/StreamingReduceService.java | 3 +-
.../core/query/reduce/BrokerReduceServiceTest.java | 21 +-
.../org/apache/pinot/queries/BaseQueriesTest.java | 40 +-
.../pinot/queries/ExplainPlanQueriesTest.java | 82 +-
.../org/apache/pinot/queries/ExprMinMaxTest.java | 4 +-
.../org/apache/pinot/queries/FluentQueryTest.java | 4 +-
.../ForwardIndexDisabledMultiValueQueriesTest.java | 106 +-
...dexDisabledMultiValueQueriesWithReloadTest.java | 90 +-
...ForwardIndexDisabledSingleValueQueriesTest.java | 368 ++--
.../ForwardIndexHandlerReloadQueriesTest.java | 134 +-
.../pinot/queries/MultiValueRawQueriesTest.java | 10 +-
.../LeafStageTransferableBlockOperator.java | 48 +-
.../query/runtime/operator/MultiStageOperator.java | 2 +-
.../query/service/dispatch/QueryDispatcher.java | 96 +-
.../query/BrokerQueryEventListenerFactory.java | 104 ++
.../PinotBrokerQueryEventListenerFactory.java | 147 --
45 files changed, 1611 insertions(+), 4250 deletions(-)
copy
pinot-broker/src/main/java/org/apache/pinot/broker/requesthandler/{BaseBrokerRequestHandler.java
=> BaseSingleStageBrokerRequestHandler.java} (89%)
rename
pinot-broker/src/test/java/org/apache/pinot/broker/requesthandler/{BaseBrokerRequestHandlerTest.java
=> BaseSingleStageBrokerRequestHandlerTest.java} (70%)
delete mode 100644
pinot-broker/src/test/java/org/apache/pinot/broker/requesthandler/MultiStageBrokerRequestHandlerTest.java
delete mode 100644
pinot-common/src/main/java/org/apache/pinot/common/response/broker/BrokerResponseStats.java
create mode 100644
pinot-spi/src/main/java/org/apache/pinot/spi/eventlistener/query/BrokerQueryEventListenerFactory.java
delete mode 100644
pinot-spi/src/main/java/org/apache/pinot/spi/eventlistener/query/PinotBrokerQueryEventListenerFactory.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
