Uses of Interface
org.apache.flink.streaming.api.functions.AssignerWithPeriodicWatermarks

Packages that use AssignerWithPeriodicWatermarks

Package	Description
org.apache.flink.streaming.api.datastream
org.apache.flink.streaming.api.functions
org.apache.flink.streaming.api.functions.timestamps
org.apache.flink.streaming.runtime.operators.util

Uses of AssignerWithPeriodicWatermarks in org.apache.flink.streaming.api.datastream

Methods in org.apache.flink.streaming.api.datastream with parameters of type AssignerWithPeriodicWatermarks

Modifier and Type	Method	Description
SingleOutputStreamOperator<T>	DataStream.assignTimestampsAndWatermarks(AssignerWithPeriodicWatermarks<T> timestampAndWatermarkAssigner)	Deprecated. Please use DataStream.assignTimestampsAndWatermarks(WatermarkStrategy) instead.

Uses of AssignerWithPeriodicWatermarks in org.apache.flink.streaming.api.functions

Classes in org.apache.flink.streaming.api.functions that implement AssignerWithPeriodicWatermarks

Modifier and Type	Class	Description
class	AscendingTimestampExtractor<T>	Deprecated. Extend AscendingTimestampExtractor instead.
class	IngestionTimeExtractor<T>	Deprecated.

Uses of AssignerWithPeriodicWatermarks in org.apache.flink.streaming.api.functions.timestamps

Classes in org.apache.flink.streaming.api.functions.timestamps that implement AssignerWithPeriodicWatermarks

Modifier and Type	Class	Description
class	AscendingTimestampExtractor<T>	Deprecated.
class	BoundedOutOfOrdernessTimestampExtractor<T>	This is a AssignerWithPeriodicWatermarks used to emit Watermarks that lag behind the element with the maximum timestamp (in event time) seen so far by a fixed amount of time, t_late.

Uses of AssignerWithPeriodicWatermarks in org.apache.flink.streaming.runtime.operators.util

Constructors in org.apache.flink.streaming.runtime.operators.util with parameters of type AssignerWithPeriodicWatermarks

Constructor	Description
AssignerWithPeriodicWatermarksAdapter(AssignerWithPeriodicWatermarks<T> wms)
Strategy(AssignerWithPeriodicWatermarks<T> wms)