pyflink.datastream.data_stream.DataStream.assign_timestamps_and_watermarks

DataStream.assign_timestamps_and_watermarks(watermark_strategy: pyflink.common.watermark_strategy.WatermarkStrategy) → pyflink.datastream.data_stream.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.