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)  
    • 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