pyflink.datastream.data_stream.DataStream.assign_timestamps_and_watermarks

DataStream.assign_timestamps_and_watermarks(watermark_strategy: WatermarkStrategy) → DataStream

Assigns timestamps to the elements in the data stream and generates watermarks to signal event time progress. The given {@link WatermarkStrategy} is used to create a TimestampAssigner and WatermarkGenerator.

Parameters:

watermark_strategy – The strategy to generate watermarks based on event timestamps.

Returns:

The stream after the transformation, with assigned timestamps and watermarks.