Class ExecOpBindJoinSPARQLwithUNION

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

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

All Implemented Interfaces:

StatsProvider, ExecutableOperator, UnaryExecutableOp

public class ExecOpBindJoinSPARQLwithUNION
extends BaseForExecOpBindJoinSPARQL

Implementation of (a batching version of) the bind join algorithm that uses UNION clauses with FILTERs inside. The current algorithm should to be changed. See: https://github.com/LiUSemWeb/HeFQUIN/issues/344

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
static final int	DEFAULT_BATCH_SIZE

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

varsInSubQuery

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

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
ExecOpBindJoinSPARQLwithUNION(SPARQLGraphPattern query, SPARQLEndpoint fm, boolean collectExceptions)
ExecOpBindJoinSPARQLwithUNION(SPARQLGraphPattern query, SPARQLEndpoint fm, int batchSize, boolean collectExceptions)

Method Summary

Modifier and Type	Method	Description
protected NullaryExecutableOp	createExecutableReqOp(Iterable<SolutionMapping> solMaps)	Implementations of this function should create an executable operator that can perform a bind join request in which the query of this bind join operator is combined with the given solution mappings.
protected org.apache.jena.sparql.algebra.Op	createUnion(Iterable<SolutionMapping> solMaps)

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

_processBatch

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

_concludeExecution, _processJoinableInput, _processWithoutSplittingInputFirst, 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

DEFAULT_BATCH_SIZE

public static final int DEFAULT_BATCH_SIZE

See Also:

• Constant Field Values

Constructor Details

ExecOpBindJoinSPARQLwithUNION

public ExecOpBindJoinSPARQLwithUNION(SPARQLGraphPattern query,
 SPARQLEndpoint fm,
 int batchSize,
 boolean collectExceptions)

ExecOpBindJoinSPARQLwithUNION

public ExecOpBindJoinSPARQLwithUNION(SPARQLGraphPattern query,
 SPARQLEndpoint fm,
 boolean collectExceptions)

Method Details

createExecutableReqOp

protected NullaryExecutableOp createExecutableReqOp(Iterable<SolutionMapping> solMaps)

Description copied from class: BaseForExecOpBindJoinWithRequestOps

Implementations of this function should create an executable operator that can perform a bind join request in which the query of this bind join operator is combined with the given solution mappings. The operator created by this function should throws exceptions instead of collecting them.

Specified by:

createExecutableReqOp in class BaseForExecOpBindJoinWithRequestOps<SPARQLGraphPattern,SPARQLEndpoint>

createUnion

protected org.apache.jena.sparql.algebra.Op createUnion(Iterable<SolutionMapping> solMaps)