Package org.apache.flink.autoscaler.metrics

Enum FlinkMetric

  • All Implemented Interfaces:
    java.io.Serializable, java.lang.Comparable<FlinkMetric>
    public enum FlinkMetric
extends java.lang.Enum<FlinkMetric>
    Enum representing the collected Flink metrics for autoscaling. The actual metric names depend on the JobGraph.

    • Enum Constant Detail

      • BUSY_TIME_PER_SEC

        public static final FlinkMetric BUSY_TIME_PER_SEC

      • SOURCE_TASK_NUM_RECORDS_IN_PER_SEC

        public static final FlinkMetric SOURCE_TASK_NUM_RECORDS_IN_PER_SEC

      • SOURCE_TASK_NUM_RECORDS_OUT

        public static final FlinkMetric SOURCE_TASK_NUM_RECORDS_OUT

      • SOURCE_TASK_NUM_RECORDS_OUT_PER_SEC

        public static final FlinkMetric SOURCE_TASK_NUM_RECORDS_OUT_PER_SEC

      • SOURCE_TASK_NUM_RECORDS_IN

        public static final FlinkMetric SOURCE_TASK_NUM_RECORDS_IN

      • PENDING_RECORDS

        public static final FlinkMetric PENDING_RECORDS

      • BACKPRESSURE_TIME_PER_SEC

        public static final FlinkMetric BACKPRESSURE_TIME_PER_SEC

      • HEAP_MEMORY_MAX

        public static final FlinkMetric HEAP_MEMORY_MAX

      • HEAP_MEMORY_USED

        public static final FlinkMetric HEAP_MEMORY_USED

      • MANAGED_MEMORY_USED

        public static final FlinkMetric MANAGED_MEMORY_USED

      • METASPACE_MEMORY_USED

        public static final FlinkMetric METASPACE_MEMORY_USED

      • TOTAL_GC_TIME_PER_SEC

        public static final FlinkMetric TOTAL_GC_TIME_PER_SEC

      • NUM_TASK_SLOTS_TOTAL

        public static final FlinkMetric NUM_TASK_SLOTS_TOTAL

      • NUM_TASK_SLOTS_AVAILABLE

        public static final FlinkMetric NUM_TASK_SLOTS_AVAILABLE

    • Field Detail

      • FINISHED_METRICS

        public static final java.util.Map<FlinkMetric,​org.apache.flink.runtime.rest.messages.job.metrics.AggregatedMetric> FINISHED_METRICS

      • predicate

        public final java.util.function.Predicate<java.lang.String> predicate

    • Method Detail

      • values

        public static FlinkMetric[] 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 (FlinkMetric c : FlinkMetric.values())
    System.out.println(c);
        Returns:
        an array containing the constants of this enum type, in the order they are declared

      • valueOf

        public static FlinkMetric 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 name
        java.lang.NullPointerException - if the argument is null

      • findAny

        public java.util.Optional<java.lang.String> findAny​(java.util.Collection<java.lang.String> metrics)

      • findAll

        public java.util.List<java.lang.String> findAll​(java.util.Collection<java.lang.String> metrics)