Interface | Description |
---|---|
StateFactory<T extends org.apache.flink.runtime.scheduler.adaptive.State> |
Factory for creating adaptive scheduler state instances.
|
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. |
AdaptiveSchedulerFactory |
Factory for the adaptive scheduler.
|
CreatingExecutionGraph |
State which waits for the creation of the
ExecutionGraph . |
JobGraphJobInformation |
JobInformation created from a JobGraph . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.