Uses of Interface
se.liu.ida.hefquin.engine.queryproc.QueryProcContextExt

Packages that use QueryProcContextExt

Package	Description
se.liu.ida.hefquin.engine.queryplan.executable
se.liu.ida.hefquin.engine.queryplan.executable.impl.iterbased
se.liu.ida.hefquin.engine.queryplan.executable.impl.ops
se.liu.ida.hefquin.engine.queryplan.executable.impl.pushbased
se.liu.ida.hefquin.engine.queryproc
se.liu.ida.hefquin.engine.queryproc.impl
se.liu.ida.hefquin.engine.queryproc.impl.compiler
se.liu.ida.hefquin.engine.queryproc.impl.planning
se.liu.ida.hefquin.engine.queryproc.impl.poptimizer
se.liu.ida.hefquin.engine.queryproc.impl.poptimizer.simple

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

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

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

Fields in se.liu.ida.hefquin.engine.queryplan.executable.impl.iterbased declared as QueryProcContextExt

Modifier and Type	Field	Description
protected final QueryProcContextExt	ResultElementIterBase.ctx

Constructors in se.liu.ida.hefquin.engine.queryplan.executable.impl.iterbased with parameters of type QueryProcContextExt

Modifier	Constructor	Description
protected	ResultElementIterBase(QueryProcContextExt ctx)
	ResultElementIterWithBinaryExecOp(BinaryExecutableOp op, ResultElementIterator inputIter1, ResultElementIterator inputIter2, QueryProcContextExt ctx)
	ResultElementIterWithNullaryExecOp(NullaryExecutableOp op, QueryProcContextExt ctx)
	ResultElementIterWithUnaryExecOp(UnaryExecutableOp op, ResultElementIterator inputIter, QueryProcContextExt ctx)

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

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

Modifier and Type	Field	Description
protected final QueryProcContextExt	ExecOpParallelMultiwayLeftJoin.Worker.ctx

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

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 Runnable	BaseForExecOpIndexNestedLoopsJoinWithRequestOps.createProcessor(NullaryExecutableOp reqOp, SolutionMapping smFromInput, IntermediateResultElementSink outputSink, QueryProcContextExt ctx)
final void	NullaryExecutableOpBase.execute(IntermediateResultElementSink sink, QueryProcContextExt ctx)
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 void	BaseForExecOpParallelBindJoin.obtainFullResult(QueryProcContextExt ctx)	Performs a request to retrieve all solution mappings for the query of this operator (see BaseForExecOpParallelBindJoin.createExecutableReqOpForAll()) and puts the retrieved solution mappings into BaseForExecOpParallelBindJoin.fullResult.
protected void	ExecOpParallelMultiwayLeftJoin.parallelPhase(List<SolutionMapping> inputForParallelProcess, QueryProcContextExt ctx)
protected List<SolutionMapping>	ExecOpLookupJoinViaWrapperWithoutParamVars.performRequest(QueryProcContextExt ctx)
protected void	BaseForExecOpSequentialBindJoin.performRequestAndHandleResponse(IntermediateResultElementSink sink, QueryProcContextExt ctx)
protected void	ExecOpSequentialBindJoinSPARQLwithVALUESorFILTER.performRequestAndHandleResponse(IntermediateResultElementSink sink, QueryProcContextExt ctx)
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	BaseForExecOpSequentialBindJoin.switchToFullRetrievalMode(QueryProcContextExt ctx)	Performs a request to retrieve all solution mappings for the query of this operator (see BaseForExecOpSequentialBindJoin.createExecutableReqOpForAll()) and puts the retrieved solution mappings into BaseForExecOpSequentialBindJoin.fullResult.
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 QueryProcContextExt

Modifier	Constructor	Description
	Worker(LogicalOpRequest<?,?> req, SolutionMappingsIndex index, List<SolutionMapping> input, ExpectedVariables inputVarsFromNonOptionalPart, QueryProcContextExt ctx, boolean mayReduce)

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

Fields in se.liu.ida.hefquin.engine.queryplan.executable.impl.pushbased declared as QueryProcContextExt

Modifier and Type	Field	Description
protected final QueryProcContextExt	PushBasedPlanThreadImplBase.ctx

Constructors in se.liu.ida.hefquin.engine.queryplan.executable.impl.pushbased with parameters of type QueryProcContextExt

Modifier	Constructor	Description
protected	ConnectorForAdditionalConsumer(QueryProcContextExt ctx)
	PushBasedExecutablePlanImpl(LinkedList<PushBasedPlanThread> tasks, QueryProcContextExt ctx)
