Package | Description |
---|---|
org.apache.hadoop.hive.llap.daemon.impl | |
org.apache.hadoop.hive.llap.daemon.rpc | |
org.apache.hadoop.hive.llap.tez |
Modifier and Type | Method and Description |
---|---|
LlapDaemonProtocolProtos.SignableVertexSpec |
TaskRunnerCallable.getVertexSpec() |
LlapDaemonProtocolProtos.SignableVertexSpec |
QueryFragmentInfo.getVertexSpec() |
Modifier and Type | Method and Description |
---|---|
static String |
TaskRunnerCallable.getTaskIdentifierString(LlapDaemonProtocolProtos.SubmitWorkRequestProto request,
LlapDaemonProtocolProtos.SignableVertexSpec vertex) |
QueryFragmentInfo |
QueryInfo.registerFragment(String vertexName,
int fragmentNumber,
int attemptNumber,
LlapDaemonProtocolProtos.SignableVertexSpec vertexSpec,
String fragmentIdString) |
static String |
ContainerRunnerImpl.stringifySubmitRequest(LlapDaemonProtocolProtos.SubmitWorkRequestProto request,
LlapDaemonProtocolProtos.SignableVertexSpec vertex) |
Constructor and Description |
---|
QueryFragmentInfo(QueryInfo queryInfo,
String vertexName,
int fragmentNumber,
int attemptNumber,
LlapDaemonProtocolProtos.SignableVertexSpec vertexSpec,
String fragmentIdString) |
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) |
Modifier and Type | Field and Description |
---|---|
static com.google.protobuf.Parser<LlapDaemonProtocolProtos.SignableVertexSpec> |
LlapDaemonProtocolProtos.SignableVertexSpec.PARSER |
Modifier and Type | Method and Description |
---|---|
LlapDaemonProtocolProtos.SignableVertexSpec |
LlapDaemonProtocolProtos.SignableVertexSpec.Builder.build() |
LlapDaemonProtocolProtos.SignableVertexSpec |
LlapDaemonProtocolProtos.SignableVertexSpec.Builder.buildPartial() |
static LlapDaemonProtocolProtos.SignableVertexSpec |
LlapDaemonProtocolProtos.SignableVertexSpec.getDefaultInstance() |
LlapDaemonProtocolProtos.SignableVertexSpec |
LlapDaemonProtocolProtos.SignableVertexSpec.getDefaultInstanceForType() |
LlapDaemonProtocolProtos.SignableVertexSpec |
LlapDaemonProtocolProtos.SignableVertexSpec.Builder.getDefaultInstanceForType() |
LlapDaemonProtocolProtos.SignableVertexSpec |
LlapDaemonProtocolProtos.VertexOrBinaryOrBuilder.getVertex()
optional .SignableVertexSpec vertex = 1; |
LlapDaemonProtocolProtos.SignableVertexSpec |
LlapDaemonProtocolProtos.VertexOrBinary.getVertex()
optional .SignableVertexSpec vertex = 1; |
LlapDaemonProtocolProtos.SignableVertexSpec |
LlapDaemonProtocolProtos.VertexOrBinary.Builder.getVertex()
optional .SignableVertexSpec vertex = 1; |
static LlapDaemonProtocolProtos.SignableVertexSpec |
LlapDaemonProtocolProtos.SignableVertexSpec.parseDelimitedFrom(InputStream input) |
static LlapDaemonProtocolProtos.SignableVertexSpec |
LlapDaemonProtocolProtos.SignableVertexSpec.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static LlapDaemonProtocolProtos.SignableVertexSpec |
LlapDaemonProtocolProtos.SignableVertexSpec.parseFrom(byte[] data) |
static LlapDaemonProtocolProtos.SignableVertexSpec |
LlapDaemonProtocolProtos.SignableVertexSpec.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static LlapDaemonProtocolProtos.SignableVertexSpec |
LlapDaemonProtocolProtos.SignableVertexSpec.parseFrom(com.google.protobuf.ByteString data) |
static LlapDaemonProtocolProtos.SignableVertexSpec |
LlapDaemonProtocolProtos.SignableVertexSpec.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static LlapDaemonProtocolProtos.SignableVertexSpec |
LlapDaemonProtocolProtos.SignableVertexSpec.parseFrom(com.google.protobuf.CodedInputStream input) |
static LlapDaemonProtocolProtos.SignableVertexSpec |
LlapDaemonProtocolProtos.SignableVertexSpec.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static LlapDaemonProtocolProtos.SignableVertexSpec |
LlapDaemonProtocolProtos.SignableVertexSpec.parseFrom(InputStream input) |
static LlapDaemonProtocolProtos.SignableVertexSpec |
LlapDaemonProtocolProtos.SignableVertexSpec.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
com.google.protobuf.Parser<LlapDaemonProtocolProtos.SignableVertexSpec> |
LlapDaemonProtocolProtos.SignableVertexSpec.getParserForType() |
Modifier and Type | Method and Description |
---|---|
LlapDaemonProtocolProtos.SignableVertexSpec.Builder |
LlapDaemonProtocolProtos.SignableVertexSpec.Builder.mergeFrom(LlapDaemonProtocolProtos.SignableVertexSpec other) |
LlapDaemonProtocolProtos.VertexOrBinary.Builder |
LlapDaemonProtocolProtos.VertexOrBinary.Builder.mergeVertex(LlapDaemonProtocolProtos.SignableVertexSpec value)
optional .SignableVertexSpec vertex = 1; |
static LlapDaemonProtocolProtos.SignableVertexSpec.Builder |
LlapDaemonProtocolProtos.SignableVertexSpec.newBuilder(LlapDaemonProtocolProtos.SignableVertexSpec prototype) |
LlapDaemonProtocolProtos.VertexOrBinary.Builder |
LlapDaemonProtocolProtos.VertexOrBinary.Builder.setVertex(LlapDaemonProtocolProtos.SignableVertexSpec value)
optional .SignableVertexSpec vertex = 1; |
Modifier and Type | Method and Description |
---|---|
static LlapDaemonProtocolProtos.SignableVertexSpec |
Converters.convertTaskSpecToProto(org.apache.tez.runtime.api.impl.TaskSpec taskSpec,
int appAttemptId,
String tokenIdentifier,
Integer signatureKeyId,
String user) |
Modifier and Type | Method and Description |
---|---|
static org.apache.tez.runtime.api.impl.TaskSpec |
Converters.getTaskSpecfromProto(LlapDaemonProtocolProtos.SignableVertexSpec vectorProto,
int fragmentNum,
int attemptNum,
org.apache.tez.dag.records.TezTaskAttemptID attemptId) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.