flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Florian Schmidt (JIRA)" <j...@apache.org>
Subject [jira] [Assigned] (FLINK-8478) Add support for time-bounded joins in DataStream API
Date Mon, 29 Jan 2018 16:10:00 GMT

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

Florian Schmidt reassigned FLINK-8478:
--------------------------------------

    Assignee: Florian Schmidt

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

Mime
View raw message