关于flink:flink多流join

多流 join

实时计算的 JOIN 和传统批处理 JOIN 的语义统一，都用于将两张表分割起来。区别的是实时计算分割的是两张动静表，分割的后果也会动静更新以保障最终后果和批处理后果保持一致。

场景形容

订单表动静关联商品表，关联字段为商品 id，输入关联后的宽表，源表数据样例如下所示。

订单表：

商品表：

-- 多流 join
 
-- 2019-10-22 11:42:04
 
-- moxian
 
-- 实时计算的 JOIN 和传统批处理 JOIN 的语义统一，都用于将两张表分割起来。区别的是实时计算分割的是两张动静表，分割的后果也会动静更新以保障最终后果和批处理后果保持一致。INSERT INTO mx_stream2stream
 
SELECT 
 
 o.rt as rowtime,
 
 o.productId as productId,
 
 o.orderId as orderId,
 
 o.units as units,
 
 p.name as category,
 
 cast(p.unitPrice as int) as unitPrice
 
FROM orders o -- 源表 1 订单表
 
JOIN products p -- 源表 2 产品表
 
ON o.productId = p.productId;

留神：

1. 订单表是动静的，产品示意动态的，动静表 join 动态表