Hi devs,

I'd like to start a discussion thread for FLIP-296[1]. This comes from an
offline discussion with @Yun Tang, and we hope to enrich table API & SQL to
support many watermark-related features which were only implemented at the
datastream API level.


Basically, we want to introduce watermark options in table API & SQL via
SQL hint named 'WATERMARK_PARAMS' to support features:

1、Configurable watermark emit strategy

2、Dealing with idle sources

3、Watermark alignment


Last but not least, thanks to Qingsheng and Jing Zhang for the initial
reviews.


Looking forward to your thoughts and any feedback is appreciated!


[1]
https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=240884405


Best

Yuan Kui

Reply via email to