Uses of Interface
se.liu.ida.hefquin.engine.queryplan.executable.IntermediateResultElementSink

Packages that use IntermediateResultElementSink

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

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

Methods in se.liu.ida.hefquin.engine.queryplan.executable with parameters of type IntermediateResultElementSink

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 IntermediateResultElementSink in se.liu.ida.hefquin.engine.queryplan.executable.impl

Subinterfaces of IntermediateResultElementSink in se.liu.ida.hefquin.engine.queryplan.executable.impl

Modifier and Type	Interface	Description
interface	ClosableIntermediateResultElementSink

Classes in se.liu.ida.hefquin.engine.queryplan.executable.impl that implement IntermediateResultElementSink

Modifier and Type	Class	Description
class	CollectingIntermediateResultElementSink	A (thread-safe) implementation of IntermediateResultElementSink that collects all solution mappings that are sent to it.
class	CollectingIntermediateResultElementSinkWithTranslation
class	MaterializingIntermediateResultElementSink	An implementation of IntermediateResultElementSink that materializes all solution mappings that are sent to it directly into an IntermediateResultBlock.
class	SynchronizedIntermediateResultElementSink

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

Classes in se.liu.ida.hefquin.engine.queryplan.executable.impl.ops that implement IntermediateResultElementSink

Modifier and Type	Class	Description
protected class	BaseForExecOpBindJoinWithRequestOps.MyIntermediateResultElementSink
protected class	BaseForExecOpBindJoinWithRequestOps.MyIntermediateResultElementSinkOuterJoin
protected class	BaseForExecOpIndexNestedLoopsJoinWithRequestOps.MyIntermediateResultElementSink
protected class	BaseForExecOpIndexNestedLoopsJoinWithRequestOps.MyIntermediateResultElementSinkOuterJoin

Fields in se.liu.ida.hefquin.engine.queryplan.executable.impl.ops declared as IntermediateResultElementSink

Modifier and Type	Field	Description
protected final IntermediateResultElementSink	ExecOpParallelMultiwayLeftJoin.Worker.mySink
protected final IntermediateResultElementSink	BaseForExecOpBindJoinWithRequestOps.MyIntermediateResultElementSink.outputSink
protected final IntermediateResultElementSink	BaseForExecOpIndexNestedLoopsJoinWithRequestOps.MyIntermediateResultElementSink.outputSink
protected final IntermediateResultElementSink	BaseForExecOpIndexNestedLoopsJoinWithRequests.MyResponseProcessor.sink

Methods in se.liu.ida.hefquin.engine.queryplan.executable.impl.ops with parameters of type IntermediateResultElementSink

Modifier and Type	Method	Description
protected void	BaseForExecOpBindJoin._concludeExecution(IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	BaseForExecOpIndexNestedLoopsJoin._concludeExecution(IntermediateResultElementSink sink, ExecutionContext execCxt)
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 void	UnaryExecutableOpBaseWithIterator._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	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(Iterator<SolutionMapping> output, IntermediateResultElementSink sink, ExecutionContext execCxt)
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 void	ExecOpBinaryUnion._processBlockFromChild1(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpHashJoin._processBlockFromChild1(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpNaiveNestedLoopsJoin._processBlockFromChild1(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpSymmetricHashJoin._processBlockFromChild1(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)
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 void	ExecOpBinaryUnion._processBlockFromChild2(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpHashJoin._processBlockFromChild2(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpNaiveNestedLoopsJoin._processBlockFromChild2(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpSymmetricHashJoin._processBlockFromChild2(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpMultiwayUnion._processBlockFromXthChild(int x, IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)
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	ExecOpHashJoin._processSolMapFromChild2(SolutionMapping smR, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpHashRJoin._processSolMapFromChild2(SolutionMapping smR, 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 void	ExecOpBinaryUnion._wrapUpForChild1(IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpHashJoin._wrapUpForChild1(IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpNaiveNestedLoopsJoin._wrapUpForChild1(IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpSymmetricHashJoin._wrapUpForChild1(IntermediateResultElementSink sink, ExecutionContext execCxt)
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 void	ExecOpBinaryUnion._wrapUpForChild2(IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpHashJoin._wrapUpForChild2(IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpNaiveNestedLoopsJoin._wrapUpForChild2(IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpSymmetricHashJoin._wrapUpForChild2(IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpMultiwayUnion._wrapUpForXthChild(int x, IntermediateResultElementSink sink, ExecutionContext execCxt)
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 void	BaseForExecOpRequestWithTPFPaging.consumeMatchingTriples(Iterable<Triple> itTriples, IntermediateResultElementSink sink)
protected abstract void	BaseForExecOpRequestWithPaging.consumeResponse(PageRespType response, IntermediateResultElementSink sink)
protected Runnable	BaseForExecOpIndexNestedLoopsJoinWithRequestOps.createProcessor(NullaryExecutableOp reqOp, SolutionMapping smFromInput, IntermediateResultElementSink outputSink, ExecutionContext execCxt)
protected abstract BaseForExecOpIndexNestedLoopsJoinWithRequests<QueryType,MemberType,ReqType,RespType>.MyResponseProcessor	BaseForExecOpIndexNestedLoopsJoinWithRequests.createResponseProcessor(SolutionMapping sm, IntermediateResultElementSink sink)
protected BaseForExecOpIndexNestedLoopsJoinWithRequests<QueryType,MemberType,ReqType,SolMapsResponse>.MyResponseProcessor	BaseForExecOpIndexNestedLoopsJoinWithSolMapsRequests.createResponseProcessor(SolutionMapping sm, IntermediateResultElementSink sink)
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.mergePhase(Iterable<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink)
protected void	BaseForExecOpSolMapsRequest.process(SolMapsResponse response, IntermediateResultElementSink sink)
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)

Constructors in se.liu.ida.hefquin.engine.queryplan.executable.impl.ops with parameters of type IntermediateResultElementSink

Modifier	Constructor	Description
	MyIntermediateResultElementSink(IntermediateResultElementSink outputSink, Iterable<SolutionMapping> inputSolutionMappings)
	MyIntermediateResultElementSink(IntermediateResultElementSink outputSink, SolutionMapping smFromInput)
	MyIntermediateResultElementSinkOuterJoin(IntermediateResultElementSink outputSink, Iterable<SolutionMapping> inputSolutionMappings)
	MyIntermediateResultElementSinkOuterJoin(IntermediateResultElementSink outputSink, SolutionMapping smFromInput)
	MyResponseProcessor(SolutionMapping sm, IntermediateResultElementSink sink)

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

Classes in se.liu.ida.hefquin.engine.queryplan.executable.impl.pushbased that implement IntermediateResultElementSink

Modifier and Type	Class	Description
class	ConnectorForAdditionalConsumer
class	PushBasedExecPlanTaskBase	Push-based implementation of ExecPlanTask.
class	PushBasedExecPlanTaskForBinaryOperator
class	PushBasedExecPlanTaskForNaryOperator
class	PushBasedExecPlanTaskForNullaryOperator
class	PushBasedExecPlanTaskForUnaryOperator

Methods in se.liu.ida.hefquin.engine.queryplan.executable.impl.pushbased with parameters of type IntermediateResultElementSink

Modifier and Type	Method	Description
protected void	ConnectorForAdditionalConsumer.produceOutput(IntermediateResultElementSink sink)
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.