Class BaseForExecOpIndexNestedLoopsJoinWithRequestOps<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.UnaryExecutableOpBaseWithBatching

se.liu.ida.hefquin.engine.queryplan.executable.impl.ops.BaseForExecOpIndexNestedLoopsJoinWithRequestOps<QueryType,MemberType>

All Implemented Interfaces:

StatsProvider, ExecutableOperator, UnaryExecutableOp

Direct Known Subclasses:

BaseForExecOpIndexNestedLoopsJoinWithTPFRequests

public abstract class BaseForExecOpIndexNestedLoopsJoinWithRequestOps<QueryType extends Query,MemberType extends FederationMember>
extends UnaryExecutableOpBaseWithBatching

Abstract base class to implement index nested loops joins by using request operators. The possibility to rely on a request operator is particularly useful in cases in which this operator implements paging, because the alternative would be the need to re-implement paging again in the nested loops join algorithm of potential subclasses of this base class. For an abstract base class that issues requests directly (instead of using request operators), use BaseForExecOpIndexNestedLoopsJoinWithRequests.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	BaseForExecOpIndexNestedLoopsJoinWithRequestOps.MyIntermediateResultElementSink
protected class	BaseForExecOpIndexNestedLoopsJoinWithRequestOps.MyIntermediateResultElementSinkOuterJoin

Field Summary

Fields

Modifier and Type	Field	Description
static final int	DEFAULT_BATCH_SIZE
protected final MemberType	fm
protected long	numberOfOutputMappingsProduced
protected int	numberOfRequestOpsUsed
protected final QueryType	query
protected ExecutableOperatorStats	statsOfLastReqOp
protected final boolean	useOuterJoinSemantics

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

batchSize, collectedInputSolMaps

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

collectExceptions

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	BaseForExecOpIndexNestedLoopsJoinWithRequestOps(QueryType query, MemberType fm, boolean useOuterJoinSemantics, boolean collectExceptions)
protected	BaseForExecOpIndexNestedLoopsJoinWithRequestOps(QueryType query, MemberType fm, boolean useOuterJoinSemantics, int batchSize, boolean collectExceptions)

Method Summary

Modifier and Type	Method	Description
protected void	_concludeExecution(List<SolutionMapping> input, IntermediateResultElementSink sink, ExecutionContext execCxt)	Implementations of this function need to process the given batch of solution mappings as last input, conclude the execution of this operator, and send the remaining result elements (if any) to the given sink.
protected void	_processBatch(List<SolutionMapping> input, IntermediateResultElementSink sink, ExecutionContext execCxt)	Implementations of this function need to process the given batch of solution mappings as input and send the produced result elements (if any) to the given sink.
protected abstract NullaryExecutableOp	createExecutableRequestOperator(SolutionMapping sm)
protected Runnable	createProcessor(NullaryExecutableOp reqOp, SolutionMapping smFromInput, IntermediateResultElementSink outputSink, ExecutionContext execCxt)
protected ExecutableOperatorStatsImpl	createStats()
protected CompletableFuture<?>[]	initiateProcessing(List<SolutionMapping> input, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected CompletableFuture<?>	initiateProcessing(SolutionMapping sm, IntermediateResultElementSink sink, ExecutionContext execCxt)
void	resetStats()

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

_concludeExecution, _process

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

_process, concludeExecution, getStats, process, 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

Field Details

DEFAULT_BATCH_SIZE

public static final int DEFAULT_BATCH_SIZE

See Also:

• Constant Field Values

query

protected final QueryType extends Query query

fm

protected final MemberType extends FederationMember fm

useOuterJoinSemantics

protected final boolean useOuterJoinSemantics

numberOfOutputMappingsProduced

protected long numberOfOutputMappingsProduced

numberOfRequestOpsUsed

protected int numberOfRequestOpsUsed

statsOfLastReqOp

protected ExecutableOperatorStats statsOfLastReqOp

Constructor Details

BaseForExecOpIndexNestedLoopsJoinWithRequestOps

protected BaseForExecOpIndexNestedLoopsJoinWithRequestOps(QueryType query,
 MemberType fm,
 boolean useOuterJoinSemantics,
 int batchSize,
 boolean collectExceptions)

BaseForExecOpIndexNestedLoopsJoinWithRequestOps

protected BaseForExecOpIndexNestedLoopsJoinWithRequestOps(QueryType query,
 MemberType fm,
 boolean useOuterJoinSemantics,
 boolean collectExceptions)

Method Details

_processBatch

protected void _processBatch(List<SolutionMapping> input,
 IntermediateResultElementSink sink,
 ExecutionContext execCxt)
                      throws ExecOpExecutionException

Description copied from class: UnaryExecutableOpBaseWithBatching

Implementations of this function need to process the given batch of solution mappings as input and send the produced result elements (if any) to the given sink. If an exception occurs while processing the batch, then this exception needs to be thrown.

Specified by:

_processBatch in class UnaryExecutableOpBaseWithBatching

Throws:

ExecOpExecutionException

initiateProcessing

protected CompletableFuture<?>[] initiateProcessing(List<SolutionMapping> input,
 IntermediateResultElementSink sink,
 ExecutionContext execCxt)

initiateProcessing

protected CompletableFuture<?> initiateProcessing(SolutionMapping sm,
 IntermediateResultElementSink sink,
 ExecutionContext execCxt)
                                           throws VariableByBlankNodeSubstitutionException

Throws:

VariableByBlankNodeSubstitutionException

createExecutableRequestOperator

protected abstract NullaryExecutableOp createExecutableRequestOperator(SolutionMapping sm)
                                                                throws VariableByBlankNodeSubstitutionException

Throws:

VariableByBlankNodeSubstitutionException

createProcessor

protected Runnable createProcessor(NullaryExecutableOp reqOp,
 SolutionMapping smFromInput,
 IntermediateResultElementSink outputSink,
 ExecutionContext execCxt)

_concludeExecution

protected void _concludeExecution(List<SolutionMapping> input,
 IntermediateResultElementSink sink,
 ExecutionContext execCxt)
                           throws ExecOpExecutionException

Description copied from class: UnaryExecutableOpBaseWithBatching

Implementations of this function need to process the given batch of solution mappings as last input, conclude the execution of this operator, and send the remaining result elements (if any) to the given sink. Notice that the given batch of solution mappings may be empty! If an exception occurs during this process, then this exception needs to be thrown.

Specified by:

_concludeExecution in class UnaryExecutableOpBaseWithBatching

Throws:

ExecOpExecutionException

resetStats

public void resetStats()

Specified by:

resetStats in interface StatsProvider

Overrides:

resetStats in class UnaryExecutableOpBaseWithBatching

createStats

protected ExecutableOperatorStatsImpl createStats()

Overrides:

createStats in class UnaryExecutableOpBaseWithBatching