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

Class UnaryExecutableOpBaseWithIterator

java.lang.Object

se.liu.ida.hefquin.engine.queryplan.executable.impl.ops.BaseForExecOps

se.liu.ida.hefquin.engine.queryplan.executable.impl.ops.UnaryExecutableOpBase

se.liu.ida.hefquin.engine.queryplan.executable.impl.ops.UnaryExecutableOpBaseWithIterator

All Implemented Interfaces:

StatsProvider, ExecutableOperator, UnaryExecutableOp

Direct Known Subclasses:

ExecOpFilter, ExecOpGlobalToLocal, ExecOpLocalToGlobal

public abstract class UnaryExecutableOpBaseWithIterator
extends UnaryExecutableOpBase

Field Summary

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

timeAtCurrentProcStart

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

collectExceptions

Constructor Summary

Constructors

Constructor	Description
UnaryExecutableOpBaseWithIterator(boolean collectExceptions)

Method Summary

Modifier and Type	Method	Description
protected void	_concludeExecution(IntermediateResultElementSink sink, ExecutionContext execCxt)	Implementations of this function need to conclude the execution of this operator and send the remaining result elements (if any) to the given sink.
protected void	_process(Iterator<SolutionMapping> output, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	_process(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)	Implementations of this function need to process the given input block and send the produced result elements (if any) to the given sink.
protected abstract Iterator<SolutionMapping>	createInputToOutputIterator(Iterable<SolutionMapping> input)
protected ExecutableOperatorStatsImpl	createStats()
int	preferredInputBlockSize()	Returns the preferred block size of input blocks that are passed to this executable operator.
void	resetStats()

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

concludeExecution, getStats, process

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

getExceptionsCaughtDuringExecution, recordExceptionCaughtDuringExecution

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.ExecutableOperator

getExceptionsCaughtDuringExecution

Constructor Details

UnaryExecutableOpBaseWithIterator

public UnaryExecutableOpBaseWithIterator(boolean collectExceptions)

Method Details

preferredInputBlockSize

public int preferredInputBlockSize()

Description copied from interface: UnaryExecutableOp

Returns the preferred block size of input blocks that are passed to this executable operator. A query planner may use this number as an optimization hint but it does not have to use it.

_process

protected void _process(IntermediateResultBlock input,
 IntermediateResultElementSink sink,
 ExecutionContext execCxt)
                 throws ExecOpExecutionException

Description copied from class: UnaryExecutableOpBase

Implementations of this function need to process the given input block and send the produced result elements (if any) to the given sink. If an exception occurs while processing the input block, this exception needs to either be collected or be thrown, depending on whether BaseForExecOps.collectExceptions is set to true.

Specified by:

_process in class UnaryExecutableOpBase

Throws:

ExecOpExecutionException

_concludeExecution

protected void _concludeExecution(IntermediateResultElementSink sink,
 ExecutionContext execCxt)

Description copied from class: UnaryExecutableOpBase

Implementations of this function need to conclude the execution of this operator and send the remaining result elements (if any) to the given sink. If an exception occurs during this process, then this exception needs to either be collected or be thrown, depending on whether BaseForExecOps.collectExceptions is set to true.

Specified by:

_concludeExecution in class UnaryExecutableOpBase

createInputToOutputIterator

protected abstract Iterator<SolutionMapping> createInputToOutputIterator(Iterable<SolutionMapping> input)
                                                                  throws ExecOpExecutionException

Throws:

ExecOpExecutionException

_process

protected void _process(Iterator<SolutionMapping> output,
 IntermediateResultElementSink sink,
 ExecutionContext execCxt)

resetStats

public void resetStats()

Specified by:

resetStats in interface StatsProvider

Overrides:

resetStats in class UnaryExecutableOpBase

createStats

protected ExecutableOperatorStatsImpl createStats()

Overrides:

createStats in class UnaryExecutableOpBase