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) |
Modifier and Type | Method and Description |
---|---|
protected org.apache.tez.runtime.task.TaskRunner2Result |
callInternal() |
boolean |
canFinish() |
boolean |
equals(Object obj) |
org.apache.hadoop.hive.llap.daemon.impl.TaskRunnerCallable.TaskRunnerCallback |
getCallback() |
QueryFragmentInfo |
getFragmentInfo() |
LlapDaemonProtocolProtos.FragmentRuntimeInfo |
getFragmentRuntimeInfo() |
String |
getQueryId() |
LlapDaemonProtocolProtos.SubmitWorkRequestProto |
getRequest() |
String |
getRequestId() |
long |
getStartTime() |
static String |
getTaskIdentifierString(LlapDaemonProtocolProtos.SubmitWorkRequestProto request,
LlapDaemonProtocolProtos.SignableVertexSpec vertex) |
LlapDaemonProtocolProtos.SignableVertexSpec |
getVertexSpec() |
int |
hashCode() |
void |
killTask()
Attempt to kill a running task.
|
void |
reportTaskKilled()
Inform the AM that this task has been killed.
|
void |
shutdown() |
String |
toString() |
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)
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 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)
public LlapDaemonProtocolProtos.FragmentRuntimeInfo getFragmentRuntimeInfo()
public LlapDaemonProtocolProtos.SignableVertexSpec getVertexSpec()
Copyright © 2016 The Apache Software Foundation. All rights reserved.