原因在于
1 事实表join是需要两头关联的,维表join是 只需要事实流表一方关联
2 维表join可以利用broadcast是方式来实现,当然也可以利用传统的hbase的方式实现
第一遍是初始化中间层
中间表包括broadcast的初始化,其实可以自己写个程序统一读取后放入kafka的topic
第二遍是通过已经初始化好的中间层来关联出宽表,也就是静态的宽表
实时流入
就是将上游的数据再导入到初始化时的topic中
欢迎分享,转载请注明来源:内存溢出
原因在于
1 事实表join是需要两头关联的,维表join是 只需要事实流表一方关联
2 维表join可以利用broadcast是方式来实现,当然也可以利用传统的hbase的方式实现
第一遍是初始化中间层
中间表包括broadcast的初始化,其实可以自己写个程序统一读取后放入kafka的topic
第二遍是通过已经初始化好的中间层来关联出宽表,也就是静态的宽表
实时流入
就是将上游的数据再导入到初始化时的topic中
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)