数据采集与实时计算-任务二_使用Flink处理Kafka中的数据
编写Scala工程代码，使用Flink消费Kafka中Topic为order的数据并进行相应的数据统计计算。
子任务1
子任务说明
使用Flink消费Kafka中的数据，统计个人实时订单总额，将key设置成totalprice存入Redis中（再使用hash数据格式，key存放为用户id，value存放为该用户消费总额），使用redis cli以get key方式获取totalprice值，将结果截图粘贴至对应报告中，需两次截图，第一次截图和第二次截图间隔一分钟以上，第一次截图放前面，第二次放后面。
实现原理
实现过程
1) 在IDEA中创建一个Flink Maven项目：Flink102Example。
参考教程：使用IntelliJ IDEA+Maven开发Flink项目。
2) 创建一个Flink流处理程序Task01Job.scala，编辑代码如下：
import org.apache.flink.api.common.serialization ......
......
抱歉，只有登录会员才可浏览！会员登录