twalthr commented on code in PR #27935:
URL: https://github.com/apache/flink/pull/27935#discussion_r3101104909
##########
docs/content/docs/dev/table/functions/ptfs.md:
##########
@@ -1006,6 +1006,17 @@ class TimerFunction extends ProcessTableFunction<String>
{
{{< /tab >}}
{{< /tabs >}}
+### Handling of Late Records
+
+A late record is a record with a time attribute value that is less than or
equal to the current
+watermark. PTFs handle late records just like non-late records by calling the
`eval()` method.
Review Comment:
keep docs in sync:
```suggestion
watermark. PTFs handle late records just like non-late records by calling
the `eval()` method. If the {@code on_time} argument is specified, the late
timestamp is preserved in
* the output
```
##########
docs/content/docs/dev/table/functions/ptfs.md:
##########
@@ -1006,6 +1006,17 @@ class TimerFunction extends ProcessTableFunction<String>
{
{{< /tab >}}
{{< /tabs >}}
+### Handling of Late Records
Review Comment:
copy this to the Chinese docs as well
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
