You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Timo Walther (Jira)" <ji...@apache.org> on 2021/03/26 06:58:00 UTC
[jira] [Updated] (FLINK-21989) Add a SupportsSourceWatermark
ability interface
[ https://issues.apache.org/jira/browse/FLINK-21989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Timo Walther updated FLINK-21989:
---------------------------------
Description:
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:
{code}
SupportsSourceWatermark {
boolean applySourceWatermark()
}
{code}
was:
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();
}
> 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
> Priority: Major
>
> 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:
> {code}
> SupportsSourceWatermark {
> boolean applySourceWatermark()
> }
> {code}
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)