Apache Flink 漫谈系列(10) - JOIN LATERAL

查询结果：

我们发现虽然C001的Customer有三笔订单，但是我们查询的TOP1信息。

• JOIN 写法

SELECT c.customerid, c.city, o.orderid 
FROM Customers c 
JOIN ( 
SELECT 
o2.*, 
     ROW_NUMBER() OVER ( 
        PARTITION BY customerid 
        ORDER BY orderid 
     ) AS rn 
FROM Orders o2 
) o 
ON c.customerid = o.customerid AND o.rn = 1 

查询结果：

如上我们都完成了查询需求，我们在来看一下执行Plan，如下：

我们直观发现完成相同功能，使用CROSS APPLY进行查询，执行Plan简单许多。

2. 功能方面

在功能方面INNER JOIN本身在ANSI-SQL中是不允许 JOIN 一个Function的，这也是SQL Server当时引入CROSS APPLY的根本原因。我们以一个SQL Server中DMV(相当于TVF)查询为例：

SELECT 
name, log_backup_time 
FROM sys.databases AS s 
CROSS APPLY sys.dm_db_log_stats(s.database_id); 

查询结果：

五、Apache Flink对 LATERAL的支持

前面我花费了大量的章节来向大家介绍ANSI-SQL和传统数据库以SQL Server为例如何支持LATERAL的，接下来我们看看Apache Flink对LATERAL的支持情况。

1. Calcite

（编辑：惠州站长网）

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