flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Seth Wiesman (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-7999) Variable Join Window Boundaries
Date Mon, 06 Nov 2017 16:16:00 GMT
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

View raw message