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)