pyflink.table.catalog.ResolvedSchema.get_watermark_specs

ResolvedSchema.get_watermark_specs() → List[WatermarkSpec]

Returns a list of watermark specifications each consisting of a rowtime attribute and watermark strategy expression.

Note: Currently, there is at most one WatermarkSpec in the list, because we don’t support multiple watermark definitions yet.