Class BaseForExecOpParallelBindJoinSPARQL

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.BaseForUnaryExecOpWithCollectedInput

se.liu.ida.hefquin.engine.queryplan.executable.impl.ops.BaseForExecOpParallelBindJoin<SPARQLGraphPattern,SPARQLEndpoint,SPARQLRequest,SolMapsResponse>

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

All Implemented Interfaces:

StatsProvider, ExecutableOperator, UnaryExecutableOp

Direct Known Subclasses:

ExecOpParallelBindJoinSPARQLwithFILTER, ExecOpParallelBindJoinSPARQLwithUNION, ExecOpParallelBindJoinSPARQLwithVALUES

public abstract class BaseForExecOpParallelBindJoinSPARQL
extends BaseForExecOpParallelBindJoin<SPARQLGraphPattern,SPARQLEndpoint,SPARQLRequest,SolMapsResponse>

A base class for all variations of our parallelized, 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.BaseForExecOpParallelBindJoin

BaseForExecOpParallelBindJoin.MyResponseProcessor

Field Summary

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

allJoinVarsAreCertain, batches, batchSize, currentBatch, DEFAULT_BATCH_SIZE, fm, fullResult, futures, numberOfRequestsUsed, numOfSolMapsRetrievedPerReq, query, requestDurationsInMS, solMapsCoveredByCurrentBatch, solMapsCoveredPerBatch, statsOfFullRetrievalReqOp, useOuterJoinSemantics, varsInQuery

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

collectedInputSolMaps, minimumCollectionSize

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

collectExceptions, qpInfo

Constructor Summary

Constructors

Constructor	Description
BaseForExecOpParallelBindJoinSPARQL(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).
protected Iterable<SolutionMapping>	extractSolMaps(SolMapsResponse response)	Implementations of this function should extract solution mappings from the given response (obtained via a bind-join request).

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

_concludeExecution, _processCollectedInput, alreadyCovered, batchUp, createRequest, createStats, handleCollectedSolMaps, initiateProcessingOfBatches, innerJoin, joinInFullRetrievalMode, joinInFullRetrievalMode, leftOuterJoin, obtainFullResult, recordException, resetStats, switchToFullRetrievalMode

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

_concludeExecution, _process, _process

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

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

BaseForExecOpParallelBindJoinSPARQL

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

Method Details

extractSolMaps

protected Iterable<SolutionMapping> extractSolMaps(SolMapsResponse response)
                                            throws UnsupportedOperationDueToRetrievalError

Description copied from class: BaseForExecOpParallelBindJoin

Implementations of this function should extract solution mappings from the given response (obtained via a bind-join request).

Specified by:

extractSolMaps in class BaseForExecOpParallelBindJoin<SPARQLGraphPattern,SPARQLEndpoint,SPARQLRequest,SolMapsResponse>

Throws:

UnsupportedOperationDueToRetrievalError - if the given response does not contain retrieved data but an indication of a data retrieval error

createExecutableReqOpForAll

protected NullaryExecutableOp createExecutableReqOpForAll()

Description copied from class: BaseForExecOpParallelBindJoin

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 BaseForExecOpParallelBindJoin<SPARQLGraphPattern,SPARQLEndpoint,SPARQLRequest,SolMapsResponse>