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

Class BaseForExecOpBindJoin<QueryType extends Query,MemberType extends FederationMember>

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.BaseForExecOpBindJoin<QueryType,MemberType>

All Implemented Interfaces:

StatsProvider, ExecutableOperator, UnaryExecutableOp

Direct Known Subclasses:

BaseForExecOpBindJoinWithRequestOps

public abstract class BaseForExecOpBindJoin<QueryType extends Query,MemberType extends FederationMember>
extends UnaryExecutableOpBase

An abstract base class for the different variants to implement the bind join algorithm. All that is needed for concrete classes that extend this base class is to implement the UnaryExecutableOpBase._process(se.liu.ida.hefquin.engine.queryplan.executable.IntermediateResultBlock, IntermediateResultElementSink, ExecutionContext) function.

Field Summary

Fields

Modifier and Type	Field	Description
static final int	defaultPreferredInputBlockSize
protected final MemberType	fm
protected final QueryType	query

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
BaseForExecOpBindJoin(QueryType query, MemberType fm, 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 ExecutableOperatorStatsImpl	createStats()
int	preferredInputBlockSize()	Returns the preferred block size of input blocks that are passed to this executable operator.

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

_process, concludeExecution, getStats, process, resetStats

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

Field Details

defaultPreferredInputBlockSize

public static final int defaultPreferredInputBlockSize

See Also:

• Constant Field Values

query

protected final QueryType extends Query query

fm

protected final MemberType extends FederationMember fm

Constructor Details

BaseForExecOpBindJoin

public BaseForExecOpBindJoin(QueryType query,
 MemberType fm,
 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.

_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

createStats

protected ExecutableOperatorStatsImpl createStats()

Overrides:

createStats in class UnaryExecutableOpBase