+1, But I think this should be a more general requirement, that is, support for declaring watermarks in query, which can be declared for any type of source, such as table, view. Similar to databricks provided [1], this needs a FLIP.
[1] https://docs.databricks.com/en/sql/language-manual/sql-ref-syntax-qry-select-watermark.html Best, Ron
