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)