Uses of Class
se.liu.ida.hefquin.engine.queryplan.executable.ExecOpExecutionException

Packages that use ExecOpExecutionException

Package	Description
se.liu.ida.hefquin.engine.queryplan.executable
se.liu.ida.hefquin.engine.queryplan.executable.impl.ops
se.liu.ida.hefquin.engine.queryplan.executable.impl.pushbased

Uses of ExecOpExecutionException in se.liu.ida.hefquin.engine.queryplan.executable

Methods in se.liu.ida.hefquin.engine.queryplan.executable that throw ExecOpExecutionException

Modifier and Type	Method	Description
void	UnaryExecutableOp.concludeExecution(IntermediateResultElementSink sink, ExecutionContext execCxt)	Concludes the execution of this operator and sends the remaining result elements (if any) to the given sink.
void	NullaryExecutableOp.execute(IntermediateResultElementSink sink, ExecutionContext execCxt)	Executes this operator and sends the produced result elements (if any) to the given sink.
default void	UnaryExecutableOp.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	UnaryExecutableOp.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.
default void	BinaryExecutableOp.processInputFromChild1(List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, ExecutionContext execCxt)	Processes the solution mappings of the given list as input coming from the first operand and sends the produced result elements (if any) to the given sink.
void	BinaryExecutableOp.processInputFromChild1(SolutionMapping inputSolMap, IntermediateResultElementSink sink, ExecutionContext execCxt)	Processes the given solution mapping as input coming from the first operand and sends the produced result elements (if any) to the given sink.
default void	BinaryExecutableOp.processInputFromChild2(List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, ExecutionContext execCxt)	Processes the solution mappings of the given list as input coming from the second operand and sends the produced result elements (if any) to the given sink.
void	BinaryExecutableOp.processInputFromChild2(SolutionMapping inputSolMap, IntermediateResultElementSink sink, ExecutionContext execCxt)	Processes the given solution mapping as input coming from the second operand and sends the produced result elements (if any) to the given sink.
default void	NaryExecutableOp.processInputFromXthChild(int x, List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, ExecutionContext execCxt)	Processes the solution mappings oft he given list as input coming from the x-th operand and sends the produced result elements (if any) to the given sink.
void	NaryExecutableOp.processInputFromXthChild(int x, SolutionMapping inputSolMap, IntermediateResultElementSink sink, ExecutionContext execCxt)	Processes the given solution mapping as input coming from the x-th operand and sends the produced result elements (if any) to the given sink.
void	BinaryExecutableOp.wrapUpForChild1(IntermediateResultElementSink sink, ExecutionContext execCxt)	Finishes up any processing related to the input coming from the first operand and sends the remaining result elements (if any) to the given sink.
void	BinaryExecutableOp.wrapUpForChild2(IntermediateResultElementSink sink, ExecutionContext execCxt)	Finishes up any processing related to the input coming from the second operand and sends the remaining result elements (if any) to the given sink.
void	NaryExecutableOp.wrapUpForXthChild(int x, IntermediateResultElementSink sink, ExecutionContext execCxt)	Finishes up any processing related to the input coming from the x-th operand and sends the remaining result elements (if any) to the given sink.

Uses of ExecOpExecutionException in se.liu.ida.hefquin.engine.queryplan.executable.impl.ops

Methods in se.liu.ida.hefquin.engine.queryplan.executable.impl.ops that throw ExecOpExecutionException

