com.zto.fire.flink.ext.watermark

类 FirePeriodicWatermarks<T>

java.lang.Object

com.zto.fire.flink.ext.watermark.FirePeriodicWatermarks<T>

所有已实现的接口:

Serializable, org.apache.flink.api.common.eventtime.TimestampAssigner<T>, org.apache.flink.api.common.functions.Function, org.apache.flink.streaming.api.functions.AssignerWithPeriodicWatermarks<T>

已过时。

@Deprecated
public abstract class FirePeriodicWatermarks<T>
extends Object
implements org.apache.flink.streaming.api.functions.AssignerWithPeriodicWatermarks<T>

基于AssignerWithPeriodicWatermarks的封装 有参的构造方法允许定义允许的最大乱序时间（单位ms） maxTimestamp用于自定义水位线的时间，若不指定，则以系统当前时间为水位线值

作者:

ChengLong 2020-4-17 17:18:33

另请参阅:

序列化表格

字段概要

字段

限定符和类型	字段和说明
protected long	maxOutOfOrder 已过时。
protected long	maxTimestamp 已过时。
protected org.apache.flink.streaming.api.watermark.Watermark	watermark 已过时。

从接口继承的字段 org.apache.flink.api.common.eventtime.TimestampAssigner

NO_TIMESTAMP

构造器概要

构造器

限定符	构造器和说明
protected	FirePeriodicWatermarks() 已过时。
protected	FirePeriodicWatermarks(long maxOutOfOrder) 已过时。 用于自定义允许最大的乱序时间

方法概要

限定符和类型	方法和说明
org.apache.flink.streaming.api.watermark.Watermark	getCurrentWatermark() 已过时。 计算并返回当前的水位线 如果未指定水位线的时间戳，则默认获取当前系统时间

从类继承的方法 java.lang.Object

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

从接口继承的方法 org.apache.flink.streaming.api.functions.TimestampAssigner

extractTimestamp

字段详细资料

maxTimestamp

protected long maxTimestamp

已过时。

maxOutOfOrder

protected long maxOutOfOrder

已过时。

watermark

protected transient org.apache.flink.streaming.api.watermark.Watermark watermark

已过时。

构造器详细资料

FirePeriodicWatermarks

protected FirePeriodicWatermarks()

已过时。

FirePeriodicWatermarks

protected FirePeriodicWatermarks(long maxOutOfOrder)

已过时。

用于自定义允许最大的乱序时间

参数:

maxOutOfOrder - 用户定义的最大乱序时间

方法详细资料

getCurrentWatermark

public org.apache.flink.streaming.api.watermark.Watermark getCurrentWatermark()

已过时。

计算并返回当前的水位线 如果未指定水位线的时间戳，则默认获取当前系统时间

指定者:

getCurrentWatermark 在接口中 org.apache.flink.streaming.api.functions.AssignerWithPeriodicWatermarks<T>