pyflink.table.catalog.WatermarkSpec.of

static WatermarkSpec.of(rowtime_attribute: str, watermark_expression: pyflink.table.resolved_expression.ResolvedExpression)

Creates a WatermarkSpec from a given rowtime attribute and a watermark expression.