Florian Schmidt created FLINK-8478:
--------------------------------------
Summary: 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
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)
