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.pullbased
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.
void	UnaryExecutableOp.process(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)	Processes the given input and sends the produced result elements (if any) to the given sink.
void	BinaryExecutableOp.processBlockFromChild1(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)	Processes the given input coming from the first operand and sends the produced result elements (if any) to the given sink.
void	BinaryExecutableOp.processBlockFromChild2(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)	Processes the given input coming from the second operand and sends the produced result elements (if any) to the given sink.
void	NaryExecutableOp.processBlockFromXthChild(int x, IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)	Processes the given 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	ExecOpParallelMultiwayLeftJoin._concludeExecution(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 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 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	BaseForExecOpBindJoinWithRequestOps._process(Iterable<SolutionMapping> joinableInputSMs, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	BaseForExecOpBindJoinWithRequestOps._process(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	BaseForExecOpIndexNestedLoopsJoinWithRequestOps._process(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	BaseForExecOpIndexNestedLoopsJoinWithRequests._process(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpParallelMultiwayLeftJoin._process(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected abstract void	UnaryExecutableOpBase._process(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)	Implementations of this function need to process the given input block and send the produced result elements (if any) to the given sink.
protected void	UnaryExecutableOpBaseWithIterator._process(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected abstract void	BinaryExecutableOpBase._processBlockFromChild1(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)	Implementations of this function need to process the given input block coming from the first operand and send the produced result elements (if any) to the given sink.
protected abstract void	BinaryExecutableOpBase._processBlockFromChild2(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)	Implementations of this function need to process the given input block coming from the second operand and send the produced result elements (if any) to the given sink.
protected abstract void	NaryExecutableOpBase._processBlockFromXthChild(int x, IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)	Implementations of this function need to process the given input block coming from the x-th operand and send the produced result elements (if any) to the given sink.
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)
protected abstract Iterator<SolutionMapping>	UnaryExecutableOpBaseWithIterator.createInputToOutputIterator(Iterable<SolutionMapping> input)
final void	NullaryExecutableOpBase.execute(IntermediateResultElementSink sink, ExecutionContext execCxt)
protected CompletableFuture<?>	BaseForExecOpIndexNestedLoopsJoinWithRequestOps.initiateProcessing(SolutionMapping sm, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected CompletableFuture<?>[]	BaseForExecOpIndexNestedLoopsJoinWithRequestOps.initiateProcessing(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpParallelMultiwayLeftJoin.parallelPhase(IntermediateResultBlock inputForParallelProcess, ExecutionContext execCxt)
final void	UnaryExecutableOpBase.process(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)
final void	BinaryExecutableOpBase.processBlockFromChild1(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)
final void	BinaryExecutableOpBase.processBlockFromChild2(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)
final void	NaryExecutableOpBase.processBlockFromXthChild(int x, IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)
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.pullbased

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

Modifier and Type	Method	Description
protected abstract IntermediateResultBlock	PullBasedExecPlanTaskBase.produceNextIntermediateResultBlock()	Produces and returns a new IntermediateResultBlock.
protected IntermediateResultBlock	PullBasedExecPlanTaskForBinaryOperator.produceNextIntermediateResultBlock()
protected IntermediateResultBlock	PullBasedExecPlanTaskForNullaryOperator.produceNextIntermediateResultBlock()
protected IntermediateResultBlock	PullBasedExecPlanTaskForUnaryOperator.produceNextIntermediateResultBlock()

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	PushBasedExecPlanTaskBase.produceOutput(IntermediateResultElementSink sink)
protected void	PushBasedExecPlanTaskForBinaryOperator.produceOutput(IntermediateResultElementSink sink)
protected void	PushBasedExecPlanTaskForNaryOperator.produceOutput(IntermediateResultElementSink sink)
protected void	PushBasedExecPlanTaskForNullaryOperator.produceOutput(IntermediateResultElementSink sink)
protected void	PushBasedExecPlanTaskForUnaryOperator.produceOutput(IntermediateResultElementSink sink)
protected void	PushBasedExecPlanTaskForNaryOperator.produceOutputByConsumingAllInputsInParallel(IntermediateResultElementSink sink)	Consumes the complete i-th input first (and pushes that input to the operator PushBasedExecPlanTaskForNaryOperator.op), before moving on to the (i+1)-th input.
protected void	PushBasedExecPlanTaskForBinaryOperator.produceOutputByConsumingBothInputsInParallel(IntermediateResultElementSink sink)	Aims to consume both inputs in parallel.
protected void	PushBasedExecPlanTaskForBinaryOperator.produceOutputByConsumingInput1First(IntermediateResultElementSink sink)	Consumes the complete child 1 input first (and pushes that input to the operator PushBasedExecPlanTaskForBinaryOperator.op), before moving on to the input from child 2.
protected void	PushBasedExecPlanTaskForNaryOperator.produceOutputByConsumingInputsOneAfterAnother(IntermediateResultElementSink sink)	Consumes the complete i-th input first (and pushes that input to the operator PushBasedExecPlanTaskForNaryOperator.op), before moving on to the (i+1)-th input.