I mean re-assigning watermark and timestamp  in sql queries.

Jark Wu <imj...@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 <shicheng31...@gmail.com> wrote:
>
>> can  assignTimestampAndWatermark  again on a  watermarked table?
>>
>> Jark Wu <imj...@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.orh...@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
>>>
>>>
>>>

Reply via email to