pyflink.table.expressions.source_watermark

source_watermark() → pyflink.table.expression.Expression

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.

Please check the documentation whether the connector supports source watermarks.

New in version 1.12.0.