Class ExecOpMultiwayUnion

java.lang.Object

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

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

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

All Implemented Interfaces:

StatsProvider, ExecutableOperator, NaryExecutableOp

public class ExecOpMultiwayUnion
extends NaryExecutableOpBase

Field Summary

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

numberOfChildren, timeAtCurrentProcStartXthInput

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

collectExceptions

Constructor Summary

Constructors

Constructor	Description
ExecOpMultiwayUnion(int numberOfChildren, boolean collectExceptions)

Method Summary

Modifier and Type	Method	Description
protected void	_processInputFromXthChild(int x, List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, ExecutionContext execCxt)	Processes the input solution mappings of the given list by calling NaryExecutableOpBase._processInputFromXthChild(int, SolutionMapping, IntermediateResultElementSink, ExecutionContext) for each of them.
protected void	_processInputFromXthChild(int x, SolutionMapping inputSolMap, IntermediateResultElementSink sink, ExecutionContext execCxt)	Implementations of this function need to process the given solution mapping as input coming from the x-th operand and send the produced result elements (if any) to the given sink.
protected void	_wrapUpForXthChild(int x, IntermediateResultElementSink sink, ExecutionContext execCxt)	Implementations of this function need to finish up any processing related to the input coming from the x-th operand and send the remaining result elements (if any) to the given sink.
protected ExecutableOperatorStatsImpl	createStats()
void	resetStats()

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

getStats, processInputFromXthChild, processInputFromXthChild, wrapUpForXthChild

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

ExecOpMultiwayUnion

public ExecOpMultiwayUnion(int numberOfChildren,
 boolean collectExceptions)

Method Details

_processInputFromXthChild

protected void _processInputFromXthChild(int x,
 SolutionMapping inputSolMap,
 IntermediateResultElementSink sink,
 ExecutionContext execCxt)

Description copied from class: NaryExecutableOpBase

Implementations of this function need to process the given solution mapping as input coming from the x-th operand and send the produced result elements (if any) to the given sink. If an exception occurs while processing the solution mapping, then this exception needs to be thrown.

Specified by:

_processInputFromXthChild in class NaryExecutableOpBase

_processInputFromXthChild

protected void _processInputFromXthChild(int x,
 List<SolutionMapping> inputSolMaps,
 IntermediateResultElementSink sink,
 ExecutionContext execCxt)

Description copied from class: NaryExecutableOpBase

Processes the input solution mappings of the given list by calling NaryExecutableOpBase._processInputFromXthChild(int, SolutionMapping, IntermediateResultElementSink, ExecutionContext) for each of them. Subclasses may override this behavior to send a greater number of output solution mappings to the given sink at a time (which is useful to reduce the communication between threads in the push-based execution model). If an exception occurs within the overriding implementation, then this exception needs to be thrown.

Overrides:

_processInputFromXthChild in class NaryExecutableOpBase

_wrapUpForXthChild

protected void _wrapUpForXthChild(int x,
 IntermediateResultElementSink sink,
 ExecutionContext execCxt)

Description copied from class: NaryExecutableOpBase

Implementations of this function need to finish up any processing related to the input coming from the x-th operand and send the remaining result elements (if any) to the given sink. If an exception occurs while processing the solution mapping, then this exception needs to be thrown.

Specified by:

_wrapUpForXthChild in class NaryExecutableOpBase

resetStats

public void resetStats()

Specified by:

resetStats in interface StatsProvider

Overrides:

resetStats in class NaryExecutableOpBase

createStats

protected ExecutableOperatorStatsImpl createStats()

Overrides:

createStats in class NaryExecutableOpBase