Uses of Class
org.apache.nemo.runtime.common.state.PlanState.State
-
Packages that use PlanState.State Package Description org.apache.nemo.client org.apache.nemo.client.beam org.apache.nemo.runtime.common.metric org.apache.nemo.runtime.common.state org.apache.nemo.runtime.master -
-
Uses of PlanState.State in org.apache.nemo.client
Methods in org.apache.nemo.client with parameters of type PlanState.State Modifier and Type Method Description java.lang.Enum
StateTranslator. translateState(PlanState.State planState)
Translate a plan state of nemo to a corresponding client endpoint state. -
Uses of PlanState.State in org.apache.nemo.client.beam
Methods in org.apache.nemo.client.beam with parameters of type PlanState.State Modifier and Type Method Description java.lang.Enum
BeamStateTranslator. translateState(PlanState.State jobState)
Translate a job state of nemo to a corresponding Beam state. -
Uses of PlanState.State in org.apache.nemo.runtime.common.metric
Methods in org.apache.nemo.runtime.common.metric that return types with arguments of type PlanState.State Modifier and Type Method Description java.util.List<StateTransitionEvent<PlanState.State>>
JobMetric. getStateTransitionEvents()
Methods in org.apache.nemo.runtime.common.metric with parameters of type PlanState.State Modifier and Type Method Description void
JobMetric. addEvent(PlanState.State prevState, PlanState.State newState)
-
Uses of PlanState.State in org.apache.nemo.runtime.common.state
Methods in org.apache.nemo.runtime.common.state that return PlanState.State Modifier and Type Method Description static PlanState.State
PlanState.State. valueOf(java.lang.String name)
Returns the enum constant of this type with the specified name.static PlanState.State[]
PlanState.State. values()
Returns an array containing the constants of this enum type, in the order they are declared. -
Uses of PlanState.State in org.apache.nemo.runtime.master
Methods in org.apache.nemo.runtime.master that return PlanState.State Modifier and Type Method Description PlanState.State
PlanStateManager. getPlanState()
PlanState.State
PlanStateManager. waitUntilFinish()
Wait for this plan to be finished and return the final state.PlanState.State
PlanStateManager. waitUntilFinish(long timeout, java.util.concurrent.TimeUnit unit)
Wait for this plan to be finished and return the final state.
-