Class BaseForExecOpBindJoinSPARQL

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.BaseForExecOpBindJoinWithRequestOps<SPARQLGraphPattern,SPARQLEndpoint>

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

All Implemented Interfaces:

StatsProvider, ExecutableOperator, UnaryExecutableOp

Direct Known Subclasses:

ExecOpBindJoinSPARQLwithFILTER, ExecOpBindJoinSPARQLwithUNION, ExecOpBindJoinSPARQLwithVALUES

public abstract class BaseForExecOpBindJoinSPARQL
extends BaseForExecOpBindJoinWithRequestOps<SPARQLGraphPattern,SPARQLEndpoint>

A base class for all variations of the bind join algorithm that use some form of SPARQL requests.

Nested Class Summary

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

BaseForExecOpBindJoinWithRequestOps.MyIntermediateResultElementSink, BaseForExecOpBindJoinWithRequestOps.MyIntermediateResultElementSinkOuterJoin

Field Summary

Fields

Modifier and Type	Field	Description
protected final List<org.apache.jena.sparql.core.Var>	varsInSubQuery

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

DEFAULT_BATCH_SIZE, fm, minimumRequestBlockSize, numberOfRequestOpsUsed, query, requestBlockSize, requestBlockSizeWasReduced, statsOfFirstReqOp, statsOfLastReqOp, useOuterJoinSemantics, varsInPatternForFM

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

Constructor	Description
BaseForExecOpBindJoinSPARQL(SPARQLGraphPattern p, SPARQLEndpoint fm, boolean useOuterJoinSemantics, int batchSize, boolean collectExceptions)

Method Summary

Modifier and Type	Method	Description
void	_processBatch(List<SolutionMapping> batchOfSolMaps, 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.

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

_concludeExecution, _processJoinableInput, _processWithoutSplittingInputFirst, createExecutableReqOp, createStats, extractUnjoinableInputSMs, reduceRequestBlockSize, 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

varsInSubQuery

protected final List<org.apache.jena.sparql.core.Var> varsInSubQuery

Constructor Details

BaseForExecOpBindJoinSPARQL

public BaseForExecOpBindJoinSPARQL(SPARQLGraphPattern p,
 SPARQLEndpoint fm,
 boolean useOuterJoinSemantics,
 int batchSize,
 boolean collectExceptions)

Method Details

_processBatch

public void _processBatch(List<SolutionMapping> batchOfSolMaps,
 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.

Overrides:

_processBatch in class BaseForExecOpBindJoinWithRequestOps<SPARQLGraphPattern,SPARQLEndpoint>

Throws:

ExecOpExecutionException