Jark Wu created FLINK-7548:
------------------------------
Summary: Support watermark generation for TableSource
Key: FLINK-7548
URL: https://issues.apache.org/jira/browse/FLINK-7548
Project: Flink
Issue Type: Bug
Components: Table API & SQL
Reporter: Jark Wu
As discussed in FLINK-7446, currently the TableSource only support to define
rowtime field, but not support to extract watermarks from the rowtime field. We
can provide a new interface called {{DefinedWatermark}}, which has two methods
{{getRowtimeAttribute}} (can only be an existing field) and
{{getWatermarkGenerator}}. The {{DefinedRowtimeAttribute}} will be marked
deprecated.
How to support periodic and punctuated watermarks and support some built-in
strategies needs further discussion.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
