public abstract static class LlapDaemonProtocolProtos.LlapDaemonProtocol extends Object implements com.google.protobuf.Service
LlapDaemonProtocol
Modifier and Type | Class and Description |
---|---|
static interface |
LlapDaemonProtocolProtos.LlapDaemonProtocol.BlockingInterface |
static interface |
LlapDaemonProtocolProtos.LlapDaemonProtocol.Interface |
static class |
LlapDaemonProtocolProtos.LlapDaemonProtocol.Stub |
Modifier | Constructor and Description |
---|---|
protected |
LlapDaemonProtocol() |
Modifier and Type | Method and Description |
---|---|
void |
callMethod(com.google.protobuf.Descriptors.MethodDescriptor method,
com.google.protobuf.RpcController controller,
com.google.protobuf.Message request,
com.google.protobuf.RpcCallback<com.google.protobuf.Message> done) |
static com.google.protobuf.Descriptors.ServiceDescriptor |
getDescriptor() |
com.google.protobuf.Descriptors.ServiceDescriptor |
getDescriptorForType() |
com.google.protobuf.Message |
getRequestPrototype(com.google.protobuf.Descriptors.MethodDescriptor method) |
com.google.protobuf.Message |
getResponsePrototype(com.google.protobuf.Descriptors.MethodDescriptor method) |
static LlapDaemonProtocolProtos.LlapDaemonProtocol.BlockingInterface |
newBlockingStub(com.google.protobuf.BlockingRpcChannel channel) |
static com.google.protobuf.BlockingService |
newReflectiveBlockingService(LlapDaemonProtocolProtos.LlapDaemonProtocol.BlockingInterface impl) |
static com.google.protobuf.Service |
newReflectiveService(LlapDaemonProtocolProtos.LlapDaemonProtocol.Interface impl) |
static LlapDaemonProtocolProtos.LlapDaemonProtocol.Stub |
newStub(com.google.protobuf.RpcChannel channel) |
abstract void |
queryComplete(com.google.protobuf.RpcController controller,
LlapDaemonProtocolProtos.QueryCompleteRequestProto request,
com.google.protobuf.RpcCallback<LlapDaemonProtocolProtos.QueryCompleteResponseProto> done)
rpc queryComplete(.QueryCompleteRequestProto) returns (.QueryCompleteResponseProto); |
abstract void |
sourceStateUpdated(com.google.protobuf.RpcController controller,
LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto request,
com.google.protobuf.RpcCallback<LlapDaemonProtocolProtos.SourceStateUpdatedResponseProto> done)
rpc sourceStateUpdated(.SourceStateUpdatedRequestProto) returns (.SourceStateUpdatedResponseProto); |
abstract void |
submitWork(com.google.protobuf.RpcController controller,
LlapDaemonProtocolProtos.SubmitWorkRequestProto request,
com.google.protobuf.RpcCallback<LlapDaemonProtocolProtos.SubmitWorkResponseProto> done)
rpc submitWork(.SubmitWorkRequestProto) returns (.SubmitWorkResponseProto); |
abstract void |
terminateFragment(com.google.protobuf.RpcController controller,
LlapDaemonProtocolProtos.TerminateFragmentRequestProto request,
com.google.protobuf.RpcCallback<LlapDaemonProtocolProtos.TerminateFragmentResponseProto> done)
rpc terminateFragment(.TerminateFragmentRequestProto) returns (.TerminateFragmentResponseProto); |
abstract void |
updateFragment(com.google.protobuf.RpcController controller,
LlapDaemonProtocolProtos.UpdateFragmentRequestProto request,
com.google.protobuf.RpcCallback<LlapDaemonProtocolProtos.UpdateFragmentResponseProto> done)
rpc updateFragment(.UpdateFragmentRequestProto) returns (.UpdateFragmentResponseProto); |
public static com.google.protobuf.Service newReflectiveService(LlapDaemonProtocolProtos.LlapDaemonProtocol.Interface impl)
public static com.google.protobuf.BlockingService newReflectiveBlockingService(LlapDaemonProtocolProtos.LlapDaemonProtocol.BlockingInterface impl)
public abstract void submitWork(com.google.protobuf.RpcController controller, LlapDaemonProtocolProtos.SubmitWorkRequestProto request, com.google.protobuf.RpcCallback<LlapDaemonProtocolProtos.SubmitWorkResponseProto> done)
rpc submitWork(.SubmitWorkRequestProto) returns (.SubmitWorkResponseProto);
public abstract void sourceStateUpdated(com.google.protobuf.RpcController controller, LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto request, com.google.protobuf.RpcCallback<LlapDaemonProtocolProtos.SourceStateUpdatedResponseProto> done)
rpc sourceStateUpdated(.SourceStateUpdatedRequestProto) returns (.SourceStateUpdatedResponseProto);
public abstract void queryComplete(com.google.protobuf.RpcController controller, LlapDaemonProtocolProtos.QueryCompleteRequestProto request, com.google.protobuf.RpcCallback<LlapDaemonProtocolProtos.QueryCompleteResponseProto> done)
rpc queryComplete(.QueryCompleteRequestProto) returns (.QueryCompleteResponseProto);
public abstract void terminateFragment(com.google.protobuf.RpcController controller, LlapDaemonProtocolProtos.TerminateFragmentRequestProto request, com.google.protobuf.RpcCallback<LlapDaemonProtocolProtos.TerminateFragmentResponseProto> done)
rpc terminateFragment(.TerminateFragmentRequestProto) returns (.TerminateFragmentResponseProto);
public abstract void updateFragment(com.google.protobuf.RpcController controller, LlapDaemonProtocolProtos.UpdateFragmentRequestProto request, com.google.protobuf.RpcCallback<LlapDaemonProtocolProtos.UpdateFragmentResponseProto> done)
rpc updateFragment(.UpdateFragmentRequestProto) returns (.UpdateFragmentResponseProto);
public static final com.google.protobuf.Descriptors.ServiceDescriptor getDescriptor()
public final com.google.protobuf.Descriptors.ServiceDescriptor getDescriptorForType()
getDescriptorForType
in interface com.google.protobuf.Service
public final void callMethod(com.google.protobuf.Descriptors.MethodDescriptor method, com.google.protobuf.RpcController controller, com.google.protobuf.Message request, com.google.protobuf.RpcCallback<com.google.protobuf.Message> done)
callMethod
in interface com.google.protobuf.Service
public final com.google.protobuf.Message getRequestPrototype(com.google.protobuf.Descriptors.MethodDescriptor method)
getRequestPrototype
in interface com.google.protobuf.Service
public final com.google.protobuf.Message getResponsePrototype(com.google.protobuf.Descriptors.MethodDescriptor method)
getResponsePrototype
in interface com.google.protobuf.Service
public static LlapDaemonProtocolProtos.LlapDaemonProtocol.Stub newStub(com.google.protobuf.RpcChannel channel)
public static LlapDaemonProtocolProtos.LlapDaemonProtocol.BlockingInterface newBlockingStub(com.google.protobuf.BlockingRpcChannel channel)
Copyright © 2022 The Apache Software Foundation. All rights reserved.