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

Interface Summary

Interface	Description
LabeledGlobalFailureHandler	An interface for handling and associating global failures with labels from FailureEnricher.
StateFactory<T extends org.apache.flink.runtime.scheduler.adaptive.State>	Factory for creating adaptive scheduler state instances.
StateTransitions	An interface covering all possible State transitions.
StateTransitions.ToCancelling	Interface covering transition to the Canceling state.
StateTransitions.ToCreatingExecutionGraph	Interface covering transition to the CreatingExecutionGraph state.
StateTransitions.ToExecuting	Interface covering transition to the Executing state.
StateTransitions.ToFailing	Interface covering transition to the Failing state.
StateTransitions.ToFinished	Interface covering transition to the Finished state.
StateTransitions.ToRestarting	Interface covering transition to the Restarting state.
StateTransitions.ToStopWithSavepoint	Interface covering transition to the StopWithSavepoint state.
StateTransitions.ToWaitingForResources	Interface covering transition to the WaitingForResources state.

Class Summary

Class	Description
AdaptiveScheduler	A SchedulerNG implementation that uses the declarative resource management and automatically adapts the parallelism in case not enough resource could be acquired to run at the configured parallelism, as described in FLIP-160.
AdaptiveScheduler.Settings	Consolidated settings for the adaptive scheduler.
AdaptiveSchedulerFactory	Factory for the adaptive scheduler.
CreatingExecutionGraph	State which waits for the creation of the ExecutionGraph.
FailureResultUtil	FailureResultUtil contains helper methods for FailureResult.
JobGraphJobInformation	JobInformation created from a JobGraph.
JobSchedulingPlan	A plan that describes how to execute JobGraph.
JobSchedulingPlan.SlotAssignment	Assignment of a slot to some target (e.g.