Timo Walther created FLINK-21989:
------------------------------------
Summary: Add a SupportsSourceWatermark ability interface
Key: FLINK-21989
URL: https://issues.apache.org/jira/browse/FLINK-21989
Project: Flink
Issue Type: Sub-task
Components: Table SQL / API, Table SQL / Planner
Reporter: Timo Walther
Assignee: Timo Walther
FLINK-21899 added a dedicated function that can be used in watermark
definitions. Currently, the generated watermark strategy is invalid because of
the exception that we throw in the function’s implementation. We should
integrate this concept deeper into the interfaces instead of the need to
implement some expression analyzing utility for every source.
We propose the following interface:
SupportsSourceWatermark {
void applySourceWatermark();
}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
