Uses of Class
org.apache.nemo.runtime.common.plan.PhysicalPlan

Packages that use PhysicalPlan

Package	Description
org.apache.nemo.compiler.backend.nemo
org.apache.nemo.compiler.backend.nemo.prophet
org.apache.nemo.runtime.common.metric
org.apache.nemo.runtime.common.plan
org.apache.nemo.runtime.master
org.apache.nemo.runtime.master.scheduler

Uses of PhysicalPlan in org.apache.nemo.compiler.backend.nemo

Methods in org.apache.nemo.compiler.backend.nemo that return PhysicalPlan

Modifier and Type	Method	Description
PhysicalPlan	NemoBackend.compile(IRDAG irDAG)	Compiles an IR DAG into a PhysicalPlan to be submitted to Runtime.
PhysicalPlan	NemoPlanRewriter.rewrite(int messageId)

Methods in org.apache.nemo.compiler.backend.nemo with parameters of type PhysicalPlan

Modifier and Type	Method	Description
void	NemoPlanRewriter.setCurrentPhysicalPlan(PhysicalPlan currentPhysicalPlan)

Uses of PhysicalPlan in org.apache.nemo.compiler.backend.nemo.prophet

Constructors in org.apache.nemo.compiler.backend.nemo.prophet with parameters of type PhysicalPlan

Constructor	Description
ParallelismProphet(IRDAG irdag, PhysicalPlan physicalPlan, SimulationScheduler simulationScheduler, PhysicalPlanGenerator physicalPlanGenerator, java.util.Set<StageEdge> edgesToOptimize)	Default constructor for ParallelismProphet.

Uses of PhysicalPlan in org.apache.nemo.runtime.common.metric

Constructors in org.apache.nemo.runtime.common.metric with parameters of type PhysicalPlan

Constructor	Description
JobMetric(PhysicalPlan physicalPlan)	Constructor.

Uses of PhysicalPlan in org.apache.nemo.runtime.common.plan

Methods in org.apache.nemo.runtime.common.plan that return PhysicalPlan

Modifier and Type	Method	Description
static PhysicalPlan	TestPlanGenerator.generatePhysicalPlan(TestPlanGenerator.PlanType planType, boolean isPush)
PhysicalPlan	PlanRewriter.rewrite(int messageId)

Uses of PhysicalPlan in org.apache.nemo.runtime.master

Methods in org.apache.nemo.runtime.master that return PhysicalPlan

Modifier and Type	Method	Description
static PhysicalPlan	PlanAppender.appendPlan(PhysicalPlan originalPlan, PhysicalPlan planToAppend)	Append to plans regarding to caching.
PhysicalPlan	PlanStateManager.getPhysicalPlan()

Methods in org.apache.nemo.runtime.master with parameters of type PhysicalPlan

Modifier and Type	Method	Description
static PhysicalPlan	PlanAppender.appendPlan(PhysicalPlan originalPlan, PhysicalPlan planToAppend)	Append to plans regarding to caching.
Pair<PlanStateManager,java.util.concurrent.ScheduledExecutorService>	RuntimeMaster.execute(PhysicalPlan plan, int maxScheduleAttempt)	Submits the PhysicalPlan to Runtime.
void	PlanStateManager.updatePlan(PhysicalPlan physicalPlanToUpdate, int maxScheduleAttemptToSet)	Update the physical plan and maximum attempt.

Uses of PhysicalPlan in org.apache.nemo.runtime.master.scheduler

Methods in org.apache.nemo.runtime.master.scheduler with parameters of type PhysicalPlan

Modifier and Type	Method	Description
void	BatchScheduler.schedulePlan(PhysicalPlan submittedPhysicalPlan, int maxScheduleAttempt)	Schedules a given plan.
void	Scheduler.schedulePlan(PhysicalPlan physicalPlan, int maxScheduleAttempt)	Schedules the given plan.
void	SimulationScheduler.schedulePlan(PhysicalPlan submittedPhysicalPlan, int maxScheduleAttempt)	The entrance point of the simulator.
void	StreamingScheduler.schedulePlan(PhysicalPlan submittedPhysicalPlan, int maxScheduleAttempt)
void	BatchScheduler.updatePlan(PhysicalPlan newPhysicalPlan)
void	Scheduler.updatePlan(PhysicalPlan newPhysicalPlan)	Receives and updates the scheduler with a new physical plan for a job.
void	SimulationScheduler.updatePlan(PhysicalPlan newPhysicalPlan)
void	StreamingScheduler.updatePlan(PhysicalPlan newPhysicalPlan)