[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16085952#comment-16085952
]
ASF GitHub Bot commented on FLINK-6232:
---------------------------------------
GitHub user fhueske opened a pull request:
https://github.com/apache/flink/pull/4324
[FLINK-6232] [table] Add processing time window inner join to SQL.
This is continuation and extension of PR #3715 and #4266 by @hongyuhong.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/fhueske/flink table-join
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/4324.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #4324
----
commit 10b219678f13c0c21889f97f267dcf4c517045e5
Author: hongyuhong <[email protected]>
Date: 2017-07-06T03:24:04Z
[FLINK-6232] [table] Add support for processing time inner windowed stream
join.
commit 3d671a2d1867aea2f3d4eee30b2772045917d6d4
Author: Fabian Hueske <[email protected]>
Date: 2017-07-12T22:49:30Z
[FLINK-6232] [table] Add SQL documentation for time window join.
- Add support for window join predicates in WHERE clause.
- Refactoring of WindowJoinUtil.
- Minor refactorings of join classes.
----
> Support proctime inner equi-join between two streams in the SQL API
> -------------------------------------------------------------------
>
> Key: FLINK-6232
> URL: https://issues.apache.org/jira/browse/FLINK-6232
> Project: Flink
> Issue Type: Sub-task
> Components: Table API & SQL
> Reporter: hongyuhong
> Assignee: hongyuhong
>
> The goal of this issue is to add support for inner equi-join on proc time
> streams to the SQL interface.
> Queries similar to the following should be supported:
> {code}
> SELECT o.proctime, o.productId, o.orderId, s.proctime AS shipTime
> FROM Orders AS o
> JOIN Shipments AS s
> ON o.orderId = s.orderId
> AND o.proctime BETWEEN s.proctime AND s.proctime + INTERVAL '1' HOUR;
> {code}
> The following restrictions should initially apply:
> * The join hint only support inner join
> * The ON clause should include equi-join condition
> * The time-condition {{o.proctime BETWEEN s.proctime AND s.proctime +
> INTERVAL '1' HOUR}} only can use proctime that is a system attribute, the
> time condition only support bounded time range like {{o.proctime BETWEEN
> s.proctime - INTERVAL '1' HOUR AND s.proctime + INTERVAL '1' HOUR}}, not
> support unbounded like {{o.proctime > s.protime}}, and should include both
> two stream's proctime attribute, {{o.proctime between proctime() and
> proctime() + 1}} should also not be supported.
> This issue includes:
> * Design of the DataStream operator to deal with stream join
> * Translation from Calcite's RelNode representation (LogicalJoin).
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
