Uses of Class
org.apache.flink.kubernetes.operator.metrics.MetricManager
-
Packages that use MetricManager Package Description org.apache.flink.kubernetes.operator.metrics org.apache.flink.kubernetes.operator.utils -
-
Uses of MetricManager in org.apache.flink.kubernetes.operator.metrics
Methods in org.apache.flink.kubernetes.operator.metrics that return MetricManager Modifier and Type Method Description static MetricManager<org.apache.flink.kubernetes.operator.api.FlinkDeployment>MetricManager. createFlinkDeploymentMetricManager(FlinkConfigManager configManager, KubernetesOperatorMetricGroup metricGroup)static MetricManager<org.apache.flink.kubernetes.operator.api.FlinkSessionJob>MetricManager. createFlinkSessionJobMetricManager(FlinkConfigManager configManager, KubernetesOperatorMetricGroup metricGroup) -
Uses of MetricManager in org.apache.flink.kubernetes.operator.utils
Methods in org.apache.flink.kubernetes.operator.utils with parameters of type MetricManager Modifier and Type Method Description static <S extends org.apache.flink.kubernetes.operator.api.status.CommonStatus<?>,CR extends org.apache.flink.kubernetes.operator.api.AbstractFlinkResource<?,S>>
StatusRecorder<CR,S>StatusRecorder. create(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, MetricManager<CR> metricManager, java.util.Collection<org.apache.flink.kubernetes.operator.api.listener.FlinkResourceListener> listeners)Constructors in org.apache.flink.kubernetes.operator.utils with parameters of type MetricManager Constructor Description StatusRecorder(io.fabric8.kubernetes.client.KubernetesClient client, MetricManager<CR> metricManager, java.util.function.BiConsumer<CR,STATUS> statusUpdateListener)
-