Uses of Class
se.liu.ida.hefquin.engine.queryplan.executable.impl.pushbased.ConsumingPushBasedPlanThreadException

Packages that use ConsumingPushBasedPlanThreadException

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

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

Subclasses of ConsumingPushBasedPlanThreadException in se.liu.ida.hefquin.engine.queryplan.executable.impl.pushbased

Modifier and Type	Class	Description
class	InterruptedWaitingForPushBasedPlanThreadException	This class wraps an InterruptedException caught in a thread that is waiting to consume the output of a PushBasedPlanThread.

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

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	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.
void	PushBasedPlanThread.transferAvailableOutput(List<SolutionMapping> transferBuffer)	This function first clears the given list and, then, transfers the currently-available solution mappings produced by this task from an internal buffer to the given list, in the order in which the solution mappings have been produced.
final void	PushBasedPlanThreadImplBase.transferAvailableOutput(List<SolutionMapping> transferBuffer)