Package org.apache.flink.autoscaler

Class RestApiMetricsCollector<KEY,Context extends JobAutoScalerContext<KEY>>

java.lang.Object

org.apache.flink.autoscaler.ScalingMetricCollector<KEY,Context>

org.apache.flink.autoscaler.RestApiMetricsCollector<KEY,Context>

public class RestApiMetricsCollector<KEY,Context extends JobAutoScalerContext<KEY>>
extends ScalingMetricCollector<KEY,Context>

Metric collector using flink rest api.

Constructor Summary

Constructors

Constructor	Description
RestApiMetricsCollector()

Method Summary

Modifier and Type	Method	Description
protected java.util.Map<FlinkMetric,org.apache.flink.runtime.rest.messages.job.metrics.AggregatedMetric>	queryAggregatedVertexMetrics(Context ctx, 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(Context ctx, java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.Map<java.lang.String,FlinkMetric>> filteredVertexMetricNames)

Methods inherited from class org.apache.flink.autoscaler.ScalingMetricCollector

cleanup, getAvailableVertexMetricNames, getHistories, getJobDetailsInfo, getJobTopology, getJobTopology, getJobUpdateTs, getMetricWindowSize, queryAggregatedMetricNames, queryFilteredMetricNames, setClock, updateMetrics

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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(Context ctx,
                                                                                                                                                                                                            java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.Map<java.lang.String,FlinkMetric>> filteredVertexMetricNames)

Specified by:

queryAllAggregatedMetrics in class ScalingMetricCollector<KEY,Context extends JobAutoScalerContext<KEY>>

queryAggregatedVertexMetrics

protected java.util.Map<FlinkMetric,org.apache.flink.runtime.rest.messages.job.metrics.AggregatedMetric> queryAggregatedVertexMetrics(Context ctx,
                                                                                                                                            org.apache.flink.runtime.jobgraph.JobVertexID jobVertexID,
                                                                                                                                            java.util.Map<java.lang.String,FlinkMetric> metrics)