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
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.pullbased
se.liu.ida.hefquin.engine.queryplan.executable.impl.pushbased
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.
void	UnaryExecutableOp.process(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)	Processes the given input and sends the produced result elements (if any) to the given sink.
void	BinaryExecutableOp.processBlockFromChild1(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)	Processes the given input coming from the first operand and sends the produced result elements (if any) to the given sink.
void	BinaryExecutableOp.processBlockFromChild2(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)	Processes the given input coming from the second operand and sends the produced result elements (if any) to the given sink.
void	NaryExecutableOp.processBlockFromXthChild(int x, IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)	Processes the given input coming from the x-th operand and sends the produced result elements (if any) to the given sink.
void	BinaryExecutableOp.wrapUpForChild1(IntermediateResultElementSink sink, ExecutionContext execCxt)	Finishes up any processing related to the input coming from the first operand and sends the remaining result elements (if any) to the given sink.
void	BinaryExecutableOp.wrapUpForChild2(IntermediateResultElementSink sink, ExecutionContext execCxt)	Finishes up any processing related to the input coming from the second operand and sends the remaining result elements (if any) to the given sink.
void	NaryExecutableOp.wrapUpForXthChild(int x, IntermediateResultElementSink sink, ExecutionContext execCxt)	Finishes up any processing related to the input coming from the x-th operand and sends the remaining result elements (if any) to the given sink.

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

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

Modifier and Type	Field	Description
protected final ExecutionContext	ExecPlanTaskBase.execCxt

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

