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, QueryProcContextExt ctx)	Concludes the execution of this operator and sends the remaining result elements (if any) to the given sink.
void	NullaryExecutableOp.execute(IntermediateResultElementSink sink, QueryProcContextExt ctx)	Executes this operator and sends the produced result elements (if any) to the given sink.
default void	UnaryExecutableOp.process(List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, QueryProcContextExt ctx)	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, QueryProcContextExt ctx)	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, QueryProcContextExt ctx)	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, QueryProcContextExt ctx)	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, QueryProcContextExt ctx)	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, QueryProcContextExt ctx)	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, QueryProcContextExt ctx)	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, QueryProcContextExt ctx)	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, QueryProcContextExt ctx)	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, QueryProcContextExt ctx)	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, QueryProcContextExt ctx)	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	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	BaseForExecOpIndexNestedLoopsJoinWithRequestOps.MyIntermediateResultElementSink
protected class	BaseForExecOpIndexNestedLoopsJoinWithRequestOps.MyIntermediateResultElementSinkOuterJoin
protected class	BaseForExecOpSequentialBindJoin.MyIntermediateResultElementSink
protected class	BaseForExecOpSequentialBindJoin.MyIntermediateResultElementSinkOuterJoin
protected class	ExecOpSequentialBindJoinSPARQLwithVarRenaming.MyIntermediateResultElementSink2
protected class	ExecOpSequentialBindJoinSPARQLwithVarRenaming.MyIntermediateResultElementSinkOuterJoin2

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	BaseForExecOpIndexNestedLoopsJoinWithRequestOps.MyIntermediateResultElementSink.outputSink
protected final IntermediateResultElementSink	BaseForExecOpIndexNestedLoopsJoinWithRequests.MyResponseProcessor.sink
protected final IntermediateResultElementSink	BaseForExecOpParallelBindJoin.MyResponseProcessor.sink
protected final IntermediateResultElementSink	ExecOpLookupJoinViaWrapperWithParamVars.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	BaseForExecOpIndexNestedLoopsJoinWithRequestOps._concludeExecution(List<SolutionMapping> input, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	BaseForExecOpIndexNestedLoopsJoinWithRequests._concludeExecution(List<SolutionMapping> input, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	BaseForExecOpParallelBindJoin._concludeExecution(List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	BaseForExecOpSequentialBindJoin._concludeExecution(IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected abstract void	BaseForUnaryExecOpWithCollectedInput._concludeExecution(List<SolutionMapping> currentBatch, IntermediateResultElementSink sink, QueryProcContextExt ctx)	Implementations of this function need to process the given 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	BaseForUnaryExecOpWithCollectedInput._concludeExecution(IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpBind._concludeExecution(IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpDuplicateRemoval._concludeExecution(IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpFilter._concludeExecution(IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpGlobalToLocal._concludeExecution(IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpLocalToGlobal._concludeExecution(IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpLookupJoinViaWrapperWithoutParamVars._concludeExecution(IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpLookupJoinViaWrapperWithParamVars._concludeExecution(List<SolutionMapping> input, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpParallelMultiwayLeftJoin._concludeExecution(List<SolutionMapping> batch, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpProject._concludeExecution(IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpUnfold._concludeExecution(IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected abstract void	UnaryExecutableOpBase._concludeExecution(IntermediateResultElementSink sink, QueryProcContextExt ctx)	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, QueryProcContextExt ctx)
protected final void	BaseForExecOpRequestWithTPFPaging._execute(IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	BaseForExecOpTriplesRequest._execute(IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected final void	ExecOpRequestOther._execute(IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected final void	ExecOpRequestSPARQL._execute(IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected abstract void	NullaryExecutableOpBase._execute(IntermediateResultElementSink sink, QueryProcContextExt ctx)	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	BaseForExecOpSequentialBindJoin._process(SolutionMapping inputSolMap, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected final void	BaseForUnaryExecOpWithCollectedInput._process(List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected final void	BaseForUnaryExecOpWithCollectedInput._process(SolutionMapping inputSolMap, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpBind._process(Iterator<SolutionMapping> inputSolMaps, int maxBatchSize, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpBind._process(SolutionMapping inputSolMap, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpDuplicateRemoval._process(SolutionMapping inputSolMap, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpFilter._process(Iterator<SolutionMapping> inputSolMaps, int maxBatchSize, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpFilter._process(SolutionMapping inputSolMap, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpGlobalToLocal._process(Iterator<SolutionMapping> inputSolMaps, int maxBatchSize, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpGlobalToLocal._process(SolutionMapping inputSolMap, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpLocalToGlobal._process(Iterator<SolutionMapping> inputSolMaps, int maxBatchSize, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpLocalToGlobal._process(SolutionMapping inputSolMap, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpLookupJoinViaWrapperWithoutParamVars._process(SolutionMapping inputSM, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpProject._process(Iterator<SolutionMapping> inputSolMaps, int maxBatchSize, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpProject._process(SolutionMapping inputSolMap, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpUnfold._process(SolutionMapping inputSolMap, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	UnaryExecutableOpBase._process(List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, QueryProcContextExt ctx)	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, QueryProcContextExt ctx)	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 void	UnaryExecutableOpBaseWithoutBlocking._process(Iterator<SolutionMapping> inputSolMaps, int maxBatchSize, IntermediateResultElementSink sink, QueryProcContextExt ctx)	Processes input solution mappings of the given iterator by calling UnaryExecutableOpBase._process(SolutionMapping, IntermediateResultElementSink, ExecutionContext) for each of them, but consumes only as many input solution mappings as specified by the maxBatchSize argument (or less if the given iterator is exhausted earlier).
protected final void	UnaryExecutableOpBaseWithoutBlocking._process(List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	BaseForExecOpIndexNestedLoopsJoinWithRequestOps._processCollectedInput(List<SolutionMapping> input, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	BaseForExecOpIndexNestedLoopsJoinWithRequests._processCollectedInput(List<SolutionMapping> input, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	BaseForExecOpParallelBindJoin._processCollectedInput(List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected abstract void	BaseForUnaryExecOpWithCollectedInput._processCollectedInput(List<SolutionMapping> currentBatch, IntermediateResultElementSink sink, QueryProcContextExt ctx)	Implementations of this function need to process the given solution mappings as input and send the produced result elements (if any) to the given sink.
protected void	ExecOpLookupJoinViaWrapperWithParamVars._processCollectedInput(List<SolutionMapping> input, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpParallelMultiwayLeftJoin._processCollectedInput(List<SolutionMapping> input, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	BinaryExecutableOpBase._processInputFromChild1(List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, QueryProcContextExt ctx)	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, QueryProcContextExt ctx)	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	ExecOpBinaryUnion._processInputFromChild1(List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpBinaryUnion._processInputFromChild1(SolutionMapping inputSolMap, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpHashJoin1._processInputFromChild1(SolutionMapping inputSolMap, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpHashJoin2._processInputFromChild1(List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpHashJoin2._processInputFromChild1(SolutionMapping inputSolMap, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpNaiveNestedLoopsJoin._processInputFromChild1(SolutionMapping inputSolMap, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpSymmetricHashJoin._processInputFromChild1(List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpSymmetricHashJoin._processInputFromChild1(SolutionMapping inputSolMap, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	BinaryExecutableOpBase._processInputFromChild2(List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, QueryProcContextExt ctx)	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, QueryProcContextExt ctx)	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	ExecOpBinaryUnion._processInputFromChild2(List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpBinaryUnion._processInputFromChild2(SolutionMapping inputSolMap, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpHashJoin1._processInputFromChild2(List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpHashJoin1._processInputFromChild2(SolutionMapping inputSolMap, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpHashJoin2._processInputFromChild2(SolutionMapping inputSolMap, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpNaiveNestedLoopsJoin._processInputFromChild2(List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpNaiveNestedLoopsJoin._processInputFromChild2(SolutionMapping inputSolMap, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpSymmetricHashJoin._processInputFromChild2(List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpSymmetricHashJoin._processInputFromChild2(SolutionMapping inputSolMap, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpMultiwayUnion._processInputFromXthChild(int x, List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpMultiwayUnion._processInputFromXthChild(int x, SolutionMapping inputSolMap, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	NaryExecutableOpBase._processInputFromXthChild(int x, List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, QueryProcContextExt ctx)	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, QueryProcContextExt ctx)	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	BaseForExecOpSequentialBindJoin._processJoinableInput(SolutionMapping inputSolMap, org.apache.jena.sparql.engine.binding.Binding inputSolMapRestricted, IntermediateResultElementSink sink, QueryProcContextExt ctx)	Makes sure that the given solution mapping will be considered for the next bind-join request, and performs that request if enough solution mappings have been accumulated.
protected abstract void	BinaryExecutableOpBase._wrapUpForChild1(IntermediateResultElementSink sink, QueryProcContextExt ctx)	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, QueryProcContextExt ctx)
protected void	ExecOpHashJoin1._wrapUpForChild1(IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpHashJoin2._wrapUpForChild1(IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpNaiveNestedLoopsJoin._wrapUpForChild1(IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpSymmetricHashJoin._wrapUpForChild1(IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected abstract void	BinaryExecutableOpBase._wrapUpForChild2(IntermediateResultElementSink sink, QueryProcContextExt ctx)	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, QueryProcContextExt ctx)
protected void	ExecOpHashJoin1._wrapUpForChild2(IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpHashJoin2._wrapUpForChild2(IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpNaiveNestedLoopsJoin._wrapUpForChild2(IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpSymmetricHashJoin._wrapUpForChild2(IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpMultiwayUnion._wrapUpForXthChild(int x, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected abstract void	NaryExecutableOpBase._wrapUpForXthChild(int x, IntermediateResultElementSink sink, QueryProcContextExt ctx)	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.
protected void	BaseForExecOpParallelBindJoin.batchUp(SolutionMapping inputSolMap, IntermediateResultElementSink sink, QueryProcContextExt ctx)
final void	UnaryExecutableOpBase.concludeExecution(IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	BaseForExecOpRequestWithTPFPaging.consumeMatchingTriples(Iterable<Triple> itTriples, IntermediateResultElementSink sink)
protected void	BaseForExecOpSequentialBindJoin.consumeMySink(BaseForExecOpSequentialBindJoin<QueryType,MemberType>.MyIntermediateResultElementSink mySink, IntermediateResultElementSink outputSink)
protected abstract void	BaseForExecOpRequestWithPaging.consumeResponse(PageRespType response, IntermediateResultElementSink sink)
protected Runnable	BaseForExecOpIndexNestedLoopsJoinWithRequestOps.createProcessor(NullaryExecutableOp reqOp, SolutionMapping smFromInput, IntermediateResultElementSink outputSink, QueryProcContextExt ctx)
protected abstract BaseForExecOpIndexNestedLoopsJoinWithRequests<QueryType,MemberType,ReqType,RespType>.MyResponseProcessor	BaseForExecOpIndexNestedLoopsJoinWithRequests.createResponseProcessor(SolutionMapping sm, IntermediateResultElementSink sink, ExecutableOperator op)
protected BaseForExecOpIndexNestedLoopsJoinWithRequests<QueryType,MemberType,ReqType,SolMapsResponse>.MyResponseProcessor	BaseForExecOpIndexNestedLoopsJoinWithSolMapsRequests.createResponseProcessor(SolutionMapping sm, IntermediateResultElementSink sink, ExecutableOperator op)
final void	NullaryExecutableOpBase.execute(IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	BaseForExecOpParallelBindJoin.handleCollectedSolMaps(IntermediateResultElementSink sink)	Makes sure that all the input solution mappings collected so far are joined with the retrieved solution mappings in BaseForExecOpParallelBindJoin.fullResult; resulting solution mappings are send to the given sink.
protected CompletableFuture<?>[]	BaseForExecOpIndexNestedLoopsJoinWithRequestOps.initiateProcessing(List<SolutionMapping> input, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected CompletableFuture<?>	BaseForExecOpIndexNestedLoopsJoinWithRequestOps.initiateProcessing(SolutionMapping sm, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	BaseForExecOpParallelBindJoin.initiateProcessingOfBatches(IntermediateResultElementSink sink, QueryProcContextExt ctx)	Issues a bind-join request for every *full* batch of solution mappings that has been created from the given input solution mappings up to this point.
protected long	BaseForExecOpParallelBindJoin.innerJoin(Iterable<SolutionMapping> left, Iterable<SolutionMapping> right, IntermediateResultElementSink sink)
protected void	ExecOpLookupJoinViaWrapperWithParamVars.join(Iterable<SolutionMapping> solmaps1, Iterable<SolutionMapping> solmaps2, IntermediateResultElementSink sink)	Joins the given sets of solution mappings and sends the result to the given sink.
protected void	ExecOpLookupJoinViaWrapperWithParamVars.join(Iterable<SolutionMapping> solmaps, SolutionMapping sm, IntermediateResultElementSink sink)	Joins the given set of solution mappings with a singleton set that contains the single given solution mapping, and sends the result to the given sink.
protected void	BaseForExecOpParallelBindJoin.joinInFullRetrievalMode(Iterable<SolutionMapping> batchOfSolMaps, IntermediateResultElementSink sink)
protected void	BaseForExecOpParallelBindJoin.joinInFullRetrievalMode(SolutionMapping inputSolMap, IntermediateResultElementSink sink)
protected void	BaseForExecOpSequentialBindJoin.joinInFullRetrievalMode(Iterable<SolutionMapping> batchOfSolMaps, IntermediateResultElementSink sink)
protected void	BaseForExecOpSequentialBindJoin.joinInFullRetrievalMode(SolutionMapping inputSolMap, IntermediateResultElementSink sink)
protected long	BaseForExecOpParallelBindJoin.leftOuterJoin(Iterable<SolutionMapping> left, Iterable<SolutionMapping> right, IntermediateResultElementSink sink)
protected void	ExecOpParallelMultiwayLeftJoin.mergePhase(Iterable<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink)
protected void	BaseForExecOpSequentialBindJoin.performRequestAndHandleResponse(IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpSequentialBindJoinSPARQLwithVALUESorFILTER.performRequestAndHandleResponse(IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpRequestOther.process(String data, IntermediateResultElementSink sink)
protected void	ExecOpRequestSPARQL.process(SolMapsResponse response, IntermediateResultElementSink sink)
final void	UnaryExecutableOpBase.process(List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, QueryProcContextExt ctx)
final void	UnaryExecutableOpBase.process(SolutionMapping inputSolMap, IntermediateResultElementSink sink, QueryProcContextExt ctx)
final void	BinaryExecutableOpBase.processInputFromChild1(List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, QueryProcContextExt ctx)
final void	BinaryExecutableOpBase.processInputFromChild1(SolutionMapping inputSolMap, IntermediateResultElementSink sink, QueryProcContextExt ctx)
final void	BinaryExecutableOpBase.processInputFromChild2(List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, QueryProcContextExt ctx)
final void	BinaryExecutableOpBase.processInputFromChild2(SolutionMapping inputSolMap, IntermediateResultElementSink sink, QueryProcContextExt ctx)
final void	NaryExecutableOpBase.processInputFromXthChild(int x, List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, QueryProcContextExt ctx)
final void	NaryExecutableOpBase.processInputFromXthChild(int x, SolutionMapping inputSolMap, IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	BaseForExecOpParallelBindJoin.switchToFullRetrievalMode(IntermediateResultElementSink sink, QueryProcContextExt ctx)	Performs a request to retrieve all solution mappings for the query of this operator (see BaseForExecOpParallelBindJoin.createExecutableReqOpForAll()), puts the retrieved solution mappings into BaseForExecOpParallelBindJoin.fullResult, and joins these retrieved solution mappings with all the input solution mappings collected so far; resulting solution mappings are send to the given sink.
protected void	ExecOpUnfold.unfoldList(org.apache.jena.graph.impl.LiteralLabel lit, SolutionMapping inputSolMap, IntermediateResultElementSink sink)
protected void	ExecOpUnfold.unfoldMap(org.apache.jena.graph.impl.LiteralLabel lit, SolutionMapping smIn, IntermediateResultElementSink sink)
final void	BinaryExecutableOpBase.wrapUpForChild1(IntermediateResultElementSink sink, QueryProcContextExt ctx)
final void	BinaryExecutableOpBase.wrapUpForChild2(IntermediateResultElementSink sink, QueryProcContextExt ctx)
final void	NaryExecutableOpBase.wrapUpForXthChild(int x, IntermediateResultElementSink sink, QueryProcContextExt ctx)

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

Modifier	Constructor	Description
	MyIntermediateResultElementSink(IntermediateResultElementSink outputSink, SolutionMapping smFromInput)
	MyIntermediateResultElementSinkOuterJoin(IntermediateResultElementSink outputSink, SolutionMapping smFromInput)
	MyResponseProcessor(SolutionMapping sm, IntermediateResultElementSink sink, ExecutableOperator op)
	MyResponseProcessor(List<SolutionMapping> solMapsCoveredByBatch, IntermediateResultElementSink sink)
	MyResponseProcessor(Map<String,org.apache.jena.graph.Node> paramValues, List<SolutionMapping> solmaps, IntermediateResultElementSink sink, ExecutableOperator op)

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	PushBasedPlanThreadImplBase	Contains the core part of implementing PushBasedPlanThread.
class	PushBasedPlanThreadImplForBinaryOperator
class	PushBasedPlanThreadImplForNaryOperator
class	PushBasedPlanThreadImplForNullaryOperator
class	PushBasedPlanThreadImplForUnaryOperator

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	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	PushBasedPlanThreadImplForBinaryOperator.produceOutputByConsumingInput2First(IntermediateResultElementSink sink)	Consumes the complete child 2 input first (and pushes that input to the operator PushBasedPlanThreadImplForBinaryOperator.op), before moving on to the input from child 1.
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.