Uses of Class
edu.snu.coral.runtime.common.plan.physical.PhysicalPlan

Packages that use PhysicalPlan

Package	Description
edu.snu.coral.compiler.backend.coral
edu.snu.coral.runtime.common.eventhandler
edu.snu.coral.runtime.common.optimizer
edu.snu.coral.runtime.common.optimizer.pass.runtime
edu.snu.coral.runtime.master
edu.snu.coral.runtime.master.scheduler

Uses of PhysicalPlan in edu.snu.coral.compiler.backend.coral

Methods in edu.snu.coral.compiler.backend.coral that return PhysicalPlan

Modifier and Type	Method and Description
PhysicalPlan	CoralBackend.compile(DAG<IRVertex,IREdge> irDAG) Compiles an IR DAG into a PhysicalPlan to be submitted to Runtime.
PhysicalPlan	CoralBackend.compile(DAG<IRVertex,IREdge> irDAG, PhysicalPlanGenerator physicalPlanGenerator) Compiles an IR DAG into a PhysicalPlan to be submitted to Runtime.

Uses of PhysicalPlan in edu.snu.coral.runtime.common.eventhandler

Methods in edu.snu.coral.runtime.common.eventhandler that return PhysicalPlan

Modifier and Type	Method and Description
PhysicalPlan	UpdatePhysicalPlanEvent.getNewPhysicalPlan()
PhysicalPlan	DynamicOptimizationEvent.getPhysicalPlan()

Constructors in edu.snu.coral.runtime.common.eventhandler with parameters of type PhysicalPlan

Constructor and Description
DynamicOptimizationEvent(PhysicalPlan physicalPlan, MetricCollectionBarrierVertex metricCollectionBarrierVertex, Pair<String,String> taskInfo) Default constructor.

Uses of PhysicalPlan in edu.snu.coral.runtime.common.optimizer

Methods in edu.snu.coral.runtime.common.optimizer that return PhysicalPlan

Modifier and Type	Method and Description
static PhysicalPlan	RuntimeOptimizer.dynamicOptimization(PhysicalPlan originalPlan, MetricCollectionBarrierVertex metricCollectionBarrierVertex) Dynamic optimization method to process the dag with an appropriate pass, decided by the stats.

Methods in edu.snu.coral.runtime.common.optimizer with parameters of type PhysicalPlan

Modifier and Type	Method and Description
static PhysicalPlan	RuntimeOptimizer.dynamicOptimization(PhysicalPlan originalPlan, MetricCollectionBarrierVertex metricCollectionBarrierVertex) Dynamic optimization method to process the dag with an appropriate pass, decided by the stats.

Uses of PhysicalPlan in edu.snu.coral.runtime.common.optimizer.pass.runtime

Methods in edu.snu.coral.runtime.common.optimizer.pass.runtime that return PhysicalPlan

Modifier and Type	Method and Description
PhysicalPlan	DataSkewRuntimePass.apply(PhysicalPlan originalPlan, Map<String,List<Long>> metricData)

Methods in edu.snu.coral.runtime.common.optimizer.pass.runtime with parameters of type PhysicalPlan

Modifier and Type	Method and Description
PhysicalPlan	DataSkewRuntimePass.apply(PhysicalPlan originalPlan, Map<String,List<Long>> metricData)

Uses of PhysicalPlan in edu.snu.coral.runtime.master

Methods in edu.snu.coral.runtime.master with parameters of type PhysicalPlan

Modifier and Type	Method and Description
void	RuntimeMaster.execute(PhysicalPlan plan, int maxScheduleAttempt) Submits the PhysicalPlan to Runtime.

Constructors in edu.snu.coral.runtime.master with parameters of type PhysicalPlan

Constructor and Description
JobStateManager(PhysicalPlan physicalPlan, BlockManagerMaster blockManagerMaster, MetricMessageHandler metricMessageHandler, int maxScheduleAttempt)

Uses of PhysicalPlan in edu.snu.coral.runtime.master.scheduler

Methods in edu.snu.coral.runtime.master.scheduler with parameters of type PhysicalPlan

Modifier and Type	Method and Description
void	SingleJobTaskGroupQueue.onJobScheduled(PhysicalPlan physicalPlanForJob)
void	PendingTaskGroupQueue.onJobScheduled(PhysicalPlan physicalPlanForJob) Registers a job to this queue in case the queue needs to understand the topology of the job DAG.
void	Scheduler.scheduleJob(PhysicalPlan physicalPlan, JobStateManager jobStateManager) Schedules the given job.
void	BatchSingleJobScheduler.scheduleJob(PhysicalPlan jobToSchedule, JobStateManager scheduledJobStateManager) Receives a job to schedule.
void	Scheduler.updateJob(String jobId, PhysicalPlan newPhysicalPlan, Pair<String,String> taskInfo) Receives and updates the scheduler with a new physical plan for a job.
void	BatchSingleJobScheduler.updateJob(String jobId, PhysicalPlan newPhysicalPlan, Pair<String,String> taskInfo)