Package org.apache.nemo.runtime.common.plan

Class PhysicalPlanGenerator

java.lang.Object

org.apache.nemo.runtime.common.plan.PhysicalPlanGenerator

All Implemented Interfaces:

java.util.function.Function<IRDAG,DAG<Stage,StageEdge>>

public final class PhysicalPlanGenerator
extends java.lang.Object
implements java.util.function.Function<IRDAG,DAG<Stage,StageEdge>>

A function that converts an IR DAG to physical DAG.

Method Summary

Modifier and Type	Method	Description
DAG<Stage,StageEdge>	apply(IRDAG irDAG)	Generates the PhysicalPlan to be executed.
DAG<Stage,StageEdge>	stagePartitionIrDAG(IRDAG 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

Method Detail

apply

public DAG<Stage,StageEdge> apply(IRDAG irDAG)

Generates the PhysicalPlan to be executed.

Specified by:

apply in interface java.util.function.Function<IRDAG,DAG<Stage,StageEdge>>

Parameters:

irDAG - that should be converted to a physical execution plan

Returns:

PhysicalPlan to execute.

stagePartitionIrDAG

public DAG<Stage,StageEdge> stagePartitionIrDAG(IRDAG 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.