Uses of Interface
org.apache.flink.streaming.api.operators.source.TimestampsAndWatermarks

Packages that use TimestampsAndWatermarks

Package	Description
org.apache.flink.streaming.api.operators.source

Uses of TimestampsAndWatermarks in org.apache.flink.streaming.api.operators.source

Classes in org.apache.flink.streaming.api.operators.source that implement TimestampsAndWatermarks

Modifier and Type	Class and Description
class	BatchTimestampsAndWatermarks<T> An implementation of TimestampsAndWatermarks to be used during batch execution of a program.
class	StreamingTimestampsAndWatermarks<T> An implementation of timestamp extraction and watermark generation logic for streaming sources.

Methods in org.apache.flink.streaming.api.operators.source that return TimestampsAndWatermarks

Modifier and Type	Method and Description
static <E> TimestampsAndWatermarks<E>	TimestampsAndWatermarks.createBatchEventTimeLogic(WatermarkStrategy<E> watermarkStrategy, MetricGroup metrics)
static <E> TimestampsAndWatermarks<E>	TimestampsAndWatermarks.createStreamingEventTimeLogic(WatermarkStrategy<E> watermarkStrategy, MetricGroup metrics, ProcessingTimeService timeService, long periodicWatermarkIntervalMillis)