raminqaf commented on code in PR #28166:
URL: https://github.com/apache/flink/pull/28166#discussion_r3252510534
##########
docs/content/docs/dev/table/functions/ptfs.md:
##########
@@ -1095,6 +1095,8 @@ watermark for the given input table advances, at which
point all buffered rows w
less than or equal to the watermark are delivered to the eval() method in
sorted order. Late
events (arriving after the watermark) are dropped to maintain the ordering
guarantee.
+This pattern is particularly useful for the built-in [`FROM_CHANGELOG`]({{<
ref "docs/sql/reference/queries/changelog" >}}#from_changelog) PTF, which
converts an append-only CDC stream into a changelog. Combining `PARTITION BY`
on the primary key with `ORDER BY` on the event-time column reorders
out-of-order CDC events per key before the operations are applied.
Review Comment:
Addressed
--
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]