protected	PushBasedPlanThreadImplBase(QueryProcContextExt ctx)
	PushBasedPlanThreadImplForBinaryOperator(BinaryExecutableOp op, PushBasedPlanThread input1, PushBasedPlanThread input2, QueryProcContextExt ctx)
	PushBasedPlanThreadImplForNaryOperator(NaryExecutableOp op, PushBasedPlanThread[] inputs, QueryProcContextExt ctx)
	PushBasedPlanThreadImplForNullaryOperator(NullaryExecutableOp op, QueryProcContextExt ctx)
	PushBasedPlanThreadImplForUnaryOperator(UnaryExecutableOp op, PushBasedPlanThread input, QueryProcContextExt ctx)

Uses of QueryProcContextExt in se.liu.ida.hefquin.engine.queryproc

Methods in se.liu.ida.hefquin.engine.queryproc with parameters of type QueryProcContextExt

Modifier and Type	Method	Description
ExecutablePlan	QueryPlanCompiler.compile(PhysicalPlan qep, QueryProcContextExt ctx)
Pair<PhysicalPlan,QueryPlanningStats>	QueryPlanner.createPlan(Query query, QueryProcContextExt ctx)
Pair<PhysicalPlan,PhysicalOptimizationStats>	PhysicalOptimizer.optimize(LogicalPlan initialPlan, QueryProcContextExt ctx)

Uses of QueryProcContextExt in se.liu.ida.hefquin.engine.queryproc.impl

Classes in se.liu.ida.hefquin.engine.queryproc.impl that implement QueryProcContextExt

Modifier and Type	Class	Description
protected class	QueryProcessorImpl.MyQueryProcContextExt

Methods in se.liu.ida.hefquin.engine.queryproc.impl with parameters of type QueryProcContextExt

Modifier and Type	Method	Description
protected QueryProcessingStatsAndExceptions	QueryProcessorImpl.processQuery(Query query, QueryResultSink resultSink, QueryProcContextExt ctx)

Uses of QueryProcContextExt in se.liu.ida.hefquin.engine.queryproc.impl.compiler

Methods in se.liu.ida.hefquin.engine.queryproc.impl.compiler with parameters of type QueryProcContextExt

Modifier and Type	Method	Description
protected ResultElementIterator	QueryPlanCompilerForIteratorBasedExecution._compile(PhysicalPlan qep, QueryProcContextExt ctx)
protected PushBasedPlanThread	QueryPlanCompilerForPushBasedExecution.Worker._createThreads(PhysicalPlan qep, LinkedList<PushBasedPlanThread> tasks, QueryProcContextExt ctx)
ExecutablePlan	QueryPlanCompilerForIteratorBasedExecution.compile(PhysicalPlan qep, QueryProcContextExt ctx)
ExecutablePlan	QueryPlanCompilerForPushBasedExecution.compile(PhysicalPlan qep, QueryProcContextExt ctx)
protected PushBasedPlanThread	QueryPlanCompilerForPushBasedExecution.createThread(BinaryExecutableOp op, PushBasedPlanThread input1, PushBasedPlanThread input2, QueryProcContextExt ctx)
protected PushBasedPlanThread	QueryPlanCompilerForPushBasedExecution.createThread(NaryExecutableOp op, PushBasedPlanThread[] inputs, QueryProcContextExt ctx)
protected PushBasedPlanThread	QueryPlanCompilerForPushBasedExecution.createThread(NullaryExecutableOp op, QueryProcContextExt ctx)
protected PushBasedPlanThread	QueryPlanCompilerForPushBasedExecution.createThread(UnaryExecutableOp op, PushBasedPlanThread input, QueryProcContextExt ctx)
protected LinkedList<PushBasedPlanThread>	QueryPlanCompilerForPushBasedExecution.createThreads(PhysicalPlan qep, QueryProcContextExt ctx)
void	QueryPlanCompilerForPushBasedExecution.Worker.createThreads(PhysicalPlan qep, LinkedList<PushBasedPlanThread> threads, QueryProcContextExt ctx)

Uses of QueryProcContextExt in se.liu.ida.hefquin.engine.queryproc.impl.planning

Methods in se.liu.ida.hefquin.engine.queryproc.impl.planning with parameters of type QueryProcContextExt

Modifier and Type	Method	Description
Pair<PhysicalPlan,QueryPlanningStats>	QueryPlannerImpl.createPlan(Query query, QueryProcContextExt ctx)

Uses of QueryProcContextExt in se.liu.ida.hefquin.engine.queryproc.impl.poptimizer

Methods in se.liu.ida.hefquin.engine.queryproc.impl.poptimizer with parameters of type QueryProcContextExt

