[
https://issues.apache.org/jira/browse/FLINK-27993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
HunterHunter updated FLINK-27993:
---------------------------------
Summary: When only use 'Flink SQL' to develop programs, `watermark` can be
defined when creating view tables (was: When only use 'flex SQL' to develop
programs, `watermark` can be defined when creating view tables)
> When only use 'Flink SQL' to develop programs, `watermark` can be defined
> when creating view tables
> ---------------------------------------------------------------------------------------------------
>
> Key: FLINK-27993
> URL: https://issues.apache.org/jira/browse/FLINK-27993
> Project: Flink
> Issue Type: Improvement
> Reporter: HunterHunter
> Priority: Major
>
> When I only use 'flex SQL' to develop programs, I cannot define watermarks
> from view table，I have a data source table a, which has only one field
> `messge`. I need to parse it into others fields(like `time` field), and then
> build a view table, but I have no place to define watermark.
> Or in other scenarios, I need to perform various transformations from a table
> to get the `eventtime` field. Or merge and convert from multiple tables to
> the final table
>
> eg:
> create table A(
> messge string
> ) with( kafka )
> create view table B select udf(messge) as `eventtime` from A.
> I can define `watermark` , as i know, I can only define it when creating a
> table.
>
> My current practice is to mix Table APIs.
>
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
