Class ExecOpLookupJoinViaWrapperWithParamVars

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

All Implemented Interfaces:

StatsProvider, ExecutableOperator, UnaryExecutableOp

public class ExecOpLookupJoinViaWrapperWithParamVars
extends BaseForUnaryExecOpWithCollectedInput

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	ExecOpLookupJoinViaWrapperWithParamVars.MyResponseProcessor

Field Summary

Fields

Modifier and Type	Field	Description
protected final ConcurrentMap<Map<String,org.apache.jena.graph.Node>,List<SolutionMapping>>	cache
static final int	DEFAULT_INPUT_BLOCK_SIZE
protected final WrappedRESTEndpoint	fm
protected final Map<RESTEndpoint.Parameter,org.apache.jena.sparql.core.Var>	paramVars
protected final SPARQLGraphPattern	pattern

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
ExecOpLookupJoinViaWrapperWithParamVars(SPARQLGraphPattern pattern, Map<String,org.apache.jena.sparql.core.Var> paramVars, WrappedRESTEndpoint fm, boolean collectExceptions, QueryPlanningInfo qpInfo)
ExecOpLookupJoinViaWrapperWithParamVars(SPARQLGraphPattern pattern, Map<String,org.apache.jena.sparql.core.Var> paramVars, WrappedRESTEndpoint fm, int minimumInputBlockSize, boolean collectExceptions, QueryPlanningInfo qpInfo)

Method Summary

Modifier and Type	Method	Description
protected void	_concludeExecution(List<SolutionMapping> input, IntermediateResultElementSink sink, ExecutionContext execCxt)	Implementations of this function need to process the given solution mappings as last input, conclude the execution of this operator, and send the remaining result elements (if any) to the given sink.
protected void	_processCollectedInput(List<SolutionMapping> input, IntermediateResultElementSink sink, ExecutionContext execCxt)	Implementations of this function need to process the given solution mappings as input and send the produced result elements (if any) to the given sink.
protected RESTRequest	createRequest(Map<String,org.apache.jena.graph.Node> paramValues)	Assumes that the number of parameter values in the given array is the same as the number of parameter declarations of the REST endpoint and that the datatypes of the values match the ones of the parameter declarations.
protected ExecutableOperatorStatsImpl	createStats()
protected Map<String,org.apache.jena.graph.Node>	extractParamValues(SolutionMapping sm)	Returns the values that the given solution mapping has for the parameter variables, but only if the solution mapping does indeed have bindings for all parameter variables and the values bound to these variables are literals of the correct datatypes (as specified in the parameter declaration of the REST endpoint).
protected void	join(Iterable<SolutionMapping> solmaps1, Iterable<SolutionMapping> solmaps2, IntermediateResultElementSink sink)	Joins the given sets of solution mappings and sends the result to the given sink.
protected void	join(Iterable<SolutionMapping> solmaps, SolutionMapping sm, IntermediateResultElementSink sink)	Joins the given set of solution mappings with a singleton set that contains the single given solution mapping, and sends the result to the given sink.
void	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

pattern

protected final SPARQLGraphPattern pattern

paramVars

protected final Map<RESTEndpoint.Parameter,org.apache.jena.sparql.core.Var> paramVars

fm

protected final WrappedRESTEndpoint fm

cache

protected final ConcurrentMap<Map<String,org.apache.jena.graph.Node>,List<SolutionMapping>> cache

Constructor Details

ExecOpLookupJoinViaWrapperWithParamVars

public ExecOpLookupJoinViaWrapperWithParamVars(SPARQLGraphPattern pattern,
 Map<String,org.apache.jena.sparql.core.Var> paramVars,
 WrappedRESTEndpoint fm,
 boolean collectExceptions,
 QueryPlanningInfo qpInfo)

ExecOpLookupJoinViaWrapperWithParamVars

public ExecOpLookupJoinViaWrapperWithParamVars(SPARQLGraphPattern pattern,
 Map<String,org.apache.jena.sparql.core.Var> paramVars,
 WrappedRESTEndpoint fm,
 int minimumInputBlockSize,
 boolean collectExceptions,
 QueryPlanningInfo qpInfo)

Method Details

_processCollectedInput

protected void _processCollectedInput(List<SolutionMapping> input,
 IntermediateResultElementSink sink,
 ExecutionContext execCxt)
                               throws ExecOpExecutionException

Description copied from class: BaseForUnaryExecOpWithCollectedInput

Implementations of this function need to process the given solution mappings as input and send the produced result elements (if any) to the given sink. If an exception occurs while processing the solution mappings, then this exception needs to be thrown.

Specified by:

_processCollectedInput in class BaseForUnaryExecOpWithCollectedInput

Throws:

ExecOpExecutionException

_concludeExecution

protected void _concludeExecution(List<SolutionMapping> input,
 IntermediateResultElementSink sink,
 ExecutionContext execCxt)
                           throws ExecOpExecutionException

Description copied from class: BaseForUnaryExecOpWithCollectedInput

Implementations of this function need to process the given solution mappings as last input, conclude the execution of this operator, and send the remaining result elements (if any) to the given sink. Notice that the list of solution mappings given here may contain fewer solution mappings than the minimum collection size, and it may even be empty! If an exception occurs during this process, then this exception needs to be thrown.

Specified by:

_concludeExecution in class BaseForUnaryExecOpWithCollectedInput

Throws:

ExecOpExecutionException

extractParamValues

protected Map<String,org.apache.jena.graph.Node> extractParamValues(SolutionMapping sm)

Returns the values that the given solution mapping has for the parameter variables, but only if the solution mapping does indeed have bindings for all parameter variables and the values bound to these variables are literals of the correct datatypes (as specified in the parameter declaration of the REST endpoint). Otherwise, null is returned.

Parameters:

sm - - the solution mapping from which the parameter values are to be extracted

Returns:

the parameter values (in the form of a Jena Node objects) or null

createRequest

protected RESTRequest createRequest(Map<String,org.apache.jena.graph.Node> paramValues)

Assumes that the number of parameter values in the given array is the same as the number of parameter declarations of the REST endpoint and that the datatypes of the values match the ones of the parameter declarations.

join

protected void join(Iterable<SolutionMapping> solmaps1,
 Iterable<SolutionMapping> solmaps2,
 IntermediateResultElementSink sink)

Joins the given sets of solution mappings and sends the result to the given sink.

Parameters:

solmaps1 -

solmaps2 -

sink -

join

protected void join(Iterable<SolutionMapping> solmaps,
 SolutionMapping sm,
 IntermediateResultElementSink sink)

Joins the given set of solution mappings with a singleton set that contains the single given solution mapping, and sends the result to the given sink.

Parameters:

solmaps -

sm -

sink -

resetStats

public void resetStats()

Specified by:

resetStats in interface StatsProvider

Overrides:

resetStats in class BaseForUnaryExecOpWithCollectedInput

createStats

protected ExecutableOperatorStatsImpl createStats()

Overrides:

createStats in class BaseForUnaryExecOpWithCollectedInput