Modifier and Type	Method	Description
protected void	BaseForExecOpBindJoinWithRequestOps._concludeExecution(List<SolutionMapping> batchOfSolMaps, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	BaseForExecOpIndexNestedLoopsJoinWithRequestOps._concludeExecution(List<SolutionMapping> input, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	BaseForExecOpIndexNestedLoopsJoinWithRequests._concludeExecution(List<SolutionMapping> input, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpBindJoinSPARQLwithVALUESorFILTER._concludeExecution(List<SolutionMapping> batch, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpParallelMultiwayLeftJoin._concludeExecution(List<SolutionMapping> batch, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected abstract void	UnaryExecutableOpBase._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 abstract void	UnaryExecutableOpBaseWithBatching._concludeExecution(List<SolutionMapping> currentBatch, IntermediateResultElementSink sink, ExecutionContext execCxt)	Implementations of this function need to process the given batch of solution mappings as last input, conclude the execution of this operator, and send the remaining result elements (if any) to the given sink.
protected final void	UnaryExecutableOpBaseWithBatching._concludeExecution(IntermediateResultElementSink sink, ExecutionContext execCxt)
protected final void	BaseForExecOpRequestWithPaging._execute(IntermediateResultElementSink sink, ExecutionContext execCxt)
protected final void	BaseForExecOpRequestWithTPFPaging._execute(IntermediateResultElementSink sink, ExecutionContext execCxt)
protected final void	BaseForExecOpSolMapsRequest._execute(IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	BaseForExecOpTriplesRequest._execute(IntermediateResultElementSink sink, ExecutionContext execCxt)
protected abstract void	NullaryExecutableOpBase._execute(IntermediateResultElementSink sink, ExecutionContext execCxt)	Implementations of this function need to execute the algorithm of this operator and send the result elements (if any) to the given sink.
protected void	ExecOpBind._process(List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpBind._process(SolutionMapping inputSolMap, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	UnaryExecutableOpBase._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 abstract void	UnaryExecutableOpBase._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 final void	UnaryExecutableOpBaseWithBatching._process(SolutionMapping inputSolMap, IntermediateResultElementSink sink, ExecutionContext execCxt)
void	BaseForExecOpBindJoinSPARQL._processBatch(List<SolutionMapping> batchOfSolMaps, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	BaseForExecOpBindJoinWithRequestOps._processBatch(List<SolutionMapping> batchOfSolMaps, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	BaseForExecOpIndexNestedLoopsJoinWithRequestOps._processBatch(List<SolutionMapping> input, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	BaseForExecOpIndexNestedLoopsJoinWithRequests._processBatch(List<SolutionMapping> input, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpBindJoinSPARQLwithVALUESorFILTER._processBatch(List<SolutionMapping> batch, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpParallelMultiwayLeftJoin._processBatch(List<SolutionMapping> input, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected abstract void	UnaryExecutableOpBaseWithBatching._processBatch(List<SolutionMapping> currentBatch, IntermediateResultElementSink sink, ExecutionContext execCxt)	Implementations of this function need to process the given batch of solution mappings as input and send the produced result elements (if any) to the given sink.
protected void	BinaryExecutableOpBase._processInputFromChild1(List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, ExecutionContext execCxt)	Processes the input solution mappings of the given list by calling BinaryExecutableOpBase._processInputFromChild1(SolutionMapping, IntermediateResultElementSink, ExecutionContext) for each of them.
protected abstract void	BinaryExecutableOpBase._processInputFromChild1(SolutionMapping inputSolMap, IntermediateResultElementSink sink, ExecutionContext execCxt)	Implementations of this function need to process the given solution mapping as input coming from the first operand and send the produced result elements (if any) to the given sink.
protected void	BinaryExecutableOpBase._processInputFromChild2(List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, ExecutionContext execCxt)	Processes the input solution mappings of the given list by calling BinaryExecutableOpBase._processInputFromChild2(SolutionMapping, IntermediateResultElementSink, ExecutionContext) for each of them.
protected abstract void	BinaryExecutableOpBase._processInputFromChild2(SolutionMapping inputSolMap, IntermediateResultElementSink sink, ExecutionContext execCxt)	Implementations of this function need to process the given solution mapping as input coming from the second operand and send the produced result elements (if any) to the given sink.
protected void	NaryExecutableOpBase._processInputFromXthChild(int x, List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, ExecutionContext execCxt)	Processes the input solution mappings of the given list by calling NaryExecutableOpBase._processInputFromXthChild(int, SolutionMapping, IntermediateResultElementSink, ExecutionContext) for each of them.
protected abstract void	NaryExecutableOpBase._processInputFromXthChild(int x, SolutionMapping inputSolMap, IntermediateResultElementSink sink, ExecutionContext execCxt)	Implementations of this function need to process the given solution mapping as input coming from the x-th operand and send the produced result elements (if any) to the given sink.
protected void	BaseForExecOpBindJoinWithRequestOps._processJoinableInput(Iterable<SolutionMapping> joinableInputSMs, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	BaseForExecOpBindJoinWithRequestOps._processWithoutSplittingInputFirst(List<SolutionMapping> joinableInputSMs, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected abstract void	BinaryExecutableOpBase._wrapUpForChild1(IntermediateResultElementSink sink, ExecutionContext execCxt)	Implementations of this function need to finish up any processing related to the input coming from the first operand and send the remaining result elements (if any) to the given sink.
protected abstract void	BinaryExecutableOpBase._wrapUpForChild2(IntermediateResultElementSink sink, ExecutionContext execCxt)	Implementations of this function need to finish up any processing related to the input coming from the second operand and send the remaining result elements (if any) to the given sink.
protected abstract void	NaryExecutableOpBase._wrapUpForXthChild(int x, IntermediateResultElementSink sink, ExecutionContext execCxt)	Implementations of this function need to finish up any processing related to the input coming from the x-th operand and send the remaining result elements (if any) to the given sink.
final void	UnaryExecutableOpBase.concludeExecution(IntermediateResultElementSink sink, ExecutionContext execCxt)
final void	NullaryExecutableOpBase.execute(IntermediateResultElementSink sink, ExecutionContext execCxt)
SolutionMapping	ExecOpBind.MultipleVarsWorker.extend(SolutionMapping solmap)
SolutionMapping	ExecOpBind.OneVarWorker.extend(SolutionMapping solmap)
SolutionMapping	ExecOpBind.Worker.extend(SolutionMapping solmap)
protected boolean	BaseForExecOpRequestWithTPFPaging.isLastPage(TPFResponse response)
protected void	ExecOpParallelMultiwayLeftJoin.parallelPhase(List<SolutionMapping> inputForParallelProcess, ExecutionContext execCxt)
protected void	BaseForExecOpSolMapsRequest.process(SolMapsResponse response, IntermediateResultElementSink sink)
final void	UnaryExecutableOpBase.process(List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, ExecutionContext execCxt)
final void	UnaryExecutableOpBase.process(SolutionMapping inputSolMap, IntermediateResultElementSink sink, ExecutionContext execCxt)
final void	BinaryExecutableOpBase.processInputFromChild1(List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, ExecutionContext execCxt)
final void	BinaryExecutableOpBase.processInputFromChild1(SolutionMapping inputSolMap, IntermediateResultElementSink sink, ExecutionContext execCxt)
final void	BinaryExecutableOpBase.processInputFromChild2(List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, ExecutionContext execCxt)
final void	BinaryExecutableOpBase.processInputFromChild2(SolutionMapping inputSolMap, IntermediateResultElementSink sink, ExecutionContext execCxt)
final void	NaryExecutableOpBase.processInputFromXthChild(int x, List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, ExecutionContext execCxt)
final void	NaryExecutableOpBase.processInputFromXthChild(int x, SolutionMapping inputSolMap, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpBind.throwExecOpExecutionException(String msg)
final void	BinaryExecutableOpBase.wrapUpForChild1(IntermediateResultElementSink sink, ExecutionContext execCxt)
final void	BinaryExecutableOpBase.wrapUpForChild2(IntermediateResultElementSink sink, ExecutionContext execCxt)
final void	NaryExecutableOpBase.wrapUpForXthChild(int x, IntermediateResultElementSink sink, ExecutionContext execCxt)

Uses of ExecOpExecutionException in se.liu.ida.hefquin.engine.queryplan.executable.impl.pushbased

Methods in se.liu.ida.hefquin.engine.queryplan.executable.impl.pushbased that throw ExecOpExecutionException

Modifier and Type	Method	Description
protected abstract void	PushBasedPlanThreadImplBase.produceOutput(IntermediateResultElementSink sink)
protected void	PushBasedPlanThreadImplForBinaryOperator.produceOutput(IntermediateResultElementSink sink)
protected void	PushBasedPlanThreadImplForNaryOperator.produceOutput(IntermediateResultElementSink sink)
protected void	PushBasedPlanThreadImplForNullaryOperator.produceOutput(IntermediateResultElementSink sink)
protected void	PushBasedPlanThreadImplForUnaryOperator.produceOutput(IntermediateResultElementSink sink)
protected void	PushBasedPlanThreadImplForNaryOperator.produceOutputByConsumingAllInputsInParallel(IntermediateResultElementSink sink)	Consumes the complete i-th input first (and pushes that input to the operator PushBasedPlanThreadImplForNaryOperator.op), before moving on to the (i+1)-th input.
protected void	PushBasedPlanThreadImplForBinaryOperator.produceOutputByConsumingBothInputsInParallel(IntermediateResultElementSink sink)	Aims to consume both inputs in parallel.
protected void	PushBasedPlanThreadImplForBinaryOperator.produceOutputByConsumingInput1First(IntermediateResultElementSink sink)	Consumes the complete child 1 input first (and pushes that input to the operator PushBasedPlanThreadImplForBinaryOperator.op), before moving on to the input from child 2.
protected void	PushBasedPlanThreadImplForNaryOperator.produceOutputByConsumingInputsOneAfterAnother(IntermediateResultElementSink sink)	Consumes the complete i-th input first (and pushes that input to the operator PushBasedPlanThreadImplForNaryOperator.op), before moving on to the (i+1)-th input.