flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Aljoscha Krettek (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-8478) Add support for time-bounded joins in DataStream API
Date Mon, 06 Aug 2018 08:38:01 GMT

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

Aljoscha Krettek commented on FLINK-8478:
-----------------------------------------

[~alpinegizmo] done

> 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
>              Labels: pull-request-available
>
> 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