Package se.liu.ida.hefquin.engine.queryplan.executable.impl

Class ExecPlanTaskBase

java.lang.Object

se.liu.ida.hefquin.engine.queryplan.executable.impl.ExecPlanTaskBase

All Implemented Interfaces:

Runnable, StatsProvider, ExecPlanTask

Direct Known Subclasses:

PullBasedExecPlanTaskBase, PushBasedExecPlanTaskBase

public abstract class ExecPlanTaskBase
extends Object
implements ExecPlanTask

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	ExecPlanTaskBase.ExecPlanTaskStatsImpl
protected static enum	ExecPlanTaskBase.Status

Field Summary

Fields

Modifier and Type	Field	Description
protected final Queue<IntermediateResultBlock>	availableResultBlocks
protected final ExecutionContext	execCxt
protected final int	preferredMinimumBlockSize

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ExecPlanTaskBase(ExecutionContext execCxt, int preferredMinimumBlockSize)

Method Summary

Modifier and Type	Method	Description
Exception	getCauseOfFailure()	Returns the exception that caused the execution of this task to fail (in case ExecPlanTask.hasFailed() is true).
List<Exception>	getExceptionsCaughtDuringExecution()
protected abstract ExecutableOperator	getExecOp()
ExecPlanTaskStats	getStats()
protected ExecPlanTaskBase.Status	getStatus()
boolean	hasFailed()	Returns true if the execution of this task has failed with an exception.
boolean	hasNextIntermediateResultBlockAvailable()	Returns true if an intermediate result block is already be available to be requested via ExecPlanTask.getNextIntermediateResultBlock().
boolean	isCompleted()	Returns true if the execution of this task has completed successfully, and returns false if either the execution is still running (in which case ExecPlanTask.isRunning() is true) or the execution has been interrupted (in which case ExecPlanTask.isRunning() is false).
boolean	isRunning()	Returns true if the execution of this task is currently running; that is, the execution has started and has neither been interrupted nor completed.
void	resetStats()
protected void	setCauseOfFailure(Exception cause)
protected void	setStatus(ExecPlanTaskBase.Status newStatus)

Methods inherited from class java.lang.Object

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

Methods inherited from interface se.liu.ida.hefquin.engine.queryplan.executable.impl.ExecPlanTask

getNextIntermediateResultBlock

Methods inherited from interface java.lang.Runnable

run

Field Details

execCxt

protected final ExecutionContext execCxt

preferredMinimumBlockSize

protected final int preferredMinimumBlockSize

availableResultBlocks

protected final Queue<IntermediateResultBlock> availableResultBlocks

Constructor Details

ExecPlanTaskBase

protected ExecPlanTaskBase(ExecutionContext execCxt,
 int preferredMinimumBlockSize)

Method Details

getExecOp

protected abstract ExecutableOperator getExecOp()

getExceptionsCaughtDuringExecution

public List<Exception> getExceptionsCaughtDuringExecution()

isRunning

public boolean isRunning()

Description copied from interface: ExecPlanTask

Returns true if the execution of this task is currently running; that is, the execution has started and has neither been interrupted nor completed.

Specified by:

isRunning in interface ExecPlanTask

isCompleted

public boolean isCompleted()

Description copied from interface: ExecPlanTask

Returns true if the execution of this task has completed successfully, and returns false if either the execution is still running (in which case ExecPlanTask.isRunning() is true) or the execution has been interrupted (in which case ExecPlanTask.isRunning() is false).

Specified by:

isCompleted in interface ExecPlanTask

hasFailed

public boolean hasFailed()

Description copied from interface: ExecPlanTask

Returns true if the execution of this task has failed with an exception. The exception that caused the failed can be obtained by calling ExecPlanTask.getCauseOfFailure().

Specified by:

hasFailed in interface ExecPlanTask

getCauseOfFailure

public Exception getCauseOfFailure()

Description copied from interface: ExecPlanTask

Returns the exception that caused the execution of this task to fail (in case ExecPlanTask.hasFailed() is true).

Specified by:

getCauseOfFailure in interface ExecPlanTask

hasNextIntermediateResultBlockAvailable

public boolean hasNextIntermediateResultBlockAvailable()

Description copied from interface: ExecPlanTask

Returns true if an intermediate result block is already be available to be requested via ExecPlanTask.getNextIntermediateResultBlock(). Hence, in this case, calling ExecPlanTask.getNextIntermediateResultBlock() would not cause the calling thread to wait.

Specified by:

hasNextIntermediateResultBlockAvailable in interface ExecPlanTask

getStats

public ExecPlanTaskStats getStats()

Specified by:

getStats in interface ExecPlanTask

Specified by:

getStats in interface StatsProvider

resetStats

public void resetStats()

Specified by:

resetStats in interface StatsProvider

getStatus

protected ExecPlanTaskBase.Status getStatus()

setStatus

protected void setStatus(ExecPlanTaskBase.Status newStatus)

setCauseOfFailure

protected void setCauseOfFailure(Exception cause)