[ https://issues.apache.org/jira/browse/FLINK-8478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Flink Jira Bot updated FLINK-8478: ---------------------------------- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned (was: auto-deprioritized-major auto-unassigned stale-minor) Priority: Not a Priority (was: Minor) This issue was labeled "stale-minor" 7 days ago and has not received any updates so it is being deprioritized. If this ticket is actually Minor, please raise the priority and ask a committer to assign you the issue or revive the public discussion. > 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: API / DataStream, API / Scala > Reporter: Florian Schmidt > Priority: Not a Priority > Labels: auto-deprioritized-major, auto-deprioritized-minor, > auto-unassigned > > 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 (v8.20.1#820001)