Class ExecOpLookupJoinViaWrapperWithoutParamVars

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

All Implemented Interfaces:

StatsProvider, ExecutableOperator, UnaryExecutableOp

public class ExecOpLookupJoinViaWrapperWithoutParamVars
extends UnaryExecutableOpBase

Field Summary

Fields

Modifier and Type	Field	Description
protected final WrappedRESTEndpoint	fm
protected final SPARQLGraphPattern	pattern
protected List<SolutionMapping>	solmapsFromRequest

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

collectExceptions, qpInfo

Constructor Summary

Constructors

Constructor	Description
ExecOpLookupJoinViaWrapperWithoutParamVars(SPARQLGraphPattern pattern, WrappedRESTEndpoint fm, boolean collectExceptions, QueryPlanningInfo qpInfo)

Method Summary

Modifier and Type	Method	Description
protected void	_concludeExecution(IntermediateResultElementSink sink, ExecutionContext execCxt)	Implementations of this function need to conclude the execution of this operator and send the remaining result elements (if any) to the given sink.
protected void	_process(SolutionMapping inputSM, IntermediateResultElementSink sink, ExecutionContext execCxt)	Implementations of this function need to process the given solution mapping as input and send the produced result elements (if any) to the given sink.
protected ExecutableOperatorStatsImpl	createStats()
protected List<SolutionMapping>	performRequest(ExecutionContext execCxt)
void	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, 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

pattern

protected final SPARQLGraphPattern pattern

fm

protected final WrappedRESTEndpoint fm

solmapsFromRequest

protected List<SolutionMapping> solmapsFromRequest

Constructor Details

ExecOpLookupJoinViaWrapperWithoutParamVars

public ExecOpLookupJoinViaWrapperWithoutParamVars(SPARQLGraphPattern pattern,
 WrappedRESTEndpoint fm,
 boolean collectExceptions,
 QueryPlanningInfo qpInfo)

Method Details

_process

protected void _process(SolutionMapping inputSM,
 IntermediateResultElementSink sink,
 ExecutionContext execCxt)
                 throws ExecOpExecutionException

Description copied from class: UnaryExecutableOpBase

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

Specified by:

_process in class UnaryExecutableOpBase

Throws:

ExecOpExecutionException

_concludeExecution

protected void _concludeExecution(IntermediateResultElementSink sink,
 ExecutionContext execCxt)

Description copied from class: UnaryExecutableOpBase

Implementations of this function need to conclude the execution of this operator and send the remaining result elements (if any) to the given sink. If an exception occurs during this process, then this exception needs to be thrown.

Specified by:

_concludeExecution in class UnaryExecutableOpBase

performRequest

protected List<SolutionMapping> performRequest(ExecutionContext execCxt)
                                        throws ExecOpExecutionException

Throws:

ExecOpExecutionException

resetStats

public void resetStats()

Specified by:

resetStats in interface StatsProvider

Overrides:

resetStats in class UnaryExecutableOpBase

createStats

protected ExecutableOperatorStatsImpl createStats()

Overrides:

createStats in class UnaryExecutableOpBase