Class QueryPlanCompilerForPushBasedExecution

java.lang.Object

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

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

All Implemented Interfaces:

QueryPlanCompiler

public class QueryPlanCompilerForPushBasedExecution
extends QueryPlanCompilerBase

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	QueryPlanCompilerForPushBasedExecution.Worker

Field Summary

Fields inherited from class se.liu.ida.hefquin.engine.queryproc.impl.compiler.QueryPlanCompilerBase

ctxt

Constructor Summary

Constructors

Constructor	Description
QueryPlanCompilerForPushBasedExecution(QueryProcContext ctxt)

Method Summary

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

Methods inherited from class se.liu.ida.hefquin.engine.queryproc.impl.compiler.QueryPlanCompilerBase

createExecContext

Methods inherited from class java.lang.Object

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

Constructor Details

QueryPlanCompilerForPushBasedExecution

public QueryPlanCompilerForPushBasedExecution(QueryProcContext ctxt)

Method Details

compile

public ExecutablePlan compile(PhysicalPlan qep)

createThreads

protected LinkedList<PushBasedPlanThread> createThreads(PhysicalPlan qep,
 ExecutionContext execCxt)

createWorker

protected QueryPlanCompilerForPushBasedExecution.Worker createWorker()

createThread

protected PushBasedPlanThread createThread(NullaryExecutableOp op,
 ExecutionContext execCxt)

createThread

protected PushBasedPlanThread createThread(UnaryExecutableOp op,
 PushBasedPlanThread input,
 ExecutionContext execCxt)

createThread

protected PushBasedPlanThread createThread(BinaryExecutableOp op,
 PushBasedPlanThread input1,
 PushBasedPlanThread input2,
 ExecutionContext execCxt)

createThread

protected PushBasedPlanThread createThread(NaryExecutableOp op,
 PushBasedPlanThread[] inputs,
 ExecutionContext execCxt)