Interface UnaryExecutableOp

All Superinterfaces:

ExecutableOperator, StatsProvider

All Known Implementing Classes:

BaseForExecOpBindJoinSPARQL, BaseForExecOpBindJoinWithRequestOps, BaseForExecOpIndexNestedLoopsJoinWithRequestOps, BaseForExecOpIndexNestedLoopsJoinWithRequests, BaseForExecOpIndexNestedLoopsJoinWithSolMapsRequests, BaseForExecOpIndexNestedLoopsJoinWithTPFRequests, ExecOpBind, ExecOpBindJoinBRTPF, ExecOpBindJoinSPARQLwithFILTER, ExecOpBindJoinSPARQLwithUNION, ExecOpBindJoinSPARQLwithVALUES, ExecOpBindJoinSPARQLwithVALUESorFILTER, ExecOpFilter, ExecOpGlobalToLocal, ExecOpIndexNestedLoopsJoinBRTPF, ExecOpIndexNestedLoopsJoinSPARQL, ExecOpIndexNestedLoopsJoinTPF, ExecOpLocalToGlobal, ExecOpParallelMultiwayLeftJoin, UnaryExecutableOpBase, UnaryExecutableOpBaseWithBatching

public interface UnaryExecutableOp
extends ExecutableOperator

A specialization of the ExecutableOperator interface that captures executable operators that consume a single input sequence of solution mappings.

Method Summary

Modifier and Type	Method	Description
void	concludeExecution(IntermediateResultElementSink sink, ExecutionContext execCxt)	Concludes the execution of this operator and sends the remaining result elements (if any) to the given sink.
default void	process(List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, ExecutionContext execCxt)	Processes the solution mappings of the given list as input to this operator and sends the produced result elements (if any) to the given sink.
void	process(SolutionMapping inputSolMap, IntermediateResultElementSink sink, ExecutionContext execCxt)	Processes the given solution mapping as input to this operator and sends the produced result elements (if any) to the given sink.

Methods inherited from interface se.liu.ida.hefquin.engine.queryplan.executable.ExecutableOperator

getExceptionsCaughtDuringExecution, getStats

Methods inherited from interface se.liu.ida.hefquin.base.utils.StatsProvider

resetStats

Method Details

process

void process(SolutionMapping inputSolMap,
 IntermediateResultElementSink sink,
 ExecutionContext execCxt)
      throws ExecOpExecutionException

Processes the given solution mapping as input to this operator and sends the produced result elements (if any) to the given sink.

Throws:

ExecOpExecutionException

process

default void process(List<SolutionMapping> inputSolMaps,
 IntermediateResultElementSink sink,
 ExecutionContext execCxt)
              throws ExecOpExecutionException

Processes the solution mappings of the given list as input to this operator and sends the produced result elements (if any) to the given sink. The default implementation of this method simply calls process(SolutionMapping, IntermediateResultElementSink, ExecutionContext) for every solution mapping obtained from the given list. Subclasses may override this behavior to send a greater number of output solution mappings to the given sink at a time (which is useful to reduce the communication between threads in the push-based execution model).

Throws:

ExecOpExecutionException

concludeExecution

void concludeExecution(IntermediateResultElementSink sink,
 ExecutionContext execCxt)
                throws ExecOpExecutionException

Concludes the execution of this operator and sends the remaining result elements (if any) to the given sink. This method will be called only once, after the sub-plan that produces the input for this operator has finished producing its result.

Throws:

ExecOpExecutionException