Package org.apache.drill.exec.rpc.user
Class AwaitableUserResultsListener
java.lang.Object
org.apache.drill.exec.rpc.user.AwaitableUserResultsListener
- All Implemented Interfaces:
UserResultsListener
General mechanism for waiting on the query to be executed
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionint
await()
void
dataArrived
(QueryDataBatch result, ConnectionThrottle throttle) AQueryData
message was receivedvoid
The query has completed (successful completion or cancellation).void
queryIdArrived
(UserBitShared.QueryId queryId) QueryId is available.void
The query has failed.
-
Constructor Details
-
AwaitableUserResultsListener
- Parameters:
child
- the listener responsible for consuming the data
-
-
Method Details
-
dataArrived
Description copied from interface:UserResultsListener
AQueryData
message was received- Specified by:
dataArrived
in interfaceUserResultsListener
- Parameters:
result
- data batch receivedthrottle
- connection throttle
-
submissionFailed
Description copied from interface:UserResultsListener
The query has failed. Most likely called when the server returns a FAILED query state. Can also be called ifdataArrived()
throws an exception- Specified by:
submissionFailed
in interfaceUserResultsListener
- Parameters:
ex
- exception describing the cause of the failure
-
await
- Throws:
Exception