类 FlinkMeter

  • 所有已实现的接口:
    Serializable, org.apache.seatunnel.api.common.metrics.Meter, org.apache.seatunnel.api.common.metrics.Metric

    public class FlinkMeter
    extends Object
    implements org.apache.seatunnel.api.common.metrics.Meter
    另请参阅:
    序列化表格
    • 构造器详细资料

      • FlinkMeter

        public FlinkMeter​(String name,
                          org.apache.flink.metrics.Meter meter)
    • 方法详细资料

      • markEvent

        public void markEvent()
        指定者:
        markEvent 在接口中 org.apache.seatunnel.api.common.metrics.Meter
      • markEvent

        public void markEvent​(long n)
        指定者:
        markEvent 在接口中 org.apache.seatunnel.api.common.metrics.Meter
      • getRate

        public double getRate()
        指定者:
        getRate 在接口中 org.apache.seatunnel.api.common.metrics.Meter
      • getCount

        public long getCount()
        指定者:
        getCount 在接口中 org.apache.seatunnel.api.common.metrics.Meter
      • name

        public String name()
        指定者:
        name 在接口中 org.apache.seatunnel.api.common.metrics.Metric
      • unit

        public org.apache.seatunnel.api.common.metrics.Unit unit()
        指定者:
        unit 在接口中 org.apache.seatunnel.api.common.metrics.Metric