logo

小白学苑PBCP

PBCP, 让大数据竞赛更简单!

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】中对应的任务序号下,需两次截图,第一次截图和第 ......

......

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