flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "radu (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-5725) Support JOIN between two streams in the SQL API
Date Thu, 30 Mar 2017 21:38:41 GMT

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

radu commented on FLINK-5725:
-----------------------------

[~fhueske] [~shijinkui] [~Yuhong_kyo] [~sunjincheng121] [~twalthr] [~stefano.bortoli]

After the design document is revised i proposed that before we start breaking down the Join
implementation/contribution we should first contribute the skeleton:
the rule and the DataStreamRel with the different cases that exist
match{
joinOnProcTime 
       match{
              INNER
              FULL     
              LEFT
              RIGHT
     }
joinOnEventTIme
         match{
              INNER
              FULL     
              LEFT
              RIGHT
     }
joinOnKeyAttribute
match{
              INNER
              FULL     
              LEFT
              RIGHT
     }
}

...not sure if i missed any case. However, this schema would organize the commits in case
multiple people would contribute to the issue

> Support JOIN between two streams in the SQL API
> -----------------------------------------------
>
>                 Key: FLINK-5725
>                 URL: https://issues.apache.org/jira/browse/FLINK-5725
>             Project: Flink
>          Issue Type: New Feature
>          Components: Table API & SQL
>            Reporter: Haohui Mai
>            Assignee: hongyuhong
>
> As described in the title.
> This jira proposes to support joining two streaming tables in the SQL API.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

Mime
View raw message