void |
LlapProtocolClientProxy.sendQueryComplete(org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.QueryCompleteRequestProto request,
String host,
int port,
AsyncPbRpcProxy.ExecuteRequestCallback<org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.QueryCompleteResponseProto> callback) |
void |
LlapProtocolClientProxy.sendSourceStateUpdate(org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto request,
LlapNodeId nodeId,
AsyncPbRpcProxy.ExecuteRequestCallback<org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SourceStateUpdatedResponseProto> callback) |
void |
LlapProtocolClientProxy.sendSubmitWork(org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SubmitWorkRequestProto request,
String host,
int port,
AsyncPbRpcProxy.ExecuteRequestCallback<org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SubmitWorkResponseProto> callback) |
void |
LlapProtocolClientProxy.sendTerminateFragment(org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.TerminateFragmentRequestProto request,
String host,
int port,
AsyncPbRpcProxy.ExecuteRequestCallback<org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.TerminateFragmentResponseProto> callback) |
void |
LlapProtocolClientProxy.sendUpdateFragment(org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.UpdateFragmentRequestProto request,
String host,
int port,
AsyncPbRpcProxy.ExecuteRequestCallback<org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.UpdateFragmentResponseProto> callback) |