public class TaskRunnerCallable
extends org.apache.tez.common.CallableWithNdc<org.apache.tez.runtime.task.TaskRunner2Result>
Modifier and Type | Class and Description |
---|---|
static class |
TaskRunnerCallable.ConfParams |
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) |
public 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)
public long getStartTime()
protected org.apache.tez.runtime.task.TaskRunner2Result callInternal() throws Exception
callInternal
in class org.apache.tez.common.CallableWithNdc<org.apache.tez.runtime.task.TaskRunner2Result>
Exception
public void killTask()
public void reportTaskKilled()
public boolean canFinish()
public boolean canFinishForPriority()
public void updateCanFinishForPriority(boolean value)
public void shutdown()
public String getRequestId()
public String getQueryId()
public QueryFragmentInfo getFragmentInfo()
public org.apache.hadoop.hive.llap.daemon.impl.TaskRunnerCallable.TaskRunnerCallback getCallback()
public LlapDaemonProtocolProtos.SubmitWorkRequestProto getRequest()
public static String getTaskIdentifierString(LlapDaemonProtocolProtos.SubmitWorkRequestProto request, LlapDaemonProtocolProtos.SignableVertexSpec vertex, String queryId)
public LlapDaemonProtocolProtos.FragmentRuntimeInfo getFragmentRuntimeInfo()
public LlapDaemonProtocolProtos.SignableVertexSpec getVertexSpec()
public boolean isGuaranteed()
public void setIsGuaranteed(boolean isGuaranteed)
public void setWmCountersDone()
public void setWmCountersQueued()
public void setWmCountersRunning()
Copyright © 2022 The Apache Software Foundation. All rights reserved.