Uses of Class
org.apache.nemo.runtime.master.PlanStateManager

Packages that use PlanStateManager

Package	Description
org.apache.nemo.client
org.apache.nemo.runtime.master
org.apache.nemo.runtime.master.scheduler

Uses of PlanStateManager in org.apache.nemo.client

Constructors in org.apache.nemo.client with parameters of type PlanStateManager

Constructor	Description
DriverEndpoint(PlanStateManager planStateManager, ClientEndpoint clientEndpoint)	Construct an endpoint in driver side.

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

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

Modifier and Type	Method	Description
static PlanStateManager	PlanStateManager.newInstance(java.lang.String dagDirectory)	Static constructor for manual usage.

Methods in org.apache.nemo.runtime.master that return types with arguments of type PlanStateManager

Modifier and Type	Method	Description
Pair<PlanStateManager,java.util.concurrent.ScheduledExecutorService>	RuntimeMaster.execute(PhysicalPlan plan, int maxScheduleAttempt)	Submits the PhysicalPlan to Runtime.

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

Methods in org.apache.nemo.runtime.master.scheduler that return PlanStateManager

Modifier and Type	Method	Description
PlanStateManager	SimulationScheduler.getPlanStateManager()

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

Modifier and Type	Method	Description
static void	BatchSchedulerUtils.onRunTimePassMessage(PlanStateManager planStateManager, PlanRewriter planRewriter, java.lang.String taskId, java.lang.Object data)	Process the RuntimePassMessage.