org.apache.hadoop.hive.ql.exec

Class TaskRunner

java.lang.Object

java.lang.Thread

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

All Implemented Interfaces:

Runnable

public class TaskRunner
extends Thread

TaskRunner implementation.

Nested Class Summary

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

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected TaskResult	result
protected Thread	runner
protected SessionState	ss
protected Task<? extends Serializable>	tsk

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
TaskRunner(Task<? extends Serializable> tsk)

Method Summary

Modifier and Type	Method and Description
Thread	getRunner()
Task<? extends Serializable>	getTask()
TaskResult	getTaskResult()
static long	getTaskRunnerID()
boolean	isRunning()
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 Serializable> tsk

result

protected TaskResult result

ss

protected SessionState ss

runner

protected Thread runner

Constructor Detail

TaskRunner

public TaskRunner(Task<? extends Serializable> tsk)

Method Detail

getTask

public Task<? extends Serializable> getTask()

getTaskResult

public TaskResult getTaskResult()

getRunner

public Thread getRunner()

isRunning

public boolean isRunning()

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

runSequential

public void runSequential()

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

getTaskRunnerID

public static long getTaskRunnerID()