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