Class 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 safe Counter 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)  
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • SynchronizedCounter

        public SynchronizedCounter​(org.apache.flink.metrics.Counter delegate)
    • Method Detail

      • inc

        public void inc()
        Specified by:
        inc in interface org.apache.flink.metrics.Counter
      • inc

        public void inc​(long l)
        Specified by:
        inc in interface org.apache.flink.metrics.Counter
      • dec

        public void dec()
        Specified by:
        dec in interface org.apache.flink.metrics.Counter
      • dec

        public void dec​(long l)
        Specified by:
        dec in interface org.apache.flink.metrics.Counter
      • getCount

        public long getCount()
        Specified by:
        getCount in interface org.apache.flink.metrics.Counter