flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jark Wu <imj...@gmail.com>
Subject Re: define WATERMARKS in queries/views?
Date Sun, 26 Apr 2020 03:04:23 GMT
Hi Lec,

It's supported in SQL queries.

Best,
Jark

On Sun, 26 Apr 2020 at 09:10, lec ssmi <shicheng31604@gmail.com> wrote:

> I mean re-assigning watermark and timestamp  in sql queries.
>
> Jark Wu <imjark@gmail.com> 于2020年4月25日周六 下午9:10写道:
>
>> Hi Lec,
>>
>> You can only define `assignTimestampAndWatermark` on DataStream, so you
>> have to convert `Table` into DataStream first.
>> If the DataStream already has been assigned watermark, then the new
>> `assignTimestampAndWatermark` will override the previous watermark.
>>
>> Best,
>> Jark
>>
>> On Thu, 23 Apr 2020 at 22:03, lec ssmi <shicheng31604@gmail.com> wrote:
>>
>>> can  assignTimestampAndWatermark  again on a  watermarked table?
>>>
>>> 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