Modifier and Type | Method and Description |
---|---|
LlapDaemonProtocolProtos.SourceStateUpdatedResponseProto |
ContainerRunner.sourceStateUpdated(LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto request) |
Modifier and Type | Method and Description |
---|---|
LlapDaemonProtocolProtos.SourceStateUpdatedResponseProto |
ContainerRunnerImpl.sourceStateUpdated(LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto request) |
LlapDaemonProtocolProtos.SourceStateUpdatedResponseProto |
LlapDaemon.sourceStateUpdated(LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto request) |
LlapDaemonProtocolProtos.SourceStateUpdatedResponseProto |
LlapProtocolServerImpl.sourceStateUpdated(com.google.protobuf.RpcController controller,
LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto request) |
Modifier and Type | Field and Description |
---|---|
static com.google.protobuf.Parser<LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto> |
LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto.PARSER |
Modifier and Type | Method and Description |
---|---|
LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto |
LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto.Builder.build() |
LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto |
LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto.Builder.buildPartial() |
static LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto |
LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto.getDefaultInstance() |
LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto |
LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto.getDefaultInstanceForType() |
LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto |
LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto.Builder.getDefaultInstanceForType() |
static LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto |
LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto.parseDelimitedFrom(InputStream input) |
static LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto |
LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto |
LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto.parseFrom(byte[] data) |
static LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto |
LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto |
LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto.parseFrom(com.google.protobuf.ByteString data) |
static LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto |
LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto |
LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto.parseFrom(com.google.protobuf.CodedInputStream input) |
static LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto |
LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto |
LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto.parseFrom(InputStream input) |
static LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto |
LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
com.google.protobuf.Parser<LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto> |
LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto.getParserForType() |
Modifier and Type | Method and Description |
---|---|
LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto.Builder |
LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto.Builder.mergeFrom(LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto other) |
static LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto.Builder |
LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto.newBuilder(LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto prototype) |
LlapDaemonProtocolProtos.SourceStateUpdatedResponseProto |
LlapDaemonProtocolProtos.LlapDaemonProtocol.BlockingInterface.sourceStateUpdated(com.google.protobuf.RpcController controller,
LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto request) |
abstract void |
LlapDaemonProtocolProtos.LlapDaemonProtocol.sourceStateUpdated(com.google.protobuf.RpcController controller,
LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto request,
com.google.protobuf.RpcCallback<LlapDaemonProtocolProtos.SourceStateUpdatedResponseProto> done)
rpc sourceStateUpdated(.SourceStateUpdatedRequestProto) returns (.SourceStateUpdatedResponseProto); |
void |
LlapDaemonProtocolProtos.LlapDaemonProtocol.Interface.sourceStateUpdated(com.google.protobuf.RpcController controller,
LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto request,
com.google.protobuf.RpcCallback<LlapDaemonProtocolProtos.SourceStateUpdatedResponseProto> done)
rpc sourceStateUpdated(.SourceStateUpdatedRequestProto) returns (.SourceStateUpdatedResponseProto); |
void |
LlapDaemonProtocolProtos.LlapDaemonProtocol.Stub.sourceStateUpdated(com.google.protobuf.RpcController controller,
LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto request,
com.google.protobuf.RpcCallback<LlapDaemonProtocolProtos.SourceStateUpdatedResponseProto> done) |
Modifier and Type | Method and Description |
---|---|
LlapDaemonProtocolProtos.SourceStateUpdatedResponseProto |
LlapProtocolClientImpl.sourceStateUpdated(com.google.protobuf.RpcController controller,
LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto request) |
Modifier and Type | Method and Description |
---|---|
void |
LlapProtocolClientProxy.sendSourceStateUpdate(LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto request,
LlapNodeId nodeId,
AsyncPbRpcProxy.ExecuteRequestCallback<LlapDaemonProtocolProtos.SourceStateUpdatedResponseProto> callback) |
Modifier and Type | Method and Description |
---|---|
void |
LlapTaskCommunicator.sendStateUpdate(LlapNodeId nodeId,
LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto request) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.