[BEAM-912] Range join in Beam

• Type: New Feature
• Status: Open
• Priority: P3
• Resolution: Unresolved
• Component/s: sdk-ideas
• Assignee: Unassigned
• Reporter: Jingsong Lee
• Created: 04/Nov/16 15:35
• Updated: 03/Jun/22 16:20

Description

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