Class AutoScalerOptions


  • public class AutoScalerOptions
    extends java.lang.Object
    Config options related to the autoscaler module.
    • Field Detail

      • AUTOSCALER_ENABLED

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Boolean> AUTOSCALER_ENABLED
      • SCALING_ENABLED

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Boolean> SCALING_ENABLED
      • METRICS_WINDOW

        public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> METRICS_WINDOW
      • STABILIZATION_INTERVAL

        public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> STABILIZATION_INTERVAL
      • TARGET_UTILIZATION

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Double> TARGET_UTILIZATION
      • TARGET_UTILIZATION_BOUNDARY

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Double> TARGET_UTILIZATION_BOUNDARY
      • SCALE_UP_GRACE_PERIOD

        public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> SCALE_UP_GRACE_PERIOD
      • VERTEX_MIN_PARALLELISM

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Integer> VERTEX_MIN_PARALLELISM
      • VERTEX_MAX_PARALLELISM

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Integer> VERTEX_MAX_PARALLELISM
      • MAX_SCALE_DOWN_FACTOR

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Double> MAX_SCALE_DOWN_FACTOR
      • MAX_SCALE_UP_FACTOR

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Double> MAX_SCALE_UP_FACTOR
      • CATCH_UP_DURATION

        public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> CATCH_UP_DURATION
      • RESTART_TIME

        public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> RESTART_TIME
      • BACKLOG_PROCESSING_LAG_THRESHOLD

        public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> BACKLOG_PROCESSING_LAG_THRESHOLD
      • SCALING_EFFECTIVENESS_DETECTION_ENABLED

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Boolean> SCALING_EFFECTIVENESS_DETECTION_ENABLED
      • SCALING_EFFECTIVENESS_THRESHOLD

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Double> SCALING_EFFECTIVENESS_THRESHOLD
      • VERTEX_SCALING_HISTORY_COUNT

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Integer> VERTEX_SCALING_HISTORY_COUNT
      • VERTEX_SCALING_HISTORY_AGE

        public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> VERTEX_SCALING_HISTORY_AGE
      • BUSY_TIME_AGGREGATOR

        public static final org.apache.flink.configuration.ConfigOption<MetricAggregator> BUSY_TIME_AGGREGATOR
      • VERTEX_EXCLUDE_IDS

        public static final org.apache.flink.configuration.ConfigOption<java.util.List<java.lang.String>> VERTEX_EXCLUDE_IDS
      • SCALING_REPORT_INTERVAL

        public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> SCALING_REPORT_INTERVAL
    • Constructor Detail

      • AutoScalerOptions

        public AutoScalerOptions()