[ 
https://issues.apache.org/jira/browse/FLINK-7999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16241303#comment-16241303
 ] 

Xingcan Cui commented on FLINK-7999:
------------------------------------

Hi [~sjwiesman], thanks for opening this. Could you give some more specific 
explanations about this kind of join?

Thanks, Xingcan

> 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)

Reply via email to