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

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

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

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