Modifier and Type	Method	Description
final Pair<PhysicalPlan,PhysicalOptimizationStats>	PhysicalOptimizerBase.optimize(LogicalPlan lp, QueryProcContextExt ctx)
protected abstract Pair<PhysicalPlan,PhysicalOptimizationStats>	PhysicalOptimizerBase.optimize(PhysicalPlan initialPhysicalPlan, QueryProcContextExt ctx)
protected Pair<PhysicalPlan,PhysicalOptimizationStats>	PhysicalOptimizerWithoutOptimization.optimize(PhysicalPlan initialPlan, QueryProcContextExt ctx)

Uses of QueryProcContextExt in se.liu.ida.hefquin.engine.queryproc.impl.poptimizer.simple

Fields in se.liu.ida.hefquin.engine.queryproc.impl.poptimizer.simple declared as QueryProcContextExt

Modifier and Type	Field	Description
protected final QueryProcContextExt	CardinalityBasedGreedyJoinPlanOptimizerImpl.GreedyConstructionAlgorithm.ctx
protected final QueryProcContextExt	CostModelBasedGreedyJoinPlanOptimizerImpl.GreedyEnumerationAlgorithm.ctx
protected final QueryProcContextExt	DPBasedJoinPlanOptimizer.DynamicProgrammingOptimizerImpl.ctx

Methods in se.liu.ida.hefquin.engine.queryproc.impl.poptimizer.simple with parameters of type QueryProcContextExt

Modifier and Type	Method	Description
PhysicalPlan	JoinPlanOptimizer.determineJoinPlan(List<PhysicalPlan> subplans, QueryProcContextExt ctx)	Returns a plan that combines the given subplans using binary joins.
default PhysicalPlan	JoinPlanOptimizer.determineJoinPlan(PhysicalPlan[] subplans, QueryProcContextExt ctx)	Returns a plan that combines the given subplans using binary joins.
final PhysicalPlan	JoinPlanOptimizerBase.determineJoinPlan(List<PhysicalPlan> subplans, QueryProcContextExt ctx)
PhysicalPlan	RandomizedJoinPlanOptimizerImpl.determineJoinPlan(List<PhysicalPlan> subplans, QueryProcContextExt ctx)
protected boolean	DPBasedJoinPlanOptimizer.determineOptimalCandidatesAtStageN(List<List<PhysicalPlan>> subsets, DPBasedJoinPlanOptimizer.OptimalPlansPerStage optPlansPerStage, boolean ignoreCartesianProductJoins, QueryProcContextExt ctx)	For each of the sets of plans in 'subsets', determines the best possible join plan and adds this best plan to 'optPlansPerStage'.
protected PhysicalPlan[]	SimpleJoinOrderingQueryOptimizer.getOptimizedSubPlans(PhysicalPlan plan, QueryProcContextExt ctx)
JoinPlanOptimizerBase.EnumerationAlgorithm	CardinalityBasedGreedyJoinPlanOptimizerImpl.initializeEnumerationAlgorithm(List<PhysicalPlan> subplans, QueryProcContextExt ctx)
JoinPlanOptimizerBase.EnumerationAlgorithm	CostModelBasedGreedyJoinPlanOptimizerImpl.initializeEnumerationAlgorithm(List<PhysicalPlan> subplans, QueryProcContextExt ctx)
protected JoinPlanOptimizerBase.EnumerationAlgorithm	DPBasedJoinPlanOptimizer.initializeEnumerationAlgorithm(List<PhysicalPlan> subplans, QueryProcContextExt ctx)
protected abstract JoinPlanOptimizerBase.EnumerationAlgorithm	JoinPlanOptimizerBase.initializeEnumerationAlgorithm(List<PhysicalPlan> subplans, QueryProcContextExt ctx)
Pair<PhysicalPlan,PhysicalOptimizationStats>	SimpleJoinOrderingQueryOptimizer.optimize(PhysicalPlan initialPlan, QueryProcContextExt ctx)
PhysicalPlan	SimpleJoinOrderingQueryOptimizer.optimizePlan(PhysicalPlan plan, QueryProcContextExt ctx)

Constructors in se.liu.ida.hefquin.engine.queryproc.impl.poptimizer.simple with parameters of type QueryProcContextExt

Modifier	Constructor	Description
	DynamicProgrammingOptimizerImpl(List<PhysicalPlan> subplans, QueryProcContextExt ctx)
	GreedyConstructionAlgorithm(List<PhysicalPlan> subplans, QueryProcContextExt ctx)
	GreedyEnumerationAlgorithm(List<PhysicalPlan> subplans, QueryProcContextExt ctx)