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

Class OperatorMetricUtils

java.lang.Object

org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils

public class OperatorMetricUtils
extends java.lang.Object

Utility class for flink based operator metrics.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	OperatorMetricUtils.SynchronizedCounter	Thread safe Counter wrapper.
static class	OperatorMetricUtils.SynchronizedHistogram	Thread safe Histogram wrapper.
static class	OperatorMetricUtils.SynchronizedMeterView	Thread safe MeterView wrapper.

Constructor Summary

Constructors

Constructor	Description
OperatorMetricUtils()

Method Summary

Modifier and Type	Method	Description
static org.apache.flink.metrics.Histogram	createHistogram(FlinkOperatorConfiguration operatorConfiguration)
protected static org.apache.flink.configuration.Configuration	createMetricConfig(org.apache.flink.configuration.Configuration defaultConfig)
static KubernetesResourceMetricGroup	createResourceMetricGroup(KubernetesOperatorMetricGroup operatorMetricGroup, FlinkConfigManager configManager, AbstractFlinkResource<?,?> resource)
static KubernetesOperatorMetricGroup	initOperatorMetrics(org.apache.flink.configuration.Configuration defaultConfig)
static org.apache.flink.metrics.Counter	synchronizedCounter(org.apache.flink.metrics.Counter counter)
static OperatorMetricUtils.SynchronizedMeterView	synchronizedMeterView(org.apache.flink.metrics.MeterView meterView)

Methods inherited from class java.lang.Object

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

Constructor Detail

OperatorMetricUtils

public OperatorMetricUtils()

Method Detail

initOperatorMetrics

public static KubernetesOperatorMetricGroup initOperatorMetrics(org.apache.flink.configuration.Configuration defaultConfig)

createResourceMetricGroup

public static KubernetesResourceMetricGroup createResourceMetricGroup(KubernetesOperatorMetricGroup operatorMetricGroup,
                                                                      FlinkConfigManager configManager,
                                                                      AbstractFlinkResource<?,?> resource)

createMetricConfig

@VisibleForTesting
protected static org.apache.flink.configuration.Configuration createMetricConfig(org.apache.flink.configuration.Configuration defaultConfig)

synchronizedCounter

public static org.apache.flink.metrics.Counter synchronizedCounter(org.apache.flink.metrics.Counter counter)

synchronizedMeterView

public static OperatorMetricUtils.SynchronizedMeterView synchronizedMeterView(org.apache.flink.metrics.MeterView meterView)

createHistogram

public static org.apache.flink.metrics.Histogram createHistogram(FlinkOperatorConfiguration operatorConfiguration)