You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by "Jingsong Lee (JIRA)" <ji...@apache.org> on 2016/11/04 15:35:58 UTC
[jira] [Created] (BEAM-912) Trigger can be more flexible
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)