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<FlinkDeployment>
MetricManager. createFlinkDeploymentMetricManager(org.apache.flink.configuration.Configuration conf, KubernetesOperatorMetricGroup metricGroup)
static MetricManager<FlinkSessionJob>
MetricManager. createFlinkSessionJobMetricManager(org.apache.flink.configuration.Configuration conf, 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 CommonStatus<?>,CR extends AbstractFlinkResource<?,S>>
StatusRecorder<CR,S>StatusRecorder. create(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, MetricManager<CR> metricManager, java.util.Collection<FlinkResourceListener> listeners)
Constructors in org.apache.flink.kubernetes.operator.utils with parameters of type MetricManager Constructor Description StatusRecorder(MetricManager<CR> metricManager, java.util.function.BiConsumer<CR,STATUS> statusUpdateListener)
-