Package | Description |
---|---|
org.apache.hadoop.hive.llap.daemon | |
org.apache.hadoop.hive.llap.daemon.impl |
Modifier and Type | Method and Description |
---|---|
void |
FragmentCompletionHandler.fragmentComplete(QueryFragmentInfo fragmentInfo) |
Modifier and Type | Method and Description |
---|---|
QueryFragmentInfo |
TaskRunnerCallable.getFragmentInfo() |
QueryFragmentInfo |
QueryInfo.registerFragment(String vertexName,
int fragmentNumber,
int attemptNumber,
LlapDaemonProtocolProtos.SignableVertexSpec vertexSpec,
String fragmentIdString) |
Modifier and Type | Method and Description |
---|---|
List<QueryFragmentInfo> |
QueryInfo.getRegisteredFragments() |
Modifier and Type | Method and Description |
---|---|
static boolean |
QueryFragmentInfo.canFinish(QueryFragmentInfo fragment)
Check whether a task can run to completion or may end up blocking on it's sources.
|
void |
ContainerRunnerImpl.fragmentComplete(QueryFragmentInfo fragmentInfo) |
void |
QueryInfo.unregisterFragment(QueryFragmentInfo fragmentInfo) |
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) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.