Class RestApiMetricsCollector

    • Constructor Detail

      • RestApiMetricsCollector

        public RestApiMetricsCollector()
    • Method Detail

      • queryAllAggregatedMetrics

        protected java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,​java.util.Map<FlinkMetric,​org.apache.flink.runtime.rest.messages.job.metrics.AggregatedMetric>> queryAllAggregatedMetrics​(AbstractFlinkResource<?,​?> cr,
                                                                                                                                                                                                                    FlinkService flinkService,
                                                                                                                                                                                                                    org.apache.flink.configuration.Configuration conf,
                                                                                                                                                                                                                    java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,​java.util.Map<java.lang.String,​FlinkMetric>> filteredVertexMetricNames)
        Specified by:
        queryAllAggregatedMetrics in class ScalingMetricCollector
      • queryAggregatedVertexMetrics

        protected java.util.Map<FlinkMetric,​org.apache.flink.runtime.rest.messages.job.metrics.AggregatedMetric> queryAggregatedVertexMetrics​(FlinkService flinkService,
                                                                                                                                                    AbstractFlinkResource<?,​?> cr,
                                                                                                                                                    org.apache.flink.configuration.Configuration conf,
                                                                                                                                                    org.apache.flink.runtime.jobgraph.JobVertexID jobVertexID,
                                                                                                                                                    java.util.Map<java.lang.String,​FlinkMetric> metrics)