You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Seth Wiesman (JIRA)" <ji...@apache.org> on 2017/11/06 16:16:00 UTC

[jira] [Created] (FLINK-7999) Variable Join Window Boundaries

Seth Wiesman created FLINK-7999:
-----------------------------------

             Summary: Variable Join Window Boundaries
                 Key: FLINK-7999
                 URL: https://issues.apache.org/jira/browse/FLINK-7999
             Project: Flink
          Issue Type: New Feature
          Components: Table API & SQL
            Reporter: Seth Wiesman


Allow window joins with variable length based on row attributes. 

Consider a two streams joined on an id, where one has start and end dates, it would be useful to be able to join each row during is live durations. Today this can be expressed in the datastream api using a CoProcessFunction. 

 left.id = right.id AND (left.time > right.start and left.time < right.end)




--
This message was sent by Atlassian JIRA
(v6.4.14#64029)