2022-2023赛季高职大数据竞赛(样题解析)-数据采集与实时计算-任务二:使用Flink处理Kafka中的数据
注:与订单金额计算相关使用order_money字段,同一个订单无需多次重复计算,需要考虑退款或者取消的订单。
编写Scala代码,使用Flink消费Kafka中Topic为ods_mall_log和ods_mall_data的数据并进行相应的数据统计计算(使用ProcessTime)。
点击正文链接,可快速跳转到相应子任务实现部分:
注:与订单金额计算相关使用order_money字段,同一个订单无需多次重复计算,需要考虑退款或者取消的订单。
编写Scala代码,使用Flink消费Kafka中Topic为ods_mall_log和ods_mall_data的数据并进行相应的数据统计计算(使用ProcessTime)。
点击正文链接,可快速跳转到相应子任务实现部分: