JingsongLi commented on a change in pull request #10733:
[FLINK-15446][table][docs] Improve "Connect to External Systems" documentation
page
URL: https://github.com/apache/flink/pull/10733#discussion_r362377321
##########
File path: docs/dev/table/connect.md
##########
@@ -500,6 +501,39 @@ rowtime:
The following watermark strategies are supported:
<div class="codetabs" markdown="1">
+<div data-lang="DDL" markdown="1">
+{% highlight sql %}
+-- Sets a watermark strategy for strictly ascending rowtime attributes. Emits
a watermark of the
+-- maximum observed timestamp so far. Rows that have a timestamp smaller to
the max timestamp
+-- are not late.
+CREATE TABLE MyTable (
+ ts_field TIMESTAMP(3),
+ WATERMARK FOR ts_field AS ts_field
+) WITH (
+ ...
+)
+
+-- Sets a watermark strategy for ascending rowtime attributes. Emits a
watermark of the maximum
+-- observed timestamp so far minus 1. Rows that have a timestamp equal to the
max timestamp
+-- are not late.
+CREATE TABLE MyTable (
+ ts_field TIMESTAMP(3),
+ WATERMARK FOR ts_field AS ts_field - INTERVAL '0.001' SECOND
Review comment:
Why not same to Java/Scala?
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
With regards,
Apache Git Services
