autophagy commented on code in PR #28657:
URL: https://github.com/apache/flink/pull/28657#discussion_r3534556979
##########
docs/content/docs/dev/table/functions/ptfs.md:
##########
@@ -2703,6 +2701,53 @@ void testPOJO() throws Exception {
{{< top >}}
+### Inspecting Runtime Output with getSystemOutput()
+
+`getOutput()` returns the PTF's declared output. During live operation of
+a PTF, however, the Flink runtime emits a row that also carries generated
columns: for example partition keys
+and pass-through columns, the `rowtime` column is appended when `on_time` is
configured. During testing using
+the harness, you can use `getSystemOutput()` to inspect that full row.
Review Comment:
Good point! Yeah, I think I mix 'system' and 'runtime' a little bit
throughout here so settling on runtime makes sense
--
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]
