Package org.apache.flink.runtime.scheduler.adaptive

Class DefaultStateTransitionManager

java.lang.Object

org.apache.flink.runtime.scheduler.adaptive.DefaultStateTransitionManager

All Implemented Interfaces:

StateTransitionManager

@NotThreadSafe
public class DefaultStateTransitionManager
extends Object
implements StateTransitionManager

DefaultStateTransitionManager is a state machine which manages the AdaptiveScheduler's state transitions based on the previous transition time and the available resources. See DefaultStateTransitionManager.Phase for details on each individual phase of this state machine. Note: We use the term phase here to avoid confusion with the state used in the AdaptiveScheduler.

 DefaultStateTransitionManager.Cooldown
   |
   +--> DefaultStateTransitionManager.Idling
   |      |
   |      V
   +--> DefaultStateTransitionManager.Stabilizing
          |
          +--> DefaultStateTransitionManager.Stabilized --> DefaultStateTransitionManager.Idling
          |      |
          |      V
          \--> DefaultStateTransitionManager.Transitioning
 

Thread-safety: This class is not implemented in a thread-safe manner and relies on the fact that any method call happens within a single thread.

See Also:

Executing

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.runtime.scheduler.adaptive.StateTransitionManager

StateTransitionManager.Context

Method Summary

Modifier and Type	Method	Description
void	close()	Is called when the state transition manager should be closed.
void	onChange()	Is called if the environment changed in a way that a state transition could be considered.
void	onTrigger()	Is called when any previous observed environment changes shall be verified possibly triggering a state transition operation.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

onChange

public void onChange()

Description copied from interface: StateTransitionManager

Is called if the environment changed in a way that a state transition could be considered.

Specified by:

onChange in interface StateTransitionManager

onTrigger

public void onTrigger()

Description copied from interface: StateTransitionManager

Is called when any previous observed environment changes shall be verified possibly triggering a state transition operation.

Specified by:

onTrigger in interface StateTransitionManager

close

public void close()

Description copied from interface: StateTransitionManager

Is called when the state transition manager should be closed.

Specified by:

close in interface StateTransitionManager