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 safeCounter
wrapper.static class
OperatorMetricUtils.SynchronizedHistogram
Thread safeHistogram
wrapper.static class
OperatorMetricUtils.SynchronizedMeterView
Thread safeMeterView
wrapper.
-
Constructor Summary
Constructors Constructor Description OperatorMetricUtils()
-
Method Summary
All Methods Static Methods Concrete Methods 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 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)
-
-
-
Method Detail
-
initOperatorMetrics
public static KubernetesOperatorMetricGroup initOperatorMetrics(org.apache.flink.configuration.Configuration defaultConfig)
-
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)
-
-