Package org.apache.flink.kubernetes.operator.metrics

Class MetricManager<CR extends AbstractFlinkResource<?,?>>

java.lang.Object

org.apache.flink.kubernetes.operator.metrics.MetricManager<CR>

public class MetricManager<CR extends AbstractFlinkResource<?,?>>
extends java.lang.Object

Metric manager for Operator managed custom resources.

Constructor Summary

Constructors

Constructor	Description
MetricManager()

Method Summary

Modifier and Type	Method	Description
static MetricManager<FlinkDeployment>	createFlinkDeploymentMetricManager(FlinkConfigManager configManager, KubernetesOperatorMetricGroup metricGroup)
static MetricManager<FlinkSessionJob>	createFlinkSessionJobMetricManager(FlinkConfigManager configManager, KubernetesOperatorMetricGroup metricGroup)
java.util.List<CustomResourceMetrics<CR>>	getRegisteredMetrics()
void	onRemove(CR cr)
void	onUpdate(CR cr)
void	register(CustomResourceMetrics<CR> metrics)

Methods inherited from class java.lang.Object

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

Constructor Detail

MetricManager

public MetricManager()

Method Detail

onUpdate

public void onUpdate(CR cr)

onRemove

public void onRemove(CR cr)

register

public void register(CustomResourceMetrics<CR> metrics)

createFlinkDeploymentMetricManager

public static MetricManager<FlinkDeployment> createFlinkDeploymentMetricManager(FlinkConfigManager configManager,
                                                                                KubernetesOperatorMetricGroup metricGroup)

createFlinkSessionJobMetricManager

public static MetricManager<FlinkSessionJob> createFlinkSessionJobMetricManager(FlinkConfigManager configManager,
                                                                                KubernetesOperatorMetricGroup metricGroup)

getRegisteredMetrics

@VisibleForTesting
public java.util.List<CustomResourceMetrics<CR>> getRegisteredMetrics()