Class ExecOpBind

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

All Implemented Interfaces:

StatsProvider, ExecutableOperator, UnaryExecutableOp

public class ExecOpBind
extends UnaryExecutableOpBase

To be used for BIND clauses.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	ExecOpBind.MultipleVarsWorker
protected class	ExecOpBind.OneVarWorker
protected static interface	ExecOpBind.Worker

Field Summary

Fields

Modifier and Type	Field	Description
protected final ExecOpBind.Worker	worker

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

collectExceptions

Constructor Summary

Constructors

Constructor	Description
ExecOpBind(org.apache.jena.sparql.core.VarExprList bindExpressions, boolean collectExceptions)
ExecOpBind(org.apache.jena.sparql.core.Var var, org.apache.jena.sparql.expr.Expr expr, boolean collectExceptions)

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(List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, ExecutionContext execCxt)	Processes the input solution mappings of the given list by calling UnaryExecutableOpBase._process(SolutionMapping, IntermediateResultElementSink, ExecutionContext) for each of them.
protected void	_process(SolutionMapping inputSolMap, 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()
void	resetStats()
protected void	throwExecOpExecutionException(String msg)

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

Field Details

worker

protected final ExecOpBind.Worker worker

Constructor Details

ExecOpBind

public ExecOpBind(org.apache.jena.sparql.core.VarExprList bindExpressions,
 boolean collectExceptions)

ExecOpBind

public ExecOpBind(org.apache.jena.sparql.core.Var var,
 org.apache.jena.sparql.expr.Expr expr,
 boolean collectExceptions)

Method Details

_process

protected void _process(SolutionMapping inputSolMap,
 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

_process

protected void _process(List<SolutionMapping> inputSolMaps,
 IntermediateResultElementSink sink,
 ExecutionContext execCxt)
                 throws ExecOpExecutionException

Description copied from class: UnaryExecutableOpBase

Processes the input solution mappings of the given list by calling UnaryExecutableOpBase._process(SolutionMapping, IntermediateResultElementSink, ExecutionContext) for each of them. 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). If an exception occurs within the overriding implementation, then this exception needs to be thrown.

Overrides:

_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

resetStats

public void resetStats()

Specified by:

resetStats in interface StatsProvider

Overrides:

resetStats in class UnaryExecutableOpBase

createStats

protected ExecutableOperatorStatsImpl createStats()

Overrides:

createStats in class UnaryExecutableOpBase

throwExecOpExecutionException

protected void throwExecOpExecutionException(String msg)
                                      throws ExecOpExecutionException

Throws:

ExecOpExecutionException