微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

【大数据课程】高途课程实践-Day03:Scala实现商品实时销售统计

〇、概述

1、实现内容

 

使用Scala编写代码,通过Flink的Source、Sink以及时间语义实现实时销量展示

2、过程

(1)导包并下载依赖

(2)创建数据源数据表并写⼊数据

(3)在MysqL数据库中创建统计结果表

(4)编写Flink计算代码

a.参考ShopMysqLSource.scala 代码,进⾏Flink Source 编写,从MysqL读取数据

b.参考GaotuShopFlinkStat.scala代码,进⾏统计逻辑的编写,进⾏Flinksql 查询

c.参考ShopStatMysqLSink.scala 代码,进⾏FlinkSink 编写,存⼊数据到MysqL

一、导包并下载依赖

 

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