org.apache.hadoop.hive.ql.exec

Class TaskRunner

java.lang.Object

java.lang.Thread

org.apache.hadoop.hive.ql.exec.TaskRunner

All Implemented Interfaces:

java.lang.Runnable

public class TaskRunner
extends java.lang.Thread

TaskRunner implementation.

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected TaskResult	result
protected SessionState	ss
protected Task<? extends java.io.Serializable>	tsk

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
TaskRunner(Task<? extends java.io.Serializable> tsk, TaskResult result)

Method Summary

Modifier and Type	Method and Description
Task<? extends java.io.Serializable>	getTask()
static long	getTaskRunnerID()
void	run()
void	runSequential() Launches a task, and sets its exit value in the result variable.

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

tsk

protected Task<? extends java.io.Serializable> tsk

result

protected TaskResult result

ss

protected SessionState ss

Constructor Detail

TaskRunner

public TaskRunner(Task<? extends java.io.Serializable> tsk,
                  TaskResult result)

Method Detail

getTask

public Task<? extends java.io.Serializable> getTask()

run

public void run()

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread

runSequential

public void runSequential()

Launches a task, and sets its exit value in the result variable.

getTaskRunnerID

public static long getTaskRunnerID()