关于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 动态表