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

Class OperatorMetricUtils.SynchronizedMeterView

  • All Implemented Interfaces:
    org.apache.flink.metrics.Meter, org.apache.flink.metrics.Metric, org.apache.flink.metrics.View
    Enclosing class:
    OperatorMetricUtils
    public static class OperatorMetricUtils.SynchronizedMeterView
extends java.lang.Object
implements org.apache.flink.metrics.Meter, org.apache.flink.metrics.View
    Thread safe MeterView wrapper.

    • Field Summary

      • Fields inherited from interface org.apache.flink.metrics.View

        UPDATE_INTERVAL_SECONDS

    • Constructor Summary

      Constructors 
      Constructor Description
      SynchronizedMeterView​(org.apache.flink.metrics.MeterView delegate)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      long getCount()  
      double getRate()  
      void markEvent()  
      void markEvent​(long l)  
      void update()  

      • Methods inherited from class java.lang.Object

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

      • Methods inherited from interface org.apache.flink.metrics.Meter

        getMetricType

    • Constructor Detail

      • SynchronizedMeterView

        public SynchronizedMeterView​(org.apache.flink.metrics.MeterView delegate)

    • Method Detail

      • markEvent

        public void markEvent()
        Specified by:
        markEvent in interface org.apache.flink.metrics.Meter

      • markEvent

        public void markEvent​(long l)
        Specified by:
        markEvent in interface org.apache.flink.metrics.Meter

      • getRate

        public double getRate()
        Specified by:
        getRate in interface org.apache.flink.metrics.Meter

      • getCount

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

      • update

        public void update()
        Specified by:
        update in interface org.apache.flink.metrics.View