Modifier	Constructor	Description
protected	ExecPlanTaskBase(ExecutionContext execCxt, int preferredMinimumBlockSize)
	TaskBasedExecutablePlanImpl(LinkedList<ExecPlanTask> tasks, ExecutionContext ctx)

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, ResultBlockIterator inputIter1, ResultBlockIterator inputIter2, ExecutionContext execCxt)
	ResultElementIterWithNullaryExecOp(NullaryExecutableOp op, ExecutionContext execCxt)
	ResultElementIterWithUnaryExecOp(UnaryExecutableOp op, ResultBlockIterator 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	BaseForExecOpBindJoin._concludeExecution(IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	BaseForExecOpIndexNestedLoopsJoin._concludeExecution(IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpParallelMultiwayLeftJoin._concludeExecution(IntermediateResultElementSink sink, ExecutionContext execCxt)
protected abstract void	UnaryExecutableOpBase._concludeExecution(IntermediateResultElementSink sink, ExecutionContext execCxt)	Implementations of this function need to conclude the execution of this operator and send the remaining result elements (if any) to the given sink.
protected void	UnaryExecutableOpBaseWithIterator._concludeExecution(IntermediateResultElementSink sink, ExecutionContext execCxt)
protected final void	BaseForExecOpRequestWithPaging._execute(IntermediateResultElementSink sink, ExecutionContext execCxt)
protected final void	BaseForExecOpRequestWithTPFPaging._execute(IntermediateResultElementSink sink, ExecutionContext execCxt)
protected final void	BaseForExecOpSolMapsRequest._execute(IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	BaseForExecOpTriplesRequest._execute(IntermediateResultElementSink sink, ExecutionContext execCxt)
protected abstract void	NullaryExecutableOpBase._execute(IntermediateResultElementSink sink, ExecutionContext execCxt)	Implementations of this function need to execute the algorithm of this operator and send the result elements (if any) to the given sink.
protected void	BaseForExecOpBindJoinWithRequestOps._process(Iterable<SolutionMapping> joinableInputSMs, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	BaseForExecOpBindJoinWithRequestOps._process(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	BaseForExecOpIndexNestedLoopsJoinWithRequestOps._process(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	BaseForExecOpIndexNestedLoopsJoinWithRequests._process(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpParallelMultiwayLeftJoin._process(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected abstract void	UnaryExecutableOpBase._process(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)	Implementations of this function need to process the given input block and send the produced result elements (if any) to the given sink.
protected void	UnaryExecutableOpBaseWithIterator._process(Iterator<SolutionMapping> output, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	UnaryExecutableOpBaseWithIterator._process(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected abstract void	BinaryExecutableOpBase._processBlockFromChild1(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)	Implementations of this function need to process the given input block coming from the first operand and send the produced result elements (if any) to the given sink.
protected void	ExecOpBinaryUnion._processBlockFromChild1(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpHashJoin._processBlockFromChild1(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpNaiveNestedLoopsJoin._processBlockFromChild1(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpSymmetricHashJoin._processBlockFromChild1(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected abstract void	BinaryExecutableOpBase._processBlockFromChild2(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)	Implementations of this function need to process the given input block coming from the second operand and send the produced result elements (if any) to the given sink.
protected void	ExecOpBinaryUnion._processBlockFromChild2(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpHashJoin._processBlockFromChild2(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpNaiveNestedLoopsJoin._processBlockFromChild2(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpSymmetricHashJoin._processBlockFromChild2(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpMultiwayUnion._processBlockFromXthChild(int x, IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected abstract void	NaryExecutableOpBase._processBlockFromXthChild(int x, IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)	Implementations of this function need to process the given input block coming from the x-th operand and send the produced result elements (if any) to the given sink.
protected void	ExecOpHashJoin._processSolMapFromChild2(SolutionMapping smR, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpHashRJoin._processSolMapFromChild2(SolutionMapping smR, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	BaseForExecOpBindJoinWithRequestOps._processWithoutSplittingInputFirst(List<SolutionMapping> joinableInputSMs, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected abstract void	BinaryExecutableOpBase._wrapUpForChild1(IntermediateResultElementSink sink, ExecutionContext execCxt)	Implementations of this function need to finish up any processing related to the input coming from the first operand and send the remaining result elements (if any) to the given sink.
protected void	ExecOpBinaryUnion._wrapUpForChild1(IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpHashJoin._wrapUpForChild1(IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpNaiveNestedLoopsJoin._wrapUpForChild1(IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpSymmetricHashJoin._wrapUpForChild1(IntermediateResultElementSink sink, ExecutionContext execCxt)
protected abstract void	BinaryExecutableOpBase._wrapUpForChild2(IntermediateResultElementSink sink, ExecutionContext execCxt)	Implementations of this function need to finish up any processing related to the input coming from the second operand and send the remaining result elements (if any) to the given sink.
protected void	ExecOpBinaryUnion._wrapUpForChild2(IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpHashJoin._wrapUpForChild2(IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpNaiveNestedLoopsJoin._wrapUpForChild2(IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpSymmetricHashJoin._wrapUpForChild2(IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpMultiwayUnion._wrapUpForXthChild(int x, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected abstract void	NaryExecutableOpBase._wrapUpForXthChild(int x, IntermediateResultElementSink sink, ExecutionContext execCxt)	Implementations of this function need to finish up any processing related to the input coming from the x-th operand and send the remaining result elements (if any) to the given sink.
final void	UnaryExecutableOpBase.concludeExecution(IntermediateResultElementSink sink, ExecutionContext execCxt)
protected Runnable	BaseForExecOpIndexNestedLoopsJoinWithRequestOps.createProcessor(NullaryExecutableOp reqOp, SolutionMapping smFromInput, IntermediateResultElementSink outputSink, ExecutionContext execCxt)
final void	NullaryExecutableOpBase.execute(IntermediateResultElementSink sink, ExecutionContext execCxt)
protected CompletableFuture<?>	BaseForExecOpIndexNestedLoopsJoinWithRequestOps.initiateProcessing(SolutionMapping sm, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected CompletableFuture<?>[]	BaseForExecOpIndexNestedLoopsJoinWithRequestOps.initiateProcessing(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)
protected void	ExecOpParallelMultiwayLeftJoin.parallelPhase(IntermediateResultBlock inputForParallelProcess, ExecutionContext execCxt)
final void	UnaryExecutableOpBase.process(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)
final void	BinaryExecutableOpBase.processBlockFromChild1(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)
final void	BinaryExecutableOpBase.processBlockFromChild2(IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)
final void	NaryExecutableOpBase.processBlockFromXthChild(int x, IntermediateResultBlock input, IntermediateResultElementSink sink, ExecutionContext execCxt)
final void	BinaryExecutableOpBase.wrapUpForChild1(IntermediateResultElementSink sink, ExecutionContext execCxt)
final void	BinaryExecutableOpBase.wrapUpForChild2(IntermediateResultElementSink sink, ExecutionContext execCxt)
final void	NaryExecutableOpBase.wrapUpForXthChild(int x, IntermediateResultElementSink sink, ExecutionContext execCxt)

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

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

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

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

Modifier	Constructor	Description
protected	PullBasedExecPlanTaskBase(ExecutionContext execCxt, int preferredMinimumBlockSize)
	PullBasedExecPlanTaskForBinaryOperator(BinaryExecutableOp op, ExecPlanTask input1, ExecPlanTask input2, ExecutionContext execCxt, int minimumBlockSize)
	PullBasedExecPlanTaskForNullaryOperator(NullaryExecutableOp op, ExecutionContext execCxt, int minimumBlockSize)
	PullBasedExecPlanTaskForUnaryOperator(UnaryExecutableOp op, ExecPlanTask input, ExecutionContext execCxt, int minimumBlockSize)

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

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

Modifier	Constructor	Description
protected	ConnectorForAdditionalConsumer(ExecutionContext execCxt, int preferredMinimumBlockSize)
protected	PushBasedExecPlanTaskBase(ExecutionContext execCxt, int preferredMinimumBlockSize)
	PushBasedExecPlanTaskForBinaryOperator(BinaryExecutableOp op, ExecPlanTask input1, ExecPlanTask input2, ExecutionContext execCxt, int minimumBlockSize)
	PushBasedExecPlanTaskForNaryOperator(NaryExecutableOp op, ExecPlanTask[] inputs, ExecutionContext execCxt, int minimumBlockSize)
	PushBasedExecPlanTaskForNullaryOperator(NullaryExecutableOp op, ExecutionContext execCxt, int minimumBlockSize)
	PushBasedExecPlanTaskForUnaryOperator(UnaryExecutableOp op, ExecPlanTask input, ExecutionContext execCxt, int minimumBlockSize)

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 ExecPlanTask	TaskBasedQueryPlanCompilerBase.Worker._createTasks(PhysicalPlan qep, LinkedList<ExecPlanTask> tasks, int preferredOutputBlockSize, ExecutionContext execCxt)
protected ResultElementIterator	IteratorBasedQueryPlanCompilerImpl.compile(PhysicalPlan qep, ExecutionContext execCxt)
protected ExecPlanTask	PullBasedQueryPlanCompilerImpl.createTaskForBinaryExecOp(BinaryExecutableOp op, ExecPlanTask childTask1, ExecPlanTask childTask2, ExecutionContext execCxt, int preferredOutputBlockSize)
protected PushBasedExecPlanTask	PushBasedQueryPlanCompilerImpl.createTaskForBinaryExecOp(BinaryExecutableOp op, ExecPlanTask childTask1, ExecPlanTask childTask2, ExecutionContext execCxt, int preferredOutputBlockSize)
protected abstract ExecPlanTask	TaskBasedQueryPlanCompilerBase.createTaskForBinaryExecOp(BinaryExecutableOp op, ExecPlanTask childTask1, ExecPlanTask childTask2, ExecutionContext execCxt, int preferredOutputBlockSize)
protected ExecPlanTask	PullBasedQueryPlanCompilerImpl.createTaskForNaryExecOp(NaryExecutableOp op, ExecPlanTask[] childTasks, ExecutionContext execCxt, int preferredOutputBlockSize)
protected ExecPlanTask	PushBasedQueryPlanCompilerImpl.createTaskForNaryExecOp(NaryExecutableOp op, ExecPlanTask[] childTasks, ExecutionContext execCxt, int preferredOutputBlockSize)
protected abstract ExecPlanTask	TaskBasedQueryPlanCompilerBase.createTaskForNaryExecOp(NaryExecutableOp op, ExecPlanTask[] childTasks, ExecutionContext execCxt, int preferredOutputBlockSize)
protected ExecPlanTask	PullBasedQueryPlanCompilerImpl.createTaskForNullaryExecOp(NullaryExecutableOp op, ExecutionContext execCxt, int preferredOutputBlockSize)
protected PushBasedExecPlanTask	PushBasedQueryPlanCompilerImpl.createTaskForNullaryExecOp(NullaryExecutableOp op, ExecutionContext execCxt, int preferredOutputBlockSize)
protected abstract ExecPlanTask	TaskBasedQueryPlanCompilerBase.createTaskForNullaryExecOp(NullaryExecutableOp op, ExecutionContext execCxt, int preferredOutputBlockSize)
protected ExecPlanTask	PullBasedQueryPlanCompilerImpl.createTaskForUnaryExecOp(UnaryExecutableOp op, ExecPlanTask childTask, ExecutionContext execCxt, int preferredOutputBlockSize)
protected PushBasedExecPlanTask	PushBasedQueryPlanCompilerImpl.createTaskForUnaryExecOp(UnaryExecutableOp op, ExecPlanTask childTask, ExecutionContext execCxt, int preferredOutputBlockSize)
protected abstract ExecPlanTask	TaskBasedQueryPlanCompilerBase.createTaskForUnaryExecOp(UnaryExecutableOp op, ExecPlanTask childTask, ExecutionContext execCxt, int preferredOutputBlockSize)
protected LinkedList<ExecPlanTask>	PushBasedQueryPlanCompilerImpl.createTasks(PhysicalPlan qep, ExecutionContext execCxt)
void	PushBasedQueryPlanCompilerImpl.Worker.createTasks(PhysicalPlan qep, LinkedList<ExecPlanTask> tasks, int preferredOutputBlockSize, ExecutionContext execCxt)
protected LinkedList<ExecPlanTask>	TaskBasedQueryPlanCompilerBase.createTasks(PhysicalPlan qep, ExecutionContext execCxt)
void	TaskBasedQueryPlanCompilerBase.Worker.createTasks(PhysicalPlan qep, LinkedList<ExecPlanTask> tasks, int preferredOutputBlockSize, ExecutionContext execCxt)