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分析
样卷任务说明中，没有给出订单状态分类信息。我们假设订单状 ......
......
抱歉，只有登录会员才可浏览！会员登录
