Class OperatorMetricUtils.SynchronizedCounter
- java.lang.Object
-
- org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedCounter
-
- All Implemented Interfaces:
org.apache.flink.metrics.Counter
,org.apache.flink.metrics.Metric
- Enclosing class:
- OperatorMetricUtils
public static class OperatorMetricUtils.SynchronizedCounter extends java.lang.Object implements org.apache.flink.metrics.Counter
Thread safeCounter
wrapper.
-
-
Constructor Summary
Constructors Constructor Description SynchronizedCounter(org.apache.flink.metrics.Counter delegate)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
dec()
void
dec(long l)
long
getCount()
void
inc()
void
inc(long l)
-
-
-
Method Detail
-
inc
public void inc()
- Specified by:
inc
in interfaceorg.apache.flink.metrics.Counter
-
inc
public void inc(long l)
- Specified by:
inc
in interfaceorg.apache.flink.metrics.Counter
-
dec
public void dec()
- Specified by:
dec
in interfaceorg.apache.flink.metrics.Counter
-
dec
public void dec(long l)
- Specified by:
dec
in interfaceorg.apache.flink.metrics.Counter
-
getCount
public long getCount()
- Specified by:
getCount
in interfaceorg.apache.flink.metrics.Counter
-
-