抱歉,只有登录会员才可浏览!<a href='/member/login'>会员登录</a>

2022-2023赛季高职大数据竞赛(样题解析)-数据采集与实时计算-任务二:使用Flink处理Kafka中的数据

注:与订单金额计算相关使用order_money字段,同一个订单无需多次重复计算,需要考虑退款或者取消的订单。

编写Scala代码,使用Flink消费Kafka中Topic为ods_mall_log和ods_mall_data的数据并进行相应的数据统计计算(使用ProcessTime)。

点击正文链接,可快速跳转到相应子任务实现部分:

子任务1

子任务1描述

1、使用Flink消费Kafka中topic为ods_mall_data的数据,根 ......

......

抱歉,只有登录会员才可浏览!会员登录


《PySpark原理深入与编程实战》