flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lec ssmi <shicheng31...@gmail.com>
Subject Re: define WATERMARKS in queries/views?
Date Mon, 27 Apr 2020 01:50:35 GMT
According to my practice,  it seems that  declaring the timestamp and
watermark once again  will not work, sql seems to have no such syntax.
But it's supported in DataStream API.

Leonard Xu <xbjtdcq@gmail.com> 于2020年4月26日周日 下午6:30写道:

>
>
> 在 2020年4月23日,22:03,lec ssmi <shicheng31604@gmail.com> 写道:
>
> can  assignTimestampAndWatermark  again on a  watermarked table?
>
>
> Hi, lec
>
> I’m afraid not, multiple watermark statements is not supported yet,
> If you need multiple watermarks for one table, you can simply create
> multiple tables with different watermark using DDL in you catalog.
>
>
> Best,
> Leonard Xu
>
>
>
> Jark Wu <imjark@gmail.com> 于 2020年4月23日周四 20:18写道:
>
>> Hi Matyas,
>>
>> You can create a new table based on the existing table using LIKE syntax
>> [1] in the upcoming 1.11 version, e.g.
>>
>> CREATE  TABLE derived_table (
>>     WATERMARK FOR tstmp AS tsmp - INTERVAL '5' SECOND
>> ) LIKE base_table;
>>
>> For now, maybe you have to manually create a new table using full DDL.
>>
>> Best,
>> Jark
>>
>> [1]:
>> https://cwiki.apache.org/confluence/display/FLINK/FLIP-110%3A+Support+LIKE+clause+in+CREATE+TABLE
>> <https://cwiki.apache.org/confluence/display/FLINK/FLIP-110:+Support+LIKE+clause+in+CREATE+TABLE>
>>
>> 2020年4月23日 17:35,Őrhidi Mátyás <matyas.orhidi@gmail.com> 写道:
>>
>> Dear Community,
>>
>> is it possible to define WATERMARKS in SQL queries/views? We have a read
>> only catalog implementation and we would like to assign WMs to the tables
>> somehow.
>>
>> Thanks,
>> Matyas
>>
>>
>>
>

Mime
View raw message