Class BaseForExecOpSequentialBindJoinSPARQL

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

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

All Implemented Interfaces:

StatsProvider, ExecutableOperator, UnaryExecutableOp

Direct Known Subclasses:

ExecOpSequentialBindJoinSPARQLwithFILTER, ExecOpSequentialBindJoinSPARQLwithUNION, ExecOpSequentialBindJoinSPARQLwithVALUES, ExecOpSequentialBindJoinSPARQLwithVALUESorFILTER, ExecOpSequentialBindJoinSPARQLwithVarRenaming

public abstract class BaseForExecOpSequentialBindJoinSPARQL
extends BaseForExecOpSequentialBindJoin<SPARQLGraphPattern,SPARQLEndpoint>

A base class for all variations of our sequential, batch-based 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.BaseForExecOpSequentialBindJoin

BaseForExecOpSequentialBindJoin.MyIntermediateResultElementSink, BaseForExecOpSequentialBindJoin.MyIntermediateResultElementSinkOuterJoin

Field Summary

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

allJoinVarsAreCertain, currentBatch, currentSolMapsForRequest, DEFAULT_BATCH_SIZE, fm, fullResult, minimumRequestBlockSize, numberOfRequestOpsUsed, numOfSolMapsRetrievedPerReqOp, query, requestBlockSize, requestBlockSizeWasReduced, statsOfFirstReqOp, statsOfLastReqOp, useOuterJoinSemantics, varsInQuery

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

collectExceptions, qpInfo

Constructor Summary

Constructors

Constructor	Description
BaseForExecOpSequentialBindJoinSPARQL(SPARQLGraphPattern p, SPARQLEndpoint fm, ExpectedVariables inputVars, boolean useOuterJoinSemantics, int batchSize, boolean collectExceptions, QueryPlanningInfo qpInfo)

Method Summary

Modifier and Type	Method	Description
protected NullaryExecutableOp	createExecutableReqOpForAll()	Implementations of this function should create an executable operator that can perform a request to retrieve all solution mappings for the query of this operator (i.e., not a bind-join request).

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

_concludeExecution, _process, _processJoinableInput, alreadyCovered, areAllJoinVarsAreCertain, consumeMySink, createExecutableReqOp, createMySink, createStats, joinInFullRetrievalMode, joinInFullRetrievalMode, performRequestAndHandleResponse, reduceRequestBlockSize, resetStats, switchToFullRetrievalMode

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, getQueryPlanningInfo, 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, getQueryPlanningInfo

Constructor Details

BaseForExecOpSequentialBindJoinSPARQL

public BaseForExecOpSequentialBindJoinSPARQL(SPARQLGraphPattern p,
 SPARQLEndpoint fm,
 ExpectedVariables inputVars,
 boolean useOuterJoinSemantics,
 int batchSize,
 boolean collectExceptions,
 QueryPlanningInfo qpInfo)

Method Details

createExecutableReqOpForAll

protected NullaryExecutableOp createExecutableReqOpForAll()

Description copied from class: BaseForExecOpSequentialBindJoin

Implementations of this function should create an executable operator that can perform a request to retrieve all solution mappings for the query of this operator (i.e., not a bind-join request). The operator created by this function should throws exceptions instead of collecting them.

Specified by:

createExecutableReqOpForAll in class BaseForExecOpSequentialBindJoin<SPARQLGraphPattern,SPARQLEndpoint>