Modifier and Type | Method and Description |
---|---|
LlapDaemonProtocolProtos.SubmitWorkResponseProto |
ContainerRunner.submitWork(LlapDaemonProtocolProtos.SubmitWorkRequestProto request) |
Modifier and Type | Method and Description |
---|---|
LlapDaemonProtocolProtos.SubmitWorkRequestProto |
TaskRunnerCallable.getRequest() |
Modifier and Type | Method and Description |
---|---|
static String |
TaskRunnerCallable.getTaskIdentifierString(LlapDaemonProtocolProtos.SubmitWorkRequestProto request,
LlapDaemonProtocolProtos.SignableVertexSpec vertex,
String queryId) |
static String |
ContainerRunnerImpl.stringifySubmitRequest(LlapDaemonProtocolProtos.SubmitWorkRequestProto request,
LlapDaemonProtocolProtos.SignableVertexSpec vertex) |
LlapDaemonProtocolProtos.SubmitWorkResponseProto |
ContainerRunnerImpl.submitWork(LlapDaemonProtocolProtos.SubmitWorkRequestProto request) |
LlapDaemonProtocolProtos.SubmitWorkResponseProto |
LlapDaemon.submitWork(LlapDaemonProtocolProtos.SubmitWorkRequestProto request) |
LlapDaemonProtocolProtos.SubmitWorkResponseProto |
LlapProtocolServerImpl.submitWork(com.google.protobuf.RpcController controller,
LlapDaemonProtocolProtos.SubmitWorkRequestProto request) |
Constructor and Description |
---|
TaskRunnerCallable(LlapDaemonProtocolProtos.SubmitWorkRequestProto request,
QueryFragmentInfo fragmentInfo,
org.apache.hadoop.conf.Configuration conf,
org.apache.tez.runtime.api.ExecutionContext executionContext,
Map<String,String> envMap,
org.apache.hadoop.security.Credentials credentials,
long memoryAvailable,
AMReporter amReporter,
TaskRunnerCallable.ConfParams confParams,
LlapDaemonExecutorMetrics metrics,
KilledTaskHandler killedTaskHandler,
FragmentCompletionHandler fragmentCompleteHandler,
org.apache.tez.hadoop.shim.HadoopShim tezHadoopShim,
org.apache.tez.dag.records.TezTaskAttemptID attemptId,
LlapDaemonProtocolProtos.SignableVertexSpec vertex,
org.apache.tez.runtime.api.impl.TezEvent initialEvent,
org.apache.hadoop.security.UserGroupInformation fsTaskUgi,
SchedulerFragmentCompletingListener completionListener,
SocketFactory socketFactory,
boolean isGuaranteed,
WmFragmentCounters wmCounters) |
Modifier and Type | Field and Description |
---|---|
static com.google.protobuf.Parser<LlapDaemonProtocolProtos.SubmitWorkRequestProto> |
LlapDaemonProtocolProtos.SubmitWorkRequestProto.PARSER |
Modifier and Type | Method and Description |
---|---|
LlapDaemonProtocolProtos.SubmitWorkRequestProto |
LlapDaemonProtocolProtos.SubmitWorkRequestProto.Builder.build() |
LlapDaemonProtocolProtos.SubmitWorkRequestProto |
LlapDaemonProtocolProtos.SubmitWorkRequestProto.Builder.buildPartial() |
static LlapDaemonProtocolProtos.SubmitWorkRequestProto |
LlapDaemonProtocolProtos.SubmitWorkRequestProto.getDefaultInstance() |
LlapDaemonProtocolProtos.SubmitWorkRequestProto |
LlapDaemonProtocolProtos.SubmitWorkRequestProto.getDefaultInstanceForType() |
LlapDaemonProtocolProtos.SubmitWorkRequestProto |
LlapDaemonProtocolProtos.SubmitWorkRequestProto.Builder.getDefaultInstanceForType() |
static LlapDaemonProtocolProtos.SubmitWorkRequestProto |
LlapDaemonProtocolProtos.SubmitWorkRequestProto.parseDelimitedFrom(InputStream input) |
static LlapDaemonProtocolProtos.SubmitWorkRequestProto |
LlapDaemonProtocolProtos.SubmitWorkRequestProto.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static LlapDaemonProtocolProtos.SubmitWorkRequestProto |
LlapDaemonProtocolProtos.SubmitWorkRequestProto.parseFrom(byte[] data) |
static LlapDaemonProtocolProtos.SubmitWorkRequestProto |
LlapDaemonProtocolProtos.SubmitWorkRequestProto.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static LlapDaemonProtocolProtos.SubmitWorkRequestProto |
LlapDaemonProtocolProtos.SubmitWorkRequestProto.parseFrom(com.google.protobuf.ByteString data) |
static LlapDaemonProtocolProtos.SubmitWorkRequestProto |
LlapDaemonProtocolProtos.SubmitWorkRequestProto.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static LlapDaemonProtocolProtos.SubmitWorkRequestProto |
LlapDaemonProtocolProtos.SubmitWorkRequestProto.parseFrom(com.google.protobuf.CodedInputStream input) |
static LlapDaemonProtocolProtos.SubmitWorkRequestProto |
LlapDaemonProtocolProtos.SubmitWorkRequestProto.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static LlapDaemonProtocolProtos.SubmitWorkRequestProto |
LlapDaemonProtocolProtos.SubmitWorkRequestProto.parseFrom(InputStream input) |
static LlapDaemonProtocolProtos.SubmitWorkRequestProto |
LlapDaemonProtocolProtos.SubmitWorkRequestProto.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
com.google.protobuf.Parser<LlapDaemonProtocolProtos.SubmitWorkRequestProto> |
LlapDaemonProtocolProtos.SubmitWorkRequestProto.getParserForType() |
Modifier and Type | Method and Description |
---|---|
LlapDaemonProtocolProtos.SubmitWorkRequestProto.Builder |
LlapDaemonProtocolProtos.SubmitWorkRequestProto.Builder.mergeFrom(LlapDaemonProtocolProtos.SubmitWorkRequestProto other) |
static LlapDaemonProtocolProtos.SubmitWorkRequestProto.Builder |
LlapDaemonProtocolProtos.SubmitWorkRequestProto.newBuilder(LlapDaemonProtocolProtos.SubmitWorkRequestProto prototype) |
LlapDaemonProtocolProtos.SubmitWorkResponseProto |
LlapDaemonProtocolProtos.LlapDaemonProtocol.BlockingInterface.submitWork(com.google.protobuf.RpcController controller,
LlapDaemonProtocolProtos.SubmitWorkRequestProto request) |
abstract void |
LlapDaemonProtocolProtos.LlapDaemonProtocol.submitWork(com.google.protobuf.RpcController controller,
LlapDaemonProtocolProtos.SubmitWorkRequestProto request,
com.google.protobuf.RpcCallback<LlapDaemonProtocolProtos.SubmitWorkResponseProto> done)
rpc submitWork(.SubmitWorkRequestProto) returns (.SubmitWorkResponseProto); |
void |
LlapDaemonProtocolProtos.LlapDaemonProtocol.Interface.submitWork(com.google.protobuf.RpcController controller,
LlapDaemonProtocolProtos.SubmitWorkRequestProto request,
com.google.protobuf.RpcCallback<LlapDaemonProtocolProtos.SubmitWorkResponseProto> done)
rpc submitWork(.SubmitWorkRequestProto) returns (.SubmitWorkResponseProto); |
void |
LlapDaemonProtocolProtos.LlapDaemonProtocol.Stub.submitWork(com.google.protobuf.RpcController controller,
LlapDaemonProtocolProtos.SubmitWorkRequestProto request,
com.google.protobuf.RpcCallback<LlapDaemonProtocolProtos.SubmitWorkResponseProto> done) |
Modifier and Type | Method and Description |
---|---|
void |
LlapTaskUmbilicalExternalClient.submitWork(LlapDaemonProtocolProtos.SubmitWorkRequestProto request,
String llapHost,
int llapPort)
Submit the work for actual execution.
|
Modifier and Type | Method and Description |
---|---|
LlapDaemonProtocolProtos.SubmitWorkResponseProto |
LlapProtocolClientImpl.submitWork(com.google.protobuf.RpcController controller,
LlapDaemonProtocolProtos.SubmitWorkRequestProto request) |
Modifier and Type | Method and Description |
---|---|
void |
LlapProtocolClientProxy.sendSubmitWork(LlapDaemonProtocolProtos.SubmitWorkRequestProto request,
String host,
int port,
AsyncPbRpcProxy.ExecuteRequestCallback<LlapDaemonProtocolProtos.SubmitWorkResponseProto> callback) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.