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
Duration	getExecutingCooldownTimeout()
Duration	getExecutingResourceStabilizationTimeout()
SchedulerExecutionMode	getExecutionMode()
Duration	getMaximumDelayForTriggeringRescale()
int	getRescaleOnFailedCheckpointCount()
Duration	getSlotIdleTimeout()
Duration	getSubmissionResourceStabilizationTimeout()
Duration	getSubmissionResourceWaitTimeout()
static AdaptiveScheduler.Settings	of(Configuration configuration)
static AdaptiveScheduler.Settings	of(Configuration configuration, JobCheckpointingSettings checkpointingConfiguration)

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(Configuration configuration)
                                     throws ConfigurationException

Throws:

ConfigurationException

of

public static AdaptiveScheduler.Settings of(Configuration configuration,
                                            @Nullable
                                            JobCheckpointingSettings checkpointingConfiguration)
                                     throws ConfigurationException

Throws:

ConfigurationException

getExecutionMode

public SchedulerExecutionMode getExecutionMode()

getSubmissionResourceWaitTimeout

public Duration getSubmissionResourceWaitTimeout()

getSubmissionResourceStabilizationTimeout

public Duration getSubmissionResourceStabilizationTimeout()

getSlotIdleTimeout

public Duration getSlotIdleTimeout()

getExecutingCooldownTimeout

public Duration getExecutingCooldownTimeout()

getExecutingResourceStabilizationTimeout

public Duration getExecutingResourceStabilizationTimeout()

getMaximumDelayForTriggeringRescale

public Duration getMaximumDelayForTriggeringRescale()

getRescaleOnFailedCheckpointCount

public int getRescaleOnFailedCheckpointCount()