[
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 {
void 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:
{code}
SupportsSourceWatermark {
boolean applySourceWatermark()
}
{code}
> 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 {
> void applySourceWatermark()
> }
> {code}
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
