[jira] [Updated] (FLINK-8478) Add support for time-bounded joins in DataStream API

["Florian Schmidt (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-8478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Florian Schmidt updated FLINK-8478:
-----------------------------------
    Labels:   (was: pull-request-available)

> Add support for time-bounded joins in DataStream API
> ----------------------------------------------------
>
>                 Key: FLINK-8478
>                 URL: https://issues.apache.org/jira/browse/FLINK-8478
>             Project: Flink
>          Issue Type: New Feature
>          Components: DataStream API, Java API, Scala API
>            Reporter: Florian Schmidt
>            Assignee: Florian Schmidt
>            Priority: Major
>
> The goal is to implement a DataStream API to join together two streams based on a key and user defined time boundaries. 
> This feature should mirror what is already possible in Flink SQL:
> {code:java}
> SELECT s1.value, s2.value FROM Table s1 JOIN Table s2 ON o.key = s.key AND o.rowtime BETWEEN s.rowtime AND s.rowtime + INTERVAL '1' HOUR;
> {code}



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)