Package org.apache.drill.exec.rpc.user
Class QueryResultHandler
java.lang.Object
org.apache.drill.exec.rpc.user.QueryResultHandler
Encapsulates the future management of query submissions. This entails a
potential race condition. Normal ordering is:
- 1. Submit query to be executed.
- 2. Receive QueryHandle for buffer management.
- 3. Start receiving results batches for query.
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
batchArrived
(ConnectionThrottle throttle, io.netty.buffer.ByteBuf pBody, io.netty.buffer.ByteBuf dBody) Maps internal low-level API protocol toUserResultsListener
-level API protocol.getWrappedListener
(UserResultsListener resultsListener) void
resultArrived
(io.netty.buffer.ByteBuf pBody) Maps internal low-level API protocol toUserResultsListener
-level API protocol.
-
Constructor Details
-
QueryResultHandler
public QueryResultHandler()
-
-
Method Details
-
getWrappedListener
public RpcOutcomeListener<UserBitShared.QueryId> getWrappedListener(UserResultsListener resultsListener) -
getWrappedConnectionHandler
public RpcConnectionHandler<UserClient.UserToBitConnection> getWrappedConnectionHandler(RpcConnectionHandler<UserClient.UserToBitConnection> handler) -
resultArrived
Maps internal low-level API protocol toUserResultsListener
-level API protocol. handles data result messages- Throws:
RpcException
-
batchArrived
public void batchArrived(ConnectionThrottle throttle, io.netty.buffer.ByteBuf pBody, io.netty.buffer.ByteBuf dBody) throws RpcException Maps internal low-level API protocol toUserResultsListener
-level API protocol. handles query data messages- Throws:
RpcException
-