实时数据采集和实时计算

1 提出任务

1.1 实时数据采集

1. 在主节点使用 Flume 采集实时数据生成器 10050 端口的 socket 数据，将数据存入到 Kafka 的 Topic 中(Topic 名称为 order，分区数为 4)，使用 Kafka 自带的消费者消费 order(Topic)中的数据，将前 2 条数据的结果截图粘贴至客户端桌面【Release\任务
   D 提交结果.docx】中对应的任务序号下；
2. 采用多路复用模式，Flume 接收数据注入 kafka 的同时，将数据备份到 HDFS 目录/user/test/flumebackup下，将查看备份目录
   下的第一个文件的前 2 条数据的命令与结果截图粘贴至客户端桌面【Release\任务 D 提交结果.docx】中对应的任务序号下。

1.2 使用Flink处理Kafka中的数据

• 编写Scala代码，使用Flink消费Kafka中Topic为order的数据并进行相应的数据统计计算（订单信息对应表结构order_info,订单详细信息对应表结构order_detail（来源类型和来源编号这两个字段不考虑，所以在实时数据中不会出现），同时计算中使用order_info或order_detail表中cre