org.apache.drill.exec.rpc.user

Class QueryResultHandler

java.lang.Object

org.apache.drill.exec.rpc.user.QueryResultHandler

public class QueryResultHandler
extends Object

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.

However, 3 could potentially occur before 2. Because of that, we need to handle this case and then do a switcheroo.

Constructor Summary

Constructors

Constructor and Description
QueryResultHandler()

Method Summary

Modifier and Type	Method and Description
void	batchArrived(ConnectionThrottle throttle, io.netty.buffer.ByteBuf pBody, io.netty.buffer.ByteBuf dBody) Maps internal low-level API protocol to UserResultsListener-level API protocol.
RpcConnectionHandler<UserClient.UserToBitConnection>	getWrappedConnectionHandler(RpcConnectionHandler<UserClient.UserToBitConnection> handler)
RpcOutcomeListener<UserBitShared.QueryId>	getWrappedListener(UserResultsListener resultsListener)
void	resultArrived(io.netty.buffer.ByteBuf pBody) Maps internal low-level API protocol to UserResultsListener-level API protocol.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

QueryResultHandler

public QueryResultHandler()

Method Detail

getWrappedListener

public RpcOutcomeListener<UserBitShared.QueryId> getWrappedListener(UserResultsListener resultsListener)

getWrappedConnectionHandler

public RpcConnectionHandler<UserClient.UserToBitConnection> getWrappedConnectionHandler(RpcConnectionHandler<UserClient.UserToBitConnection> handler)

resultArrived

public void resultArrived(io.netty.buffer.ByteBuf pBody)
                   throws RpcException

Maps internal low-level API protocol to UserResultsListener-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 to UserResultsListener-level API protocol. handles query data messages

Throws:

RpcException