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
      • NUM_RECORDS_IN_PER_SEC

        public static final FlinkMetric NUM_RECORDS_IN_PER_SEC
      • NUM_RECORDS_OUT_PER_SEC

        public static final FlinkMetric NUM_RECORDS_OUT_PER_SEC
      • SOURCE_TASK_NUM_RECORDS_OUT_PER_SEC

        public static final FlinkMetric SOURCE_TASK_NUM_RECORDS_OUT_PER_SEC
      • SOURCE_TASK_NUM_RECORDS_IN_PER_SEC

        public static final FlinkMetric SOURCE_TASK_NUM_RECORDS_IN_PER_SEC
      • PENDING_RECORDS

        public static final FlinkMetric PENDING_RECORDS
    • 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<org.apache.flink.runtime.rest.messages.job.metrics.AggregatedMetric> metrics)
      • findAll

        public java.util.List<java.lang.String> findAll​(java.util.Collection<org.apache.flink.runtime.rest.messages.job.metrics.AggregatedMetric> metrics)