Class ExecOpIndexNestedLoopsJoinSPARQL

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

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

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

All Implemented Interfaces:

StatsProvider, ExecutableOperator, UnaryExecutableOp

public class ExecOpIndexNestedLoopsJoinSPARQL
extends BaseForExecOpIndexNestedLoopsJoinWithSolMapsRequests<SPARQLGraphPattern,SPARQLEndpoint,SPARQLRequest>

Nested Class Summary

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

BaseForExecOpIndexNestedLoopsJoinWithRequests.MyResponseProcessor

Field Summary

Fields

Modifier and Type	Field	Description
static final int	DEFAULT_INPUT_BLOCK_SIZE

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

fm, query

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
ExecOpIndexNestedLoopsJoinSPARQL(SPARQLGraphPattern query, SPARQLEndpoint fm, boolean useOuterJoinSemantics, boolean collectExceptions, QueryPlanningInfo qpInfo)
ExecOpIndexNestedLoopsJoinSPARQL(SPARQLGraphPattern query, SPARQLEndpoint fm, boolean useOuterJoinSemantics, int minimumInputBlockSize, boolean collectExceptions, QueryPlanningInfo qpInfo)

Method Summary

Modifier and Type	Method	Description
protected SPARQLRequest	createRequest(SolutionMapping sm)
protected CompletableFuture<SolMapsResponse>	issueRequest(SPARQLRequest req, FederationAccessManager fedAccessMgr)

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

createResponseProcessor

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

_concludeExecution, _processCollectedInput, createStats, resetStats

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

Field Details

DEFAULT_INPUT_BLOCK_SIZE

public static final int DEFAULT_INPUT_BLOCK_SIZE

See Also:

• Constant Field Values

Constructor Details

ExecOpIndexNestedLoopsJoinSPARQL

public ExecOpIndexNestedLoopsJoinSPARQL(SPARQLGraphPattern query,
 SPARQLEndpoint fm,
 boolean useOuterJoinSemantics,
 int minimumInputBlockSize,
 boolean collectExceptions,
 QueryPlanningInfo qpInfo)

ExecOpIndexNestedLoopsJoinSPARQL

public ExecOpIndexNestedLoopsJoinSPARQL(SPARQLGraphPattern query,
 SPARQLEndpoint fm,
 boolean useOuterJoinSemantics,
 boolean collectExceptions,
 QueryPlanningInfo qpInfo)

Method Details

createRequest

protected SPARQLRequest createRequest(SolutionMapping sm)
                               throws VariableByBlankNodeSubstitutionException

Specified by:

createRequest in class BaseForExecOpIndexNestedLoopsJoinWithRequests<SPARQLGraphPattern,SPARQLEndpoint,SPARQLRequest,SolMapsResponse>

Throws:

VariableByBlankNodeSubstitutionException

issueRequest

protected CompletableFuture<SolMapsResponse> issueRequest(SPARQLRequest req,
 FederationAccessManager fedAccessMgr)
                                                   throws FederationAccessException

Specified by:

issueRequest in class BaseForExecOpIndexNestedLoopsJoinWithRequests<SPARQLGraphPattern,SPARQLEndpoint,SPARQLRequest,SolMapsResponse>

Throws:

FederationAccessException