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

Packages that use ExecutionContext

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.impl
se.liu.ida.hefquin.engine.queryproc.impl.compiler

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

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

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.
default void	UnaryExecutableOp.process(List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, ExecutionContext execCxt)	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, ExecutionContext execCxt)	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, ExecutionContext execCxt)	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, ExecutionContext execCxt)	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, ExecutionContext execCxt)	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, ExecutionContext execCxt)	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, ExecutionContext execCxt)	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, ExecutionContext execCxt)	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, 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 ExecutionContext in se.liu.ida.hefquin.engine.queryplan.executable.impl.iterbased

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

Modifier and Type	Field	Description
protected final ExecutionContext	ResultElementIterBase.execCxt

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

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

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

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

Modifier and Type	Field	Description
protected final ExecutionContext	ExecOpParallelMultiwayLeftJoin.Worker.execCxt

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

Modifier and Type	Method	Description
protected void	BaseForExecOpIndexNestedLoopsJoinWithRequestOps._concludeExecution(List<SolutionMapping> input, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	BaseForExecOpIndexNestedLoopsJoinWithRequests._concludeExecution(List<SolutionMapping> input, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	BaseForExecOpParallelBindJoin._concludeExecution(List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	BaseForExecOpSequentialBindJoin._concludeExecution(IntermediateResultElementSink sink, ExecutionContext execCxt)
protected abstract void	BaseForUnaryExecOpWithCollectedInput._concludeExecution(List<SolutionMapping> currentBatch, IntermediateResultElementSink sink, ExecutionContext execCxt)	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, ExecutionContext execCxt)
protected void	ExecOpBind._concludeExecution(IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpDuplicateRemoval._concludeExecution(IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpFilter._concludeExecution(IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpGlobalToLocal._concludeExecution(IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpLocalToGlobal._concludeExecution(IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpLookupJoinViaWrapperWithoutParamVars._concludeExecution(IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpLookupJoinViaWrapperWithParamVars._concludeExecution(List<SolutionMapping> input, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpParallelMultiwayLeftJoin._concludeExecution(List<SolutionMapping> batch, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpUnfold._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 void	BaseForExecOpTriplesRequest._execute(IntermediateResultElementSink sink, ExecutionContext execCxt)
protected final void	ExecOpRequestOther._execute(IntermediateResultElementSink sink, ExecutionContext execCxt)
protected final void	ExecOpRequestSPARQL._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	BaseForExecOpSequentialBindJoin._process(SolutionMapping inputSolMap, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected final void	BaseForUnaryExecOpWithCollectedInput._process(List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected final void	BaseForUnaryExecOpWithCollectedInput._process(SolutionMapping inputSolMap, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpBind._process(Iterator<SolutionMapping> inputSolMaps, int maxBatchSize, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpBind._process(SolutionMapping inputSolMap, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpDuplicateRemoval._process(SolutionMapping inputSolMap, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpFilter._process(Iterator<SolutionMapping> inputSolMaps, int maxBatchSize, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpFilter._process(SolutionMapping inputSolMap, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpGlobalToLocal._process(Iterator<SolutionMapping> inputSolMaps, int maxBatchSize, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpGlobalToLocal._process(SolutionMapping inputSolMap, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpLocalToGlobal._process(Iterator<SolutionMapping> inputSolMaps, int maxBatchSize, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpLocalToGlobal._process(SolutionMapping inputSolMap, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpLookupJoinViaWrapperWithoutParamVars._process(SolutionMapping inputSM, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpUnfold._process(SolutionMapping inputSolMap, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	UnaryExecutableOpBase._process(List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, ExecutionContext execCxt)	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, ExecutionContext execCxt)	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, ExecutionContext execCxt)	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, ExecutionContext execCxt)
protected void	BaseForExecOpIndexNestedLoopsJoinWithRequestOps._processCollectedInput(List<SolutionMapping> input, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	BaseForExecOpIndexNestedLoopsJoinWithRequests._processCollectedInput(List<SolutionMapping> input, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	BaseForExecOpParallelBindJoin._processCollectedInput(List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected abstract void	BaseForUnaryExecOpWithCollectedInput._processCollectedInput(List<SolutionMapping> currentBatch, IntermediateResultElementSink sink, ExecutionContext execCxt)	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, ExecutionContext execCxt)
protected void	ExecOpParallelMultiwayLeftJoin._processCollectedInput(List<SolutionMapping> input, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	BinaryExecutableOpBase._processInputFromChild1(List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, ExecutionContext execCxt)	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, ExecutionContext execCxt)	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, ExecutionContext execCxt)
protected void	ExecOpBinaryUnion._processInputFromChild1(SolutionMapping inputSolMap, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpHashJoin._processInputFromChild1(SolutionMapping inputSolMap, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpNaiveNestedLoopsJoin._processInputFromChild1(SolutionMapping inputSolMap, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpSymmetricHashJoin._processInputFromChild1(List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpSymmetricHashJoin._processInputFromChild1(SolutionMapping inputSolMap, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	BinaryExecutableOpBase._processInputFromChild2(List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, ExecutionContext execCxt)	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, ExecutionContext execCxt)	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, ExecutionContext execCxt)
protected void	ExecOpBinaryUnion._processInputFromChild2(SolutionMapping inputSolMap, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpHashJoin._processInputFromChild2(List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpHashJoin._processInputFromChild2(SolutionMapping inputSolMap, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpNaiveNestedLoopsJoin._processInputFromChild2(List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpNaiveNestedLoopsJoin._processInputFromChild2(SolutionMapping inputSolMap, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpSymmetricHashJoin._processInputFromChild2(List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpSymmetricHashJoin._processInputFromChild2(SolutionMapping inputSolMap, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpMultiwayUnion._processInputFromXthChild(int x, List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpMultiwayUnion._processInputFromXthChild(int x, SolutionMapping inputSolMap, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	NaryExecutableOpBase._processInputFromXthChild(int x, List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, ExecutionContext execCxt)	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, ExecutionContext execCxt)	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, ExecutionContext execCxt)	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, 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.
protected void	BaseForExecOpParallelBindJoin.batchUp(SolutionMapping inputSolMap, IntermediateResultElementSink sink, ExecutionContext execCxt)
final void	UnaryExecutableOpBase.concludeExecution(IntermediateResultElementSink sink, ExecutionContext execCxt)
protected Runnable	BaseForExecOpIndexNestedLoopsJoinWithRequestOps.createProcessor(NullaryExecutableOp reqOp, SolutionMapping smFromInput, IntermediateResultElementSink outputSink, ExecutionContext execCxt)
final void	NullaryExecutableOpBase.execute(IntermediateResultElementSink sink, ExecutionContext execCxt)
protected CompletableFuture<?>[]	BaseForExecOpIndexNestedLoopsJoinWithRequestOps.initiateProcessing(List<SolutionMapping> input, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected CompletableFuture<?>	BaseForExecOpIndexNestedLoopsJoinWithRequestOps.initiateProcessing(SolutionMapping sm, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	BaseForExecOpParallelBindJoin.initiateProcessingOfBatches(IntermediateResultElementSink sink, ExecutionContext execCxt)	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(ExecutionContext execCxt)	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, ExecutionContext execCxt)
protected List<SolutionMapping>	ExecOpLookupJoinViaWrapperWithoutParamVars.performRequest(ExecutionContext execCxt)
protected void	BaseForExecOpSequentialBindJoin.performRequestAndHandleResponse(IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpSequentialBindJoinSPARQLwithVALUESorFILTER.performRequestAndHandleResponse(IntermediateResultElementSink sink, ExecutionContext execCxt)
final void	UnaryExecutableOpBase.process(List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, ExecutionContext execCxt)
final void	UnaryExecutableOpBase.process(SolutionMapping inputSolMap, IntermediateResultElementSink sink, ExecutionContext execCxt)
final void	BinaryExecutableOpBase.processInputFromChild1(List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, ExecutionContext execCxt)
final void	BinaryExecutableOpBase.processInputFromChild1(SolutionMapping inputSolMap, IntermediateResultElementSink sink, ExecutionContext execCxt)
final void	BinaryExecutableOpBase.processInputFromChild2(List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, ExecutionContext execCxt)
final void	BinaryExecutableOpBase.processInputFromChild2(SolutionMapping inputSolMap, IntermediateResultElementSink sink, ExecutionContext execCxt)
final void	NaryExecutableOpBase.processInputFromXthChild(int x, List<SolutionMapping> inputSolMaps, IntermediateResultElementSink sink, ExecutionContext execCxt)
final void	NaryExecutableOpBase.processInputFromXthChild(int x, SolutionMapping inputSolMap, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	BaseForExecOpParallelBindJoin.switchToFullRetrievalMode(ExecutionContext execCxt, IntermediateResultElementSink sink)	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(ExecutionContext execCxt)	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, 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 ExecutionContext

Modifier	Constructor	Description
	Worker(LogicalOpRequest<?,?> req, SolutionMappingsIndex index, List<SolutionMapping> input, ExpectedVariables inputVarsFromNonOptionalPart, ExecutionContext execCxt)

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

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

Modifier and Type	Field	Description
protected final ExecutionContext	PushBasedPlanThreadImplBase.execCxt

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

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

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

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

Modifier and Type	Class	Description
class	ExecutionContextImpl

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

Methods in se.liu.ida.hefquin.engine.queryproc.impl.compiler that return ExecutionContext

Modifier and Type	Method	Description
protected ExecutionContext	QueryPlanCompilerBase.createExecContext()

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

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