[GitHub] [beam] damccorm opened a new issue, #17938: Range join in Beam

[GitBox <gi...@apache.org>]

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: github-unsubscribe@beam.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [beam] damccorm closed issue #17938: Range join in Beam

[GitBox <gi...@apache.org>]

damccorm closed issue #17938: Range join in Beam
URL: https://github.com/apache/beam/issues/17938


-- 
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: github-unsubscribe@beam.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org