org.apache.hadoop.hive.llap.daemon.impl

Class TaskExecutorService.TaskWrapper

java.lang.Object

org.apache.hadoop.hive.llap.daemon.impl.TaskExecutorService.TaskWrapper

All Implemented Interfaces:

FinishableStateUpdateHandler

Enclosing class:

TaskExecutorService

public static class TaskExecutorService.TaskWrapper
extends Object
implements FinishableStateUpdateHandler

Constructor Summary

Constructors

Constructor and Description
TaskWrapper(TaskRunnerCallable taskRunnerCallable, TaskExecutorService taskExecutorService)

Method Summary

Modifier and Type	Method and Description
boolean	canFinishForPriority()
boolean	equals(Object o)
void	finishableStateUpdated(boolean finishableState)
String	getRequestId()
TaskRunnerCallable	getTaskRunnerCallable()
int	hashCode()
boolean	isGuaranteed()
boolean	isInPreemptionQueue()
boolean	isInWaitQueue()
boolean	maybeRegisterForFinishedStateNotifications(boolean currentFinishableState)
void	maybeUnregisterForFinishedStateNotifications()
void	setIsInPreemptableQueue(boolean value)
void	setIsInWaitQueue(boolean value)
String	toString()
void	updateCanFinishForPriority(boolean newFinishableState)
void	updateIsGuaranteed(boolean isGuaranteed)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

TaskWrapper

public TaskWrapper(TaskRunnerCallable taskRunnerCallable,
                   TaskExecutorService taskExecutorService)

Method Detail

updateIsGuaranteed

public void updateIsGuaranteed(boolean isGuaranteed)

canFinishForPriority

public boolean canFinishForPriority()

isGuaranteed

public boolean isGuaranteed()

updateCanFinishForPriority

public void updateCanFinishForPriority(boolean newFinishableState)

maybeRegisterForFinishedStateNotifications

public boolean maybeRegisterForFinishedStateNotifications(boolean currentFinishableState)

Parameters:

currentFinishableState -

Returns:

true if the state has not changed from currentFinishableState, false otherwise

maybeUnregisterForFinishedStateNotifications

public void maybeUnregisterForFinishedStateNotifications()

getTaskRunnerCallable

public TaskRunnerCallable getTaskRunnerCallable()

isInWaitQueue

public boolean isInWaitQueue()

isInPreemptionQueue

public boolean isInPreemptionQueue()

setIsInWaitQueue

public void setIsInWaitQueue(boolean value)

setIsInPreemptableQueue

public void setIsInPreemptableQueue(boolean value)

getRequestId

public String getRequestId()

toString

public String toString()

Overrides:

toString in class Object

finishableStateUpdated

public void finishableStateUpdated(boolean finishableState)

Specified by:

finishableStateUpdated in interface FinishableStateUpdateHandler

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object