pyflink.table.catalog.WatermarkSpec.of

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

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