本期示例： 将对电商实时订单进行聚合计算，分以下两个维度进行： 1. 统计每 1 分钟的订单数量、用户数量、销售额、商品数 2. 统计每个分类的订单总数量、用户总数量（未去重）、销售额、商品数 流程说明： 1. 通过模拟电商平台订单简要数据，向 Kafka 消息队列中推送 mq 数据； 2. 通过 flink 集群，建立 SQL 流批处理任务； 3.Kafka 做为 SQL 数据流的输入源，并建立 source 数据表； 4. 通过 SQL 建立查询视图，将聚合算子的结果通过视图输出； 5.Mysql 做为 SQL 数据流的输出源，并建立 sink 数据表； 6. 执行 insert 操作，并在 flink 集群中建立 Task Job 任务，将聚合结果视图输出到 sink 表； 操作过程 1. 前期准备工作 1. 搭建 Flink 集群，保持集群可用，并处于启动状态 2. 开启 flink-sql-client 客户端 3. 搭建 Kafka 消息队列中间件服务，并启动服务，保持 9092 端口可连接 4. 创建 mysql 数据库相关表 5.
