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

2023年国赛_赛项规程样题解析-数据采集与实时计算_子任务二:使用Flink处理Kafka中的数据

编写Scala代码,使用Flink消费Kafka中Topic为order的数据并进行相应的数据统计计算(订单信息对应表结构order_info,订单详细信息对应表结构order_detail,同时计算中使用order_info或order_detail表中create_time或operate_time取两者中值较大者作为EventTime,若operate_time为空值或无此列,则使用create_time填充,允许数据延迟5s)。

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

子任务1

子任务1说明

1. 使用Flink消费Kafka中的数据,统计商城实时订单实收金额,将key设置成totalprice存入Redis中。使用redis cli以get key方式获取totalprice值,将结果截图粘贴至客户端桌面【Release\任务D提交结果.docx】中对应的任务序号下,需两次截图,第一次截图和第二次截图间隔1分钟以上,第一次截图放前面,第二次截图放后面;

子任务1分析

样卷任务说明中,没有给出订单状态分类信息。我们假设订单状态分别为“1001:创建订单、1002:支付订单、1003:取消订单、1004:完成订单、1005:申请退回、1006:退回完 ......

......

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


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