Uses of Interface
se.liu.ida.hefquin.engine.queryplan.executable.impl.pushbased.PushBasedPlanThread

Packages that use PushBasedPlanThread

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

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

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

Modifier and Type	Class	Description
class	ConnectorForAdditionalConsumer
class	PushBasedPlanThreadImplBase	Contains the core part of implementing PushBasedPlanThread.
class	PushBasedPlanThreadImplForBinaryOperator
class	PushBasedPlanThreadImplForNaryOperator
class	PushBasedPlanThreadImplForNullaryOperator
class	PushBasedPlanThreadImplForUnaryOperator

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

Modifier and Type	Field	Description
protected final PushBasedPlanThread	PushBasedPlanThreadImplForUnaryOperator.input
protected final PushBasedPlanThread	PushBasedPlanThreadImplForBinaryOperator.input1
protected final PushBasedPlanThread	PushBasedPlanThreadImplForBinaryOperator.input2
protected final PushBasedPlanThread[]	PushBasedPlanThreadImplForNaryOperator.inputs

Fields in se.liu.ida.hefquin.engine.queryplan.executable.impl.pushbased with type parameters of type PushBasedPlanThread

Modifier and Type	Field	Description
protected final LinkedList<PushBasedPlanThread>	PushBasedExecutablePlanImpl.tasks

Methods in se.liu.ida.hefquin.engine.queryplan.executable.impl.pushbased that return PushBasedPlanThread

Modifier and Type	Method	Description
PushBasedPlanThread	ConnectorForAdditionalConsumer.addConnectorForAdditionalConsumer()
PushBasedPlanThread	PushBasedPlanThread.addConnectorForAdditionalConsumer()	Can be used for cases in which multiple threads consume the output produced by this thread.
PushBasedPlanThread	PushBasedPlanThreadImplBase.addConnectorForAdditionalConsumer()

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

Modifier	Constructor	Description
	PushBasedPlanThreadImplForBinaryOperator(BinaryExecutableOp op, PushBasedPlanThread input1, PushBasedPlanThread input2, ExecutionContext execCxt)
	PushBasedPlanThreadImplForNaryOperator(NaryExecutableOp op, PushBasedPlanThread[] inputs, ExecutionContext execCxt)
	PushBasedPlanThreadImplForUnaryOperator(UnaryExecutableOp op, PushBasedPlanThread input, ExecutionContext execCxt)

Constructor parameters in se.liu.ida.hefquin.engine.queryplan.executable.impl.pushbased with type arguments of type PushBasedPlanThread

Modifier	Constructor	Description
	PushBasedExecutablePlanImpl(LinkedList<PushBasedPlanThread> tasks, ExecutionContext ctx)

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

Fields in se.liu.ida.hefquin.engine.queryproc.impl.compiler with type parameters of type PushBasedPlanThread

Modifier and Type	Field	Description
protected final Map<PhysicalPlan,PushBasedPlanThread>	QueryPlanCompilerForPushBasedExecution.Worker.convertedSubPlans

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

Modifier and Type	Method	Description
protected PushBasedPlanThread	QueryPlanCompilerForPushBasedExecution.Worker._createThreads(PhysicalPlan qep, LinkedList<PushBasedPlanThread> tasks, 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)

Methods in se.liu.ida.hefquin.engine.queryproc.impl.compiler that return types with arguments of type PushBasedPlanThread

Modifier and Type	Method	Description
protected LinkedList<PushBasedPlanThread>	QueryPlanCompilerForPushBasedExecution.createThreads(PhysicalPlan qep, ExecutionContext execCxt)

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

Modifier and Type	Method	Description
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(UnaryExecutableOp op, PushBasedPlanThread input, ExecutionContext execCxt)

Method parameters in se.liu.ida.hefquin.engine.queryproc.impl.compiler with type arguments of type PushBasedPlanThread

Modifier and Type	Method	Description
protected PushBasedPlanThread	QueryPlanCompilerForPushBasedExecution.Worker._createThreads(PhysicalPlan qep, LinkedList<PushBasedPlanThread> tasks, ExecutionContext execCxt)
void	QueryPlanCompilerForPushBasedExecution.Worker.createThreads(PhysicalPlan qep, LinkedList<PushBasedPlanThread> threads, ExecutionContext execCxt)