Enum ScalingMetric
- java.lang.Object
-
- java.lang.Enum<ScalingMetric>
-
- org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetric
-
- All Implemented Interfaces:
java.io.Serializable
,java.lang.Comparable<ScalingMetric>
public enum ScalingMetric extends java.lang.Enum<ScalingMetric>
Supported scaling metrics. These represent high level metrics computed from Flink job metrics that are used for scaling decisions in the autoscaler module.
-
-
Enum Constant Summary
Enum Constants Enum Constant Description CATCH_UP_DATA_RATE
Target processing rate of operators as derived from backlog (records/sec).EXPECTED_PROCESSING_RATE
Expected true processing rate after scale up.LAG
Total number of pending records.LOAD_AVG
Average subtask load (busy time ratio 0 (idle) to 1 (fully utilized)).LOAD_MAX
Max subtask load (busy time ratio 0 (idle) to 1 (fully utilized)).MAX_PARALLELISM
Job vertex max parallelism.OUTPUT_RATIO
Number of outputs produced on average for every input record.PARALLELISM
Job vertex parallelism.SCALE_DOWN_RATE_THRESHOLD
Lower boundary of the target data rate range.SCALE_UP_RATE_THRESHOLD
Upper boundary of the target data rate range.SOURCE_DATA_RATE
Incoming data rate to the source, e.g.TARGET_DATA_RATE
Target processing rate of operators as derived from source inputs (records/sec).TRUE_OUTPUT_RATE
Output rate at full capacity (records/sec).TRUE_PROCESSING_RATE
Processing rate at full capacity (records/sec).
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
isCalculateAverage()
static ScalingMetric
valueOf(java.lang.String name)
Returns the enum constant of this type with the specified name.static ScalingMetric[]
values()
Returns an array containing the constants of this enum type, in the order they are declared.
-
-
-
Enum Constant Detail
-
LOAD_MAX
public static final ScalingMetric LOAD_MAX
Max subtask load (busy time ratio 0 (idle) to 1 (fully utilized)).
-
LOAD_AVG
public static final ScalingMetric LOAD_AVG
Average subtask load (busy time ratio 0 (idle) to 1 (fully utilized)).
-
TRUE_PROCESSING_RATE
public static final ScalingMetric TRUE_PROCESSING_RATE
Processing rate at full capacity (records/sec).
-
TRUE_OUTPUT_RATE
public static final ScalingMetric TRUE_OUTPUT_RATE
Output rate at full capacity (records/sec).
-
SOURCE_DATA_RATE
public static final ScalingMetric SOURCE_DATA_RATE
Incoming data rate to the source, e.g. rate of records written to the Kafka topic (records/sec).
-
TARGET_DATA_RATE
public static final ScalingMetric TARGET_DATA_RATE
Target processing rate of operators as derived from source inputs (records/sec).
-
CATCH_UP_DATA_RATE
public static final ScalingMetric CATCH_UP_DATA_RATE
Target processing rate of operators as derived from backlog (records/sec).
-
OUTPUT_RATIO
public static final ScalingMetric OUTPUT_RATIO
Number of outputs produced on average for every input record.
-
LAG
public static final ScalingMetric LAG
Total number of pending records.
-
PARALLELISM
public static final ScalingMetric PARALLELISM
Job vertex parallelism.
-
MAX_PARALLELISM
public static final ScalingMetric MAX_PARALLELISM
Job vertex max parallelism.
-
SCALE_UP_RATE_THRESHOLD
public static final ScalingMetric SCALE_UP_RATE_THRESHOLD
Upper boundary of the target data rate range.
-
SCALE_DOWN_RATE_THRESHOLD
public static final ScalingMetric SCALE_DOWN_RATE_THRESHOLD
Lower boundary of the target data rate range.
-
EXPECTED_PROCESSING_RATE
public static final ScalingMetric EXPECTED_PROCESSING_RATE
Expected true processing rate after scale up.
-
-
Method Detail
-
values
public static ScalingMetric[] values()
Returns an array containing the constants of this enum type, in the order they are declared. This method may be used to iterate over the constants as follows:for (ScalingMetric c : ScalingMetric.values()) System.out.println(c);
- Returns:
- an array containing the constants of this enum type, in the order they are declared
-
valueOf
public static ScalingMetric valueOf(java.lang.String name)
Returns the enum constant of this type with the specified name. The string must match exactly an identifier used to declare an enum constant in this type. (Extraneous whitespace characters are not permitted.)- Parameters:
name
- the name of the enum constant to be returned.- Returns:
- the enum constant with the specified name
- Throws:
java.lang.IllegalArgumentException
- if this enum type has no constant with the specified namejava.lang.NullPointerException
- if the argument is null
-
isCalculateAverage
public boolean isCalculateAverage()
-
-