pyflink.table.expressions.source_watermark#

source_watermark() → Expression[source]#

Source watermark declaration for schema.

This is a marker function that doesn’t have concrete runtime implementation. It can only be used as a single expression for watermark strategies in schema declarations. The declaration will be pushed down into a table source that implements the SupportsSourceWatermark interface. The source will emit system-defined watermarks afterwards.