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/incubator-pinot.git.
from d764ea6 Enhance table rebalance rest API argument check (#4824)
add 648d02a Replace ServerInstance with ServerRoutingInstance for Broker
scatter-gather (#4817)
No new revisions were added by this update.
Summary of changes:
.../ConnectionPoolBrokerRequestHandler.java | 15 ++--
.../SingleConnectionBrokerRequestHandler.java | 19 ++---
.../apache/pinot/common/query/ReduceService.java | 49 ------------
.../pinot/common/query/ReduceServiceRegistry.java | 70 -----------------
.../org/apache/pinot/common/utils/HashUtil.java | 11 ++-
.../core/query/reduce/BrokerReduceService.java | 89 +++++++++++-----------
.../query/selection/SelectionOperatorService.java | 11 +--
.../query/selection/SelectionOperatorUtils.java | 12 +--
.../pinot/core/transport/AsyncQueryResponse.java | 27 +++----
.../pinot/core/transport/DataTableHandler.java | 23 +++---
.../apache/pinot/core/transport/QueryRouter.java | 31 ++++----
.../pinot/core/transport/ServerChannels.java | 18 ++---
.../pinot/core/transport/ServerResponse.java | 2 +-
.../{Server.java => ServerRoutingInstance.java} | 70 ++++++++---------
.../pinot/core/transport/QueryRouterTest.java | 46 +++++------
.../org/apache/pinot/queries/BaseQueriesTest.java | 13 ++--
16 files changed, 193 insertions(+), 313 deletions(-)
delete mode 100644
pinot-common/src/main/java/org/apache/pinot/common/query/ReduceService.java
delete mode 100644
pinot-common/src/main/java/org/apache/pinot/common/query/ReduceServiceRegistry.java
rename pinot-core/src/main/java/org/apache/pinot/core/transport/{Server.java
=> ServerRoutingInstance.java} (53%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
