You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Timo Walther (Jira)" <ji...@apache.org> on 2021/03/26 06:58:00 UTC

[jira] [Created] (FLINK-21989) Add a SupportsSourceWatermark ability interface

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)