FlinkDataStream与DataStreamFusion的join机制原理

JOIN简介

在探讨Flink双流JOIN之前，我们先回顾一下最为常见的MySQL表JOIN操作。对于表JOIN的多种类型，此处不再赘述其具体差异。接下来，我们将分析流式数据的JOIN与传统表JOIN之间的区别，并进行简要介绍。

CROSS JOIN - 交叉连接，用于计算两个数据集的笛卡儿积；

INNER JOIN - 内连接，仅返回符合连接条件的数据记录；

OUTER JOIN

LEFT - 返回左表中的所有行，若右表中无匹配项则以NULL填充；

RIGHT - 返回右表中的所有行，若左表中无匹配项则以NULL填充；

FULL - 返回左表和右表中所有行的并集，若某侧无匹配项则以NULL补充；

SELF JOIN - 自连接，在查询过程中为同一张表赋予不同的别名以实现关联操作。

CROSS JOIN	交叉连接，计算笛卡儿积；
INNER JOIN	内连接，返回满足条件的记录
LEFT JOIN	返回左表所有行，右表不存在补NULL；
RIGHT JOIN	返回右表所有行，左边不存在补NULL；
FULL JOIN	返回左表和右表的并集，不存在一边补NULL;
SELF JOIN	自连接，将表查询时候命名不同的别名

支持的join类型

Apache Flink