org.apache.hadoop.hive.llap.daemon.impl

Class TaskRunnerCallable

java.lang.Object

org.apache.tez.common.CallableWithNdc<org.apache.tez.runtime.task.TaskRunner2Result>

org.apache.hadoop.hive.llap.daemon.impl.TaskRunnerCallable

All Implemented Interfaces:

Callable<org.apache.tez.runtime.task.TaskRunner2Result>

public class TaskRunnerCallable
extends org.apache.tez.common.CallableWithNdc<org.apache.tez.runtime.task.TaskRunner2Result>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TaskRunnerCallable.ConfParams

Constructor Summary

Constructors

Constructor and Description

TaskRunnerCallable(org.apache.hadoop.hive.llap.daemon.rpc.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, org.apache.hadoop.hive.llap.daemon.rpc.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)

Method Summary

Modifier and Type	Method and Description
protected org.apache.tez.runtime.task.TaskRunner2Result	callInternal()
boolean	canFinish()
boolean	canFinishForPriority()
boolean	equals(Object obj)
org.apache.hadoop.hive.llap.daemon.impl.TaskRunnerCallable.TaskRunnerCallback	getCallback()
QueryFragmentInfo	getFragmentInfo()
org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.FragmentRuntimeInfo	getFragmentRuntimeInfo()
String	getQueryId()
org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SubmitWorkRequestProto	getRequest()
String	getRequestId()
long	getStartTime()
static String	getTaskIdentifierString(org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SubmitWorkRequestProto request, org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SignableVertexSpec vertex, String queryId)
org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SignableVertexSpec	getVertexSpec()
int	hashCode()
boolean	isGuaranteed()
void	killTask() Attempt to kill a running task.
void	reportTaskKilled() Inform the AM that this task has been killed.
void	setIsGuaranteed(boolean isGuaranteed)
void	setWmCountersDone()
void	setWmCountersQueued()
void	setWmCountersRunning()
void	shutdown()
String	toString()
void	updateCanFinishForPriority(boolean value)

Methods inherited from class org.apache.tez.common.CallableWithNdc

call

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

TaskRunnerCallable

public TaskRunnerCallable(org.apache.hadoop.hive.llap.daemon.rpc.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,
                          org.apache.hadoop.hive.llap.daemon.rpc.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)

Method Detail

getStartTime

public long getStartTime()

callInternal

protected org.apache.tez.runtime.task.TaskRunner2Result callInternal()
                                                              throws Exception

Specified by:

callInternal in class org.apache.tez.common.CallableWithNdc<org.apache.tez.runtime.task.TaskRunner2Result>

Throws:

Exception

killTask

public void killTask()

Attempt to kill a running task. If the task has not started running, it will not start. If it's already running, a kill request will be sent to it.

The AM will be informed about the task kill.

reportTaskKilled

public void reportTaskKilled()

Inform the AM that this task has been killed.

canFinish

public boolean canFinish()

canFinishForPriority

public boolean canFinishForPriority()

updateCanFinishForPriority

public void updateCanFinishForPriority(boolean value)

shutdown

public void shutdown()

toString

public String toString()

Overrides:

toString in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

getRequestId

public String getRequestId()

getQueryId

public String getQueryId()

getFragmentInfo

public QueryFragmentInfo getFragmentInfo()

getCallback

public org.apache.hadoop.hive.llap.daemon.impl.TaskRunnerCallable.TaskRunnerCallback getCallback()

getRequest

public org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SubmitWorkRequestProto getRequest()

getTaskIdentifierString

public static String getTaskIdentifierString(org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SubmitWorkRequestProto request,
                                             org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SignableVertexSpec vertex,
                                             String queryId)

getFragmentRuntimeInfo

public org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.FragmentRuntimeInfo getFragmentRuntimeInfo()

getVertexSpec

public org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SignableVertexSpec getVertexSpec()

isGuaranteed

public boolean isGuaranteed()

setIsGuaranteed

public void setIsGuaranteed(boolean isGuaranteed)

setWmCountersDone

public void setWmCountersDone()

setWmCountersQueued

public void setWmCountersQueued()

setWmCountersRunning

public void setWmCountersRunning()