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

java.lang.Object
  extended by java.lang.Thread
      extended by 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
protected  TaskResult result
           
protected  SessionState ss
           
protected  Task<? extends Serializable> tsk
           
 
Fields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
 
Constructor Summary
TaskRunner(Task<? extends Serializable> tsk, TaskResult result)
           
 
Method Summary
 Task<? extends Serializable> getTask()
           
 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
Constructor Detail

TaskRunner

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

getTask

public Task<? extends Serializable> getTask()

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.



Copyright © 2013 The Apache Software Foundation