nifi-flink
2020-10-21 18:06:22 3 举报实时流架构，Nifi实时采集至大数据Flink实时加工
作者其他创作
大纲/内容
数据抽取方落表数据（方便指标做double check比对）
NIFI Binlog同步DML数据
每张表配置一个topic实时同步
过滤清洗
多流表join
聚合、窗口计算
业务方原始数据表
FlinkSourceKafkaN
Nifi同步层
实时指标落库
Flink计算层
FlinkSourceKafka02
DistributedMapCacheServer数据缓冲通道
Nifi发送表数据变动kafka消息
(每张表对应一个kafkaTopic)
.....
实时数据宽表层
FlinkSourceKafka01
0 条评论
下一页
为你推荐
查看更多
