You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "godfrey he (JIRA)" <ji...@apache.org> on 2019/04/13 11:04:00 UTC

[jira] [Created] (FLINK-12185) Add support for generating optimized logical plan for join on stream

godfrey he created FLINK-12185:
----------------------------------

             Summary: Add support for generating optimized logical plan for join on stream
                 Key: FLINK-12185
                 URL: https://issues.apache.org/jira/browse/FLINK-12185
             Project: Flink
          Issue Type: New Feature
          Components: Table SQL / Planner
            Reporter: godfrey he
            Assignee: godfrey he


This issue aims to supports generating optimized plan for join on stream. 
The query will be converted to window join if join condition contains window bounds, otherwise will be converted to normal join.

e.g.
Queries similar to the following should be window join:
{code:sql}
SELECT t1.a, t2.b FROM MyTable t1 JOIN MyTable2 t2 ON
    t1.a = t2.a AND
    t1.proctime BETWEEN t2.proctime - INTERVAL '1' HOUR AND t2.proctime + INTERVAL '1' HOUR
{code}




--
This message was sent by Atlassian JIRA
(v7.6.3#76005)