多流join
实时计算的JOIN和传统批处理JOIN的语义统一,都用于将两张表分割起来。区别的是实时计算分割的是两张动静表,分割的后果也会动静更新以保障最终后果和批处理后果保持一致。
场景形容
订单表动静关联商品表,关联字段为商品id,输入关联后的宽表,源表数据样例如下所示。
订单表:
商品表:
-- 多流join-- 2019-10-22 11:42:04-- moxian-- 实时计算的JOIN和传统批处理JOIN的语义统一,都用于将两张表分割起来。区别的是实时计算分割的是两张动静表,分割的后果也会动静更新以保障最终后果和批处理后果保持一致。INSERT INTO mx_stream2streamSELECT 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 unitPriceFROM orders o --源表1 订单表JOIN products p --源表2 产品表ON o.productId = p.productId;
留神:
- 订单表是动静的,产品示意动态的,动静表join动态表