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

Class MetricManager<CR extends io.fabric8.kubernetes.client.CustomResource<?,?>>

java.lang.Object

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

public class MetricManager<CR extends io.fabric8.kubernetes.client.CustomResource<?,?>>
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(org.apache.flink.configuration.Configuration conf, KubernetesOperatorMetricGroup metricGroup)
static MetricManager<FlinkSessionJob>	createFlinkSessionJobMetricManager(org.apache.flink.configuration.Configuration conf, KubernetesOperatorMetricGroup metricGroup)
static MetricManager<FlinkStateSnapshot>	createFlinkStateSnapshotMetricManager(org.apache.flink.configuration.Configuration conf, 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(org.apache.flink.configuration.Configuration conf,
                                                                                KubernetesOperatorMetricGroup metricGroup)

createFlinkSessionJobMetricManager

public static MetricManager<FlinkSessionJob> createFlinkSessionJobMetricManager(org.apache.flink.configuration.Configuration conf,
                                                                                KubernetesOperatorMetricGroup metricGroup)

createFlinkStateSnapshotMetricManager

public static MetricManager<FlinkStateSnapshot> createFlinkStateSnapshotMetricManager(org.apache.flink.configuration.Configuration conf,
                                                                                      KubernetesOperatorMetricGroup metricGroup)

getRegisteredMetrics

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