public static interface LlapDaemonProtocolProtos.LlapDaemonProtocol.Interface
Modifier and Type | Method and Description |
---|---|
void |
queryComplete(com.google.protobuf.RpcController controller,
LlapDaemonProtocolProtos.QueryCompleteRequestProto request,
com.google.protobuf.RpcCallback<LlapDaemonProtocolProtos.QueryCompleteResponseProto> done)
rpc queryComplete(.QueryCompleteRequestProto) returns (.QueryCompleteResponseProto); |
void |
sourceStateUpdated(com.google.protobuf.RpcController controller,
LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto request,
com.google.protobuf.RpcCallback<LlapDaemonProtocolProtos.SourceStateUpdatedResponseProto> done)
rpc sourceStateUpdated(.SourceStateUpdatedRequestProto) returns (.SourceStateUpdatedResponseProto); |
void |
submitWork(com.google.protobuf.RpcController controller,
LlapDaemonProtocolProtos.SubmitWorkRequestProto request,
com.google.protobuf.RpcCallback<LlapDaemonProtocolProtos.SubmitWorkResponseProto> done)
rpc submitWork(.SubmitWorkRequestProto) returns (.SubmitWorkResponseProto); |
void |
terminateFragment(com.google.protobuf.RpcController controller,
LlapDaemonProtocolProtos.TerminateFragmentRequestProto request,
com.google.protobuf.RpcCallback<LlapDaemonProtocolProtos.TerminateFragmentResponseProto> done)
rpc terminateFragment(.TerminateFragmentRequestProto) returns (.TerminateFragmentResponseProto); |
void |
updateFragment(com.google.protobuf.RpcController controller,
LlapDaemonProtocolProtos.UpdateFragmentRequestProto request,
com.google.protobuf.RpcCallback<LlapDaemonProtocolProtos.UpdateFragmentResponseProto> done)
rpc updateFragment(.UpdateFragmentRequestProto) returns (.UpdateFragmentResponseProto); |
void submitWork(com.google.protobuf.RpcController controller, LlapDaemonProtocolProtos.SubmitWorkRequestProto request, com.google.protobuf.RpcCallback<LlapDaemonProtocolProtos.SubmitWorkResponseProto> done)
rpc submitWork(.SubmitWorkRequestProto) returns (.SubmitWorkResponseProto);
void sourceStateUpdated(com.google.protobuf.RpcController controller, LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto request, com.google.protobuf.RpcCallback<LlapDaemonProtocolProtos.SourceStateUpdatedResponseProto> done)
rpc sourceStateUpdated(.SourceStateUpdatedRequestProto) returns (.SourceStateUpdatedResponseProto);
void queryComplete(com.google.protobuf.RpcController controller, LlapDaemonProtocolProtos.QueryCompleteRequestProto request, com.google.protobuf.RpcCallback<LlapDaemonProtocolProtos.QueryCompleteResponseProto> done)
rpc queryComplete(.QueryCompleteRequestProto) returns (.QueryCompleteResponseProto);
void terminateFragment(com.google.protobuf.RpcController controller, LlapDaemonProtocolProtos.TerminateFragmentRequestProto request, com.google.protobuf.RpcCallback<LlapDaemonProtocolProtos.TerminateFragmentResponseProto> done)
rpc terminateFragment(.TerminateFragmentRequestProto) returns (.TerminateFragmentResponseProto);
void updateFragment(com.google.protobuf.RpcController controller, LlapDaemonProtocolProtos.UpdateFragmentRequestProto request, com.google.protobuf.RpcCallback<LlapDaemonProtocolProtos.UpdateFragmentResponseProto> done)
rpc updateFragment(.UpdateFragmentRequestProto) returns (.UpdateFragmentResponseProto);
Copyright © 2022 The Apache Software Foundation. All rights reserved.