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)
