类 FlinkMeter
- java.lang.Object
-
- org.apache.seatunnel.translation.flink.metric.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(String name, org.apache.flink.metrics.Meter 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
-
-