Flink Interval Join Left Join

Flink:1.11

问题

Interval Join Left Outer Join不生效，Web一直显示Join Type为Inner Join

原SQL

    var sqlQuery ="""|insert into for_shop_nt_order_detail| select|   f.id,a.creat_date as create_date,shop_id,a.state,a.name,sale_amount,c.name as city_name,g.login,h.name as user_name,org_names,order_day,f.salesman_id as user_id,f.active_salesman_performance,f.amount_salesman_performance,f.quantity,'done' as order_state| from nt_salesman_performance f| LEFT OUTER JOIN  nt_sale_order a| on a.id = f.order_id | left join lookup_table_sale_shop FOR SYSTEM_TIME AS OF a.proc b| on a.shop_id = b.id| left join lookup_table_city FOR SYSTEM_TIME AS OF a.proc c| on b.city_id = c.id| left join lookup_res_users FOR SYSTEM_TIME AS OF f.proc  g| on f.salesman_id = g.id| left join lookup_res_partner FOR SYSTEM_TIME AS OF f.proc  h| on g.partner_id = h.id| where a.sub_state = 'wait-ship' and a.shipping_state = 'shipped' and f.creat_date BETWEEN a.creat_date - INTERVAL '40' MINUTE AND a.creat_date + INTERVAL '40' MINUTE""".stripMargin

解决方法

把Where条件写在Join后边，如下：

    var sqlQuery ="""|insert into for_shop_nt_order_detail| select|   f.id,a.creat_date as create_date,shop_id,a.state,a.name,sale_amount,c.name as city_name,g.login,h.name as user_name,org_names,order_day,f.salesman_id as user_id,f.active_salesman_performance,f.amount_salesman_performance,f.quantity,'done' as order_state| from nt_salesman_performance f| LEFT OUTER JOIN  nt_sale_order a| on a.id = f.order_id and a.sub_state = 'wait-ship' and a.shipping_state = 'shipped' and f.creat_date BETWEEN a.creat_date - INTERVAL '40' MINUTE AND a.creat_date + INTERVAL '40' MINUTE| left join lookup_table_sale_shop FOR SYSTEM_TIME AS OF a.proc b| on a.shop_id = b.id| left join lookup_table_city FOR SYSTEM_TIME AS OF a.proc c| on b.city_id = c.id| left join lookup_res_users FOR SYSTEM_TIME AS OF f.proc  g| on f.salesman_id = g.id| left join lookup_res_partner FOR SYSTEM_TIME AS OF f.proc  h| on g.partner_id = h.id""".stripMargin

~ v ~

参考

https://github.com/apache/flink/blob/master/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/IntervalJoinITCase.scala

Flink Interval Join Left Join相关推荐

flink中维表Join几种常见方式总结
flink中维表Join 需求如下: 一个主流中数据是用户信息,字段包括用户姓名.城市id: 维表是城市数据,字段包括城市ID.城市名称. 要求用户表与城市表关联,输出为:用户名称.城市ID.城市名称 ...
SQL 中left join ,inner join,right join的区别
2019独角兽企业重金招聘Python工程师标准>>> sql中存在有左连接插入右连接 sql语句 left join ,inner join,right join 进行 wh ...
mysql join null_Mysql Join语法以及性能优化
一．Join语法概述 join 用于多表中字段之间的联系,语法如下: 代码如下: FROM table1 INNER|LEFT|RIGHT JOIN table2 ON conditiona tabl ...
SQL语句中LEFT JOIN、JOIN、INNER JOIN、RIGHT JOIN的区别？
w3school的一套sql教程: http://www.w3school.com.cn/sql/index.asp left join :左连接,返回左表中所有的记录以及右表中连接字段相等的记录. ...
mysql left/right join算法效率分析_mysql left join,right join,inner join超详细用法分析
MySQL left join,right join,inner join超详细用法分析下面是例子分析表A记录如下: aID aNum 1 a20050111 2 ...
图解SQL的inner join（join）、left join、right join、full outer join、union、union all的区别...
对于SQL的Join,在学习起来可能是比较乱的.我们知道,SQL的Join语法有很多inner的,有outer的,有left的,有时候,对于Select出来的结果集是什么样子有点不是很清楚.Codin ...
SQL中的left outer join,inner join,right outer join用法（左右内连接）
SQL语句中的left outer join,inner join,right outer join用法 left outer join=left join , right outer join= ...
inner join 和join的区别_left join、right join和join ？？？
点击上方"JAVA",星标公众号重磅干货,第一时间送达有个困扰说到SQL,很多人可能用了挺久,但依然有个问题一直困扰着,那就是 left join. join. righ ...
cross join 一张表没有值关联不出来数据_你是否还在对left join、right join和join有困扰呢？...
说到SQL,很多人可能用了挺久,但依然有个问题一直困扰着,那就是 left join. join. right join和 inner join等等各种 join的区别.网上搜,最常见的就是一张图解图 ...
SQL-连接查询：left join,right join,inner join,full join之间的区别
参考: https://www.cnblogs.com/lijingran/p/9001302.html https://www.cnblogs.com/assasion/p/7768931.html ...

Flink Interval Join Left Join

问题

原SQL

解决方法

参考

Flink Interval Join Left Join相关推荐

最新文章

热门文章