twalthr commented on code in PR #28065: URL: https://github.com/apache/flink/pull/28065#discussion_r3160811714
########## docs/content.zh/docs/dev/table/functions/ptfs.md: ########## @@ -1363,6 +1363,38 @@ This allows the PTF to focus on the main aggregation without the need to manuall *Note*: Pass-through columns are only available for append-only PTFs taking a single table argument and don't use timers. +The `ArgumentTrait.NO_PASS_THROUGH` instructs the system to omit all framework-added columns. The output is fully +controlled by the function's declared output type. + +By default, the framework prepends the `PARTITION BY` columns and appends a `rowtime` column when `on_time` is provided. Review Comment: The `rowtime` column is not a pass-through column. The value depends on both the incoming on_time value OR the timer firing value. If we don't output it, following temporal operations become unavailable. It is possible to disable `on_time` for this purpose (via TypeInference.disableSystemArgs) or just don't pass on_time to the call. Therefore, there is an alternative for the user I would vote for only handling the partition key. -- 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]
