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 3ec7548 Add getResultColumnName API to AggregationFunction to fetch
sql compliant result name (#4870)
add 8d08bcc Clean up the connection-pool based broker routing (#4850)
No new revisions were added by this update.
Summary of changes:
.gitignore | 1 -
docs/code_modules.rst | 6 -
pinot-broker/pom.xml | 4 -
.../pinot/broker/broker/BrokerServerBuilder.java | 24 +-
.../broker/broker/helix/HelixBrokerStarter.java | 10 -
.../broker/helix/LiveInstanceChangeHandler.java | 121 ----
.../ConnectionPoolBrokerRequestHandler.java | 423 ------------
.../pinot/common/response/ServerInstance.java | 172 -----
.../apache/pinot/common/utils/CommonConstants.java | 4 -
pinot-distribution/pom.xml | 4 -
.../pinot/integration/tests/ClusterTest.java | 6 -
pinot-server/pom.xml | 4 -
.../server/request/ScheduledRequestHandler.java | 77 ---
.../apache/pinot/server/starter/ServerBuilder.java | 14 +-
.../request/ScheduledRequestHandlerTest.java | 210 ------
pinot-transport/pom.xml | 114 ----
.../common/AbstractCompositeListenableFuture.java | 238 -------
.../transport/common/AsyncResponseFuture.java | 343 ----------
.../apache/pinot/transport/common/Callback.java | 39 --
.../apache/pinot/transport/common/Cancellable.java | 28 -
.../pinot/transport/common/CompositeFuture.java | 228 -------
.../pinot/transport/common/LinkedDequeue.java | 359 -----------
.../apache/pinot/transport/common/NoneType.java | 28 -
.../pinot/transport/common/SelectingFuture.java | 178 ------
.../transport/common/ServerResponseFuture.java | 96 ---
.../pinot/transport/conf/TransportClientConf.java | 77 ---
.../transport/config/ConnectionPoolConfig.java | 138 ----
.../transport/config/PerTableRoutingConfig.java | 145 -----
.../pinot/transport/config/RoutingTableConfig.java | 81 ---
.../pinot/transport/config/ThreadPoolConfig.java | 79 ---
.../transport/metrics/AggregatedPoolStats.java | 249 --------
.../metrics/AggregatedTransportClientMetrics.java | 200 ------
.../metrics/AggregatedTransportServerMetrics.java | 180 ------
.../pinot/transport/metrics/AsyncPoolStats.java | 239 -------
.../transport/metrics/NettyClientMetrics.java | 168 -----
.../transport/metrics/NettyServerMetrics.java | 138 ----
.../apache/pinot/transport/metrics/PoolStats.java | 164 -----
.../pinot/transport/metrics/PoolStatsProvider.java | 35 -
.../transport/metrics/TransportClientMetrics.java | 69 --
.../transport/metrics/TransportServerMetrics.java | 63 --
.../transport/netty/NettyClientConnection.java | 152 -----
.../apache/pinot/transport/netty/NettyServer.java | 313 ---------
.../transport/netty/NettyTCPClientConnection.java | 435 -------------
.../pinot/transport/netty/NettyTCPServer.java | 118 ----
.../netty/PooledNettyClientResourceManager.java | 146 -----
.../org/apache/pinot/transport/pool/AsyncPool.java | 136 ----
.../apache/pinot/transport/pool/AsyncPoolImpl.java | 711 ---------------------
.../pool/AsyncPoolResourceManagerAdapter.java | 125 ----
.../org/apache/pinot/transport/pool/KeyedPool.java | 108 ----
.../apache/pinot/transport/pool/KeyedPoolImpl.java | 223 -------
.../transport/pool/PooledResourceManager.java | 58 --
.../transport/pool/SizeLimitExceededException.java | 32 -
.../transport/scattergather/ScatterGather.java | 64 --
.../transport/scattergather/ScatterGatherImpl.java | 393 ------------
.../scattergather/ScatterGatherRequest.java | 65 --
.../scattergather/ScatterGatherStats.java | 112 ----
.../src/test/java/org/apache/pinot/Checkable.java | 31 -
.../src/test/java/org/apache/pinot/TestUtils.java | 57 --
.../transport/common/CompositeFutureTest.java | 662 -------------------
.../pinot/transport/common/ResponseFutureTest.java | 711 ---------------------
.../transport/common/SelectingFutureTest.java | 289 ---------
.../pinot/transport/common/ServerInstanceTest.java | 56 --
.../transport/netty/NettyCloseChannelTest.java | 123 ----
.../NettySingleConnectionIntegrationTest.java | 308 ---------
.../pinot/transport/netty/NettyTestUtils.java | 106 ---
.../transport/perf/ScatterGatherPerfClient.java | 481 --------------
.../transport/perf/ScatterGatherPerfServer.java | 204 ------
.../transport/perf/ScatterGatherPerfTester.java | 331 ----------
.../pool/AsyncPoolResourceManagerAdapterTest.java | 244 -------
.../pinot/transport/pool/KeyedPoolImplTest.java | 639 ------------------
.../transport/scattergather/ScatterGatherTest.java | 317 ---------
pom.xml | 6 -
72 files changed, 7 insertions(+), 12505 deletions(-)
delete mode 100644
pinot-broker/src/main/java/org/apache/pinot/broker/broker/helix/LiveInstanceChangeHandler.java
delete mode 100644
pinot-broker/src/main/java/org/apache/pinot/broker/requesthandler/ConnectionPoolBrokerRequestHandler.java
delete mode 100644
pinot-common/src/main/java/org/apache/pinot/common/response/ServerInstance.java
delete mode 100644
pinot-server/src/main/java/org/apache/pinot/server/request/ScheduledRequestHandler.java
delete mode 100644
pinot-server/src/test/java/org/apache/pinot/server/request/ScheduledRequestHandlerTest.java
delete mode 100644 pinot-transport/pom.xml
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/common/AbstractCompositeListenableFuture.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/common/AsyncResponseFuture.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/common/Callback.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/common/Cancellable.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/common/CompositeFuture.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/common/LinkedDequeue.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/common/NoneType.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/common/SelectingFuture.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/common/ServerResponseFuture.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/conf/TransportClientConf.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/config/ConnectionPoolConfig.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/config/PerTableRoutingConfig.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/config/RoutingTableConfig.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/config/ThreadPoolConfig.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/metrics/AggregatedPoolStats.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/metrics/AggregatedTransportClientMetrics.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/metrics/AggregatedTransportServerMetrics.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/metrics/AsyncPoolStats.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/metrics/NettyClientMetrics.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/metrics/NettyServerMetrics.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/metrics/PoolStats.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/metrics/PoolStatsProvider.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/metrics/TransportClientMetrics.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/metrics/TransportServerMetrics.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/netty/NettyClientConnection.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/netty/NettyServer.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/netty/NettyTCPClientConnection.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/netty/NettyTCPServer.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/netty/PooledNettyClientResourceManager.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/pool/AsyncPool.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/pool/AsyncPoolImpl.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/pool/AsyncPoolResourceManagerAdapter.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/pool/KeyedPool.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/pool/KeyedPoolImpl.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/pool/PooledResourceManager.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/pool/SizeLimitExceededException.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/scattergather/ScatterGather.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/scattergather/ScatterGatherImpl.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/scattergather/ScatterGatherRequest.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/scattergather/ScatterGatherStats.java
delete mode 100644
pinot-transport/src/test/java/org/apache/pinot/Checkable.java
delete mode 100644
pinot-transport/src/test/java/org/apache/pinot/TestUtils.java
delete mode 100644
pinot-transport/src/test/java/org/apache/pinot/transport/common/CompositeFutureTest.java
delete mode 100644
pinot-transport/src/test/java/org/apache/pinot/transport/common/ResponseFutureTest.java
delete mode 100644
pinot-transport/src/test/java/org/apache/pinot/transport/common/SelectingFutureTest.java
delete mode 100644
pinot-transport/src/test/java/org/apache/pinot/transport/common/ServerInstanceTest.java
delete mode 100644
pinot-transport/src/test/java/org/apache/pinot/transport/netty/NettyCloseChannelTest.java
delete mode 100644
pinot-transport/src/test/java/org/apache/pinot/transport/netty/NettySingleConnectionIntegrationTest.java
delete mode 100644
pinot-transport/src/test/java/org/apache/pinot/transport/netty/NettyTestUtils.java
delete mode 100644
pinot-transport/src/test/java/org/apache/pinot/transport/perf/ScatterGatherPerfClient.java
delete mode 100644
pinot-transport/src/test/java/org/apache/pinot/transport/perf/ScatterGatherPerfServer.java
delete mode 100644
pinot-transport/src/test/java/org/apache/pinot/transport/perf/ScatterGatherPerfTester.java
delete mode 100644
pinot-transport/src/test/java/org/apache/pinot/transport/pool/AsyncPoolResourceManagerAdapterTest.java
delete mode 100644
pinot-transport/src/test/java/org/apache/pinot/transport/pool/KeyedPoolImplTest.java
delete mode 100644
pinot-transport/src/test/java/org/apache/pinot/transport/scattergather/ScatterGatherTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
