Jark Wu created FLINK-14325: ------------------------------- Summary: Convert CatalogTable to TableSourceTable with additional watermark information Key: FLINK-14325 URL: https://issues.apache.org/jira/browse/FLINK-14325 Project: Flink Issue Type: Sub-task Components: Table SQL / Planner Reporter: Jark Wu
Pass the watermark information (named {{WatermarkSpec}}) into {{TableSourceTable}} when {{DatabaseCalciteSchema#convertCatalogTable}}. We should also update the {{TableSourceTable#getRowType}} because the rowtime field should be marked as rowtime indicator type. -- This message was sent by Atlassian Jira (v8.3.4#803005)