Re: 维度表变化，关联结果全部更新在Flink SQL该如何实现

[zns]

Cdc join

> 2022年3月21日 14:01，JianWen Huang <jianwen.huang....@gmail.com> 写道：
> 
> 事实表流A需关联维度表B做数据打宽。需求是当纬度表B发生变化时，关联结果需全部发生变化更新到最新。
> 例子:
> 变化前：
> A流：
> name  gender
> a         male
> b         male
> c         female
> 
> 纬度表B：
> name    age
> a           16
> b            17
> 
> 结果：
> name   gender   age
> a           male      16
> b           male     17
> 
> 发生变化后：
> 纬度表B：
> name    age
> a           16->17
> b            17->18
> 
> 结果：
> name   gender   age
> a           male      17
> b           male      18
> 
> 目前我想到一个做法是将维度表做成流然后关联事实表，最后根据更新时间取top1最新sink到存储里。请问大家有别的更好做法吗