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 inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

TaskRunner(Task<? extends Serializable> tsk, TaskResult result)

Method Summary

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, 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, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

TaskRunner

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

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()