flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "David Anderson (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-8478) Add support for time-bounded joins in DataStream API
Date Fri, 03 Aug 2018 07:36:00 GMT

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

David Anderson commented on FLINK-8478:

Are FLINK-8479 and FLINK-8480 part of Flink 1.6? If so, it seems like it would be helpful
to set their fix versions appropriately so they show up as being included. 

> 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

View raw message