Class RestApiMetricsCollector
- java.lang.Object
-
- org.apache.flink.kubernetes.operator.autoscaler.ScalingMetricCollector
-
- org.apache.flink.kubernetes.operator.autoscaler.RestApiMetricsCollector
-
public class RestApiMetricsCollector extends ScalingMetricCollector
Metric collector using flink rest api.
-
-
Constructor Summary
Constructors Constructor Description RestApiMetricsCollector()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description 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)
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)
-
Methods inherited from class org.apache.flink.kubernetes.operator.autoscaler.ScalingMetricCollector
cleanup, getAvailableVertexMetricNames, getFilteredVertexMetricNames, getHistories, getJobTopology, getJobTopology, getJobUpdateTs, getMetricWindowSize, queryAggregatedMetricNames, queryFilteredMetricNames, setClock, updateMetrics
-
-
-
-
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 classScalingMetricCollector
-
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)
-
-