Apache Flink 漫谈系列(13) - Table API 概述

JOIN 用于把来自两个表的行连系起来形成一个宽表，Apache Flink支持的JOIN范例：

• JOIN - INNER JOIN
• LEFT JOIN - LEFT OUTER JOIN
• RIGHT JOIN - RIGHT OUTER JOIN
• FULL JOIN - FULL OUTER JOIN

JOIN与相关代数的Join语义沟通，详细如下：

(1) Table API 示例 (JOIN)

INNER JOIN只选择满意ON前提的记录，我们查询customer_tab 和 order_tab表，将有订单的客户和订单信息选择出来，如下：

val result = customer 
.join(order.select('o_id, 'c_id as 'o_c_id, 'o_time, 'o_desc), 'c_id === 'o_c_id) 

(2)Result：

(3) Table API 示例 (LEFT JOIN)

LEFT JOIN与INNER JOIN的区别是当右表没有与左边相JOIN的数据时辰，右边对应的字段补NULL输出，语义如下：

对应的SQL语句如下(LEFT JOIN)：

SELECT ColA, ColB, T2.ColC, ColE FROM TI LEFT JOIN T2 ON T1.ColC = T2.ColC ; 

仔细的读者也许发明上面T2.ColC是添加了前缀T2了，这里必要声名一下，当两张表有字段名字一样的时辰，我必要指定是从谁人表内里投影的。

（编辑：湖南网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!