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

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 inherited from class se.liu.ida.hefquin.engine.queryplan.executable.impl.ops.BaseForExecOpIndexNestedLoopsJoinWithRequests

DEFAULT_BATCH_SIZE, fm, query

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

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, _processBatch, createStats

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

_concludeExecution, _process, resetStats

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

Constructor Details

ExecOpIndexNestedLoopsJoinSPARQL

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

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