damccorm opened a new issue, #17938: URL: https://github.com/apache/beam/issues/17938
1.We can support some data-driven trigger, so we need expose data in OnElementContext of onElement method. 2.We can support more flexible join, so we need expose buffer tag in TriggerContext, now this buffer tag is in SystemReduceFn. for example: SELECT STREAM * FROM Orders AS o JOIN Shipments AS s ON o.orderId = s.orderId AND s.rowtime BETWEEN o.rowtime AND o.rowtime **** INTERVAL '1' HOUR; link: https://issues.apache.org/jira/browse/BEAM-101 Imported from Jira [BEAM-912](https://issues.apache.org/jira/browse/BEAM-912). Original Jira may contain additional context. Reported by: lzljs3620320. -- 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]
