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

Class PushBasedExecPlanTaskBase

java.lang.Object

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

se.liu.ida.hefquin.engine.queryplan.executable.impl.pushbased.PushBasedExecPlanTaskBase

All Implemented Interfaces:

Runnable, StatsProvider, ExecPlanTask, PushBasedExecPlanTask, IntermediateResultElementSink

Direct Known Subclasses:

ConnectorForAdditionalConsumer, PushBasedExecPlanTaskForBinaryOperator, PushBasedExecPlanTaskForNaryOperator, PushBasedExecPlanTaskForNullaryOperator, PushBasedExecPlanTaskForUnaryOperator

public abstract class PushBasedExecPlanTaskBase
extends ExecPlanTaskBase
implements PushBasedExecPlanTask, IntermediateResultElementSink

Push-based implementation of ExecPlanTask. This implementation makes the following assumption: - There is only one thread that consumes the output of this task (by calling getNextIntermediateResultBlock()).

Nested Class Summary

Nested classes/interfaces inherited from class se.liu.ida.hefquin.engine.queryplan.executable.impl.ExecPlanTaskBase

ExecPlanTaskBase.ExecPlanTaskStatsImpl, ExecPlanTaskBase.Status

Field Summary

Fields

Modifier and Type	Field	Description
protected static final int	DEFAULT_OUTPUT_BLOCK_SIZE
protected List<ConnectorForAdditionalConsumer>	extraConnectors
protected final int	outputBlockSize

Fields inherited from class se.liu.ida.hefquin.engine.queryplan.executable.impl.ExecPlanTaskBase

availableResultBlocks, execCxt, preferredMinimumBlockSize

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
ExecPlanTask	addConnectorForAdditionalConsumer(int preferredMinimumBlockSize)
final IntermediateResultBlock	getNextIntermediateResultBlock()	Returns either the next intermediate result block produced by this task or null if all these blocks have been returned already to earlier calls of this function.
protected abstract void	produceOutput(IntermediateResultElementSink sink)
final void	run()
void	send(SolutionMapping element)
protected void	wrapUp(boolean failed, boolean interrupted)

Methods inherited from class se.liu.ida.hefquin.engine.queryplan.executable.impl.ExecPlanTaskBase

getCauseOfFailure, getExceptionsCaughtDuringExecution, getExecOp, getStats, getStatus, hasFailed, hasNextIntermediateResultBlockAvailable, isCompleted, isRunning, resetStats, setCauseOfFailure, setStatus

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

getCauseOfFailure, getStats, hasFailed, hasNextIntermediateResultBlockAvailable, isCompleted, isRunning

Methods inherited from interface se.liu.ida.hefquin.base.utils.StatsProvider

resetStats

Field Details

DEFAULT_OUTPUT_BLOCK_SIZE

protected static final int DEFAULT_OUTPUT_BLOCK_SIZE

See Also:

• Constant Field Values

outputBlockSize

protected final int outputBlockSize

extraConnectors

protected List<ConnectorForAdditionalConsumer> extraConnectors

Constructor Details

PushBasedExecPlanTaskBase

protected PushBasedExecPlanTaskBase(ExecutionContext execCxt,
 int preferredMinimumBlockSize)

Method Details

addConnectorForAdditionalConsumer

public ExecPlanTask addConnectorForAdditionalConsumer(int preferredMinimumBlockSize)

Specified by:

addConnectorForAdditionalConsumer in interface PushBasedExecPlanTask

run

public final void run()

Specified by:

run in interface Runnable

produceOutput

protected abstract void produceOutput(IntermediateResultElementSink sink)
                               throws ExecOpExecutionException,
ExecPlanTaskInputException,
ExecPlanTaskInterruptionException

Throws:

ExecOpExecutionException

ExecPlanTaskInputException

ExecPlanTaskInterruptionException

send

public void send(SolutionMapping element)

Specified by:

send in interface IntermediateResultElementSink

wrapUp

protected void wrapUp(boolean failed,
 boolean interrupted)

getNextIntermediateResultBlock

public final IntermediateResultBlock getNextIntermediateResultBlock()
                                                             throws ExecPlanTaskInterruptionException,
ExecPlanTaskInputException

Description copied from interface: ExecPlanTask

Returns either the next intermediate result block produced by this task or null if all these blocks have been returned already to earlier calls of this function. If no next block is currently available at the time when this function is called, then the call of this function causes the calling thread to wait until the next block has been produced (or it has become clear that no more blocks can be produced anymore).

Specified by:

getNextIntermediateResultBlock in interface ExecPlanTask

Throws:

ExecPlanTaskInterruptionException

ExecPlanTaskInputException