Re: How watermark is generated in sql DDL statement

Posted by Benchao Li on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/How-watermark-is-generated-in-sql-DDL-statement-tp34391p34394.html

Hi lec ssmi,

It's a good question. In blink planner, we use code gen to handle watermark expression.

And in `WatermarkAssignerOperator` we calculate current watermark when each element comes in.

If the watermark - lastEmitedWatermark > watermark interval, we will emit the new watermark.

So it's neither `PeriodicWatermark` nor `PunctuatedWatermark`. 

lec ssmi <[hidden email]> 于2020年4月17日周五 下午3:12写道：

Hi:

   In sql API , the declaration of watermark is realized by ddl statement . But which way is it implemented?

   PeriodicWatermark   or   PunctuatedWatermark？

  There seems to be  no explanation on the official website.

   

  Thanks.

--