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)

Reply via email to