Jingsong Lee created BEAM-912:
---------------------------------
Summary: Trigger can be more flexible
Key: BEAM-912
URL: https://issues.apache.org/jira/browse/BEAM-912
Project: Beam
Issue Type: New Feature
Components: beam-model
Reporter: Jingsong Lee
Assignee: Frances Perry
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
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
