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

Class AdaptiveScheduler.Settings

java.lang.Object

org.apache.flink.runtime.scheduler.adaptive.AdaptiveScheduler.Settings

Enclosing class:

AdaptiveScheduler

public static class AdaptiveScheduler.Settings
extends Object

Consolidated settings for the adaptive scheduler. This class is used to avoid passing around multiple config options.

Method Summary

Modifier and Type	Method	Description
org.apache.flink.configuration.SchedulerExecutionMode	getExecutionMode()
java.time.Duration	getInitialResourceAllocationTimeout()
java.time.Duration	getResourceStabilizationTimeout()
java.time.Duration	getScalingIntervalMax()
java.time.Duration	getScalingIntervalMin()
java.time.Duration	getSlotIdleTimeout()
static AdaptiveScheduler.Settings	of(org.apache.flink.configuration.Configuration configuration)

Methods inherited from class java.lang.Object

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

Method Detail

of

public static AdaptiveScheduler.Settings of(org.apache.flink.configuration.Configuration configuration)

getExecutionMode

public org.apache.flink.configuration.SchedulerExecutionMode getExecutionMode()

getInitialResourceAllocationTimeout

public java.time.Duration getInitialResourceAllocationTimeout()

getResourceStabilizationTimeout

public java.time.Duration getResourceStabilizationTimeout()

getSlotIdleTimeout

public java.time.Duration getSlotIdleTimeout()

getScalingIntervalMin

public java.time.Duration getScalingIntervalMin()

getScalingIntervalMax

public java.time.Duration getScalingIntervalMax()