事实表流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到存储里。请问大家有别的更好做法吗

回复