- source_watermark() pyflink.table.expression.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.
Please check the documentation whether the connector supports source watermarks.
New in version 1.12.0.