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) |
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)
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()
Copyright © 2021 The Apache Software Foundation. All rights reserved.