Class QueryPlanCompilerForPushBasedExecution

java.lang.Object

se.liu.ida.hefquin.engine.queryproc.impl.compiler.QueryPlanCompilerForPushBasedExecution

All Implemented Interfaces:

QueryPlanCompiler

public class QueryPlanCompilerForPushBasedExecution
extends Object
implements QueryPlanCompiler

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	QueryPlanCompilerForPushBasedExecution.Worker

Constructor Summary

Constructors

Constructor	Description
QueryPlanCompilerForPushBasedExecution()

Method Summary

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

QueryPlanCompilerForPushBasedExecution

public QueryPlanCompilerForPushBasedExecution()

Method Details

compile

public ExecutablePlan compile(PhysicalPlan qep,
 QueryProcContextExt ctx)

Specified by:

compile in interface QueryPlanCompiler

createThreads

protected LinkedList<PushBasedPlanThread> createThreads(PhysicalPlan qep,
 QueryProcContextExt ctx)

createWorker

protected QueryPlanCompilerForPushBasedExecution.Worker createWorker()

createThread

protected PushBasedPlanThread createThread(NullaryExecutableOp op,
 QueryProcContextExt ctx)

createThread

protected PushBasedPlanThread createThread(UnaryExecutableOp op,
 PushBasedPlanThread input,
 QueryProcContextExt ctx)

createThread

protected PushBasedPlanThread createThread(BinaryExecutableOp op,
 PushBasedPlanThread input1,
 PushBasedPlanThread input2,
 QueryProcContextExt ctx)

createThread

protected PushBasedPlanThread createThread(NaryExecutableOp op,
 PushBasedPlanThread[] inputs,
 QueryProcContextExt ctx)