void |
LlapProtocolClientProxy.sendQueryComplete(LlapDaemonProtocolProtos.QueryCompleteRequestProto request,
String host,
int port,
LlapProtocolClientProxy.ExecuteRequestCallback<LlapDaemonProtocolProtos.QueryCompleteResponseProto> callback) |
void |
LlapProtocolClientProxy.sendSourceStateUpdate(LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto request,
LlapNodeId nodeId,
LlapProtocolClientProxy.ExecuteRequestCallback<LlapDaemonProtocolProtos.SourceStateUpdatedResponseProto> callback) |
void |
LlapProtocolClientProxy.sendSubmitWork(LlapDaemonProtocolProtos.SubmitWorkRequestProto request,
String host,
int port,
LlapProtocolClientProxy.ExecuteRequestCallback<LlapDaemonProtocolProtos.SubmitWorkResponseProto> callback) |
void |
LlapProtocolClientProxy.sendTerminateFragment(LlapDaemonProtocolProtos.TerminateFragmentRequestProto request,
String host,
int port,
LlapProtocolClientProxy.ExecuteRequestCallback<LlapDaemonProtocolProtos.TerminateFragmentResponseProto> callback) |