使用Flink处理Kafka中的数据_题库子任务4、5、6_Java语言实现
注：与订单金额计算相关使用order_money字段，同一个订单无需多次重复计算，需要考虑退款或者取消的订单。
编写Java代码，使用Flink消费Kafka中Topic为ods_mall_log和ods_mall_data的数据并进行相应的数据统计计算(使用ProcessTime）。
点击正文链接，可快速跳转到相应子任务实现部分：
子任务4
子任务4描述
4、使用Flink消费Kafka的dwd层数据，统计商城实时订单数量，将key设置成totalcount存入Redis中。使用redis cli以get key方式获取totalcount值；
实现原理
本案例实现原理如下图所示：
子任务4分析
因为要求“同一个订单无需多次重复计算，需要考虑退款或者取消的订单”，所以取订单状态为“已下单”的参与计算。
为了保证总销量的正确性，所以把 ......
......
抱歉，只有登录会员才可浏览！会员登录
