JingsongLi commented on code in PR #4069:
URL: https://github.com/apache/paimon/pull/4069#discussion_r1732154626
##########
docs/content/flink/procedures.md:
##########
@@ -141,6 +141,26 @@ All available procedures are listed below.
-- for Flink 1.19 and later<br/>
CALL sys.create_tag_from_timestamp(`table` => 'default.T', `tag` =>
'my_tag', `timestamp` => 1724404318750, time_retained => '1 d')
</td>
+ </tr>
+ <tr>
+ <td>create_tag_from_watermark</td>
+ <td>
+ -- Create a tag from the first snapshot whose watermark greater than
the specified timestamp.<br/>
+ CALL [catalog.]sys.create_tag_from_watermark('identifier', 'tagName',
watermark, time_retained)
+ </td>
+ <td>
+ To create a tag based on given watermark timestamp. Arguments:
+ <li>identifier: the target table identifier. Cannot be empty.</li>
+ <li>tag: name of the new tag.</li>
+ <li>timestamp (Long): Find the first snapshot whose watermark
greater than this timestamp.</li>
Review Comment:
watermark?
--
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.
To unsubscribe, e-mail: issues-unsubscr...@paimon.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
