edu.snu.coral.runtime.common.plan.physical

Class PhysicalPlanGenerator

java.lang.Object

edu.snu.coral.runtime.common.plan.physical.PhysicalPlanGenerator

All Implemented Interfaces:

Function<DAG<IRVertex,IREdge>,DAG<PhysicalStage,PhysicalStageEdge>>

public final class PhysicalPlanGenerator
extends Object
implements Function<DAG<IRVertex,IREdge>,DAG<PhysicalStage,PhysicalStageEdge>>

A function that converts an IR DAG to physical DAG.

Method Summary

Modifier and Type	Method and Description
DAG<PhysicalStage,PhysicalStageEdge>	apply(DAG<IRVertex,IREdge> irDAG) Generates the PhysicalPlan to be executed.
Map<Task,IRVertex>	getTaskIRVertexMap() Getter for taskIRVertexMap.
DAG<Stage,StageEdge>	stagePartitionIrDAG(DAG<IRVertex,IREdge> irDAG) We take the stage-partitioned DAG and create actual stage and stage edge objects to create a DAG of stages.

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.Function

andThen, compose, identity

Method Detail

apply

public DAG<PhysicalStage,PhysicalStageEdge> apply(DAG<IRVertex,IREdge> irDAG)

Generates the PhysicalPlan to be executed.

Specified by:

apply in interface Function<DAG<IRVertex,IREdge>,DAG<PhysicalStage,PhysicalStageEdge>>

Parameters:

irDAG - that should be converted to a physical execution plan

Returns:

PhysicalPlan to execute.

stagePartitionIrDAG

public DAG<Stage,StageEdge> stagePartitionIrDAG(DAG<IRVertex,IREdge> irDAG)

We take the stage-partitioned DAG and create actual stage and stage edge objects to create a DAG of stages.

Parameters:

irDAG - stage-partitioned IR DAG.

Returns:

the DAG composed of stages and stage edges.

getTaskIRVertexMap

public Map<Task,IRVertex> getTaskIRVertexMap()

Getter for taskIRVertexMap.

Returns:

the taskIRVertexMap.