[
https://issues.apache.org/jira/browse/FLINK-5725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15950486#comment-15950486
]
hongyuhong commented on FLINK-5725:
-----------------------------------
Hi [~fhueske], thanks for your feedback. I agree with you that we should break
this issue.
I would like to attach two sub-issues to this issue for the first approach, and
we can attach other step by step:
1.support processing time inner equi-join between two streams
2.support event time inner equi-join between two streams
Certainly {{o.proctime BETWEEN s.proctime - INTERVAL '1' HOUR AND s.proctime +
INTERVAL '1' HOUR}} should be supported, but such as {{o.proctime > s.protime}}
should not be supported because we will need to hold all records. And the time
predicate should include both two stream's proctime attribute or rowtime
attribute, {{o.proctime between proctime() and proctime() + 1}} should also not
be supported.
what do you think?
> 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)
