〇、概述
1、实现内容
使用Scala编写代码,通过Flink的Source、Sink以及时间语义实现实时销量展示
2、过程
(1)导包并下载依赖
(2)创建数据源数据表并写⼊数据
(4)编写Flink计算代码
a.参考ShopMysqLSource.scala 代码,进⾏Flink Source 编写,从MysqL读取数据
b.参考GaotuShopFlinkStat.scala代码,进⾏统计逻辑的编写,进⾏Flinksql 查询
c.参考ShopStatMysqLSink.scala 代码,进⾏FlinkSink 编写,存⼊数据到MysqL
一、导包并下载依赖