HunterHunter created FLINK-27993:
------------------------------------
Summary: When only use 'flex 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
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)