类 FlinkCounter

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

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

      • FlinkCounter

        public FlinkCounter​(String name,
                            org.apache.flink.api.common.accumulators.LongCounter longCounter)
    • 方法详细资料

      • inc

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

        public void inc​(long n)
        指定者:
        inc 在接口中 org.apache.seatunnel.api.common.metrics.Counter
      • dec

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

        public void dec​(long n)
        指定者:
        dec 在接口中 org.apache.seatunnel.api.common.metrics.Counter
      • set

        public void set​(long n)
        指定者:
        set 在接口中 org.apache.seatunnel.api.common.metrics.Counter
      • getCount

        public long getCount()
        指定者:
        getCount 在接口中 org.apache.seatunnel.api.common.metrics.Counter
      • 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