易坊好文馆

  1. 首页 > 玩科技 >

Flink 1.9 实战：使用 SQL 读取 Kafka 并写入 MySQL( 二 )

这份代码主要由两部分组成：1) 能用来提交 SQL 文件的 SqlSubmit 实现 。 2） 用于演示的 SQL 示例、Kafka 启动停止脚本、 一份测试数据集、Kafka 数据源生成器 。

通过本实战 ， 你将学到：

  1. 如何使用 Blink Planner

  2. 一个简单的 SqlSubmit 是如何实现的

  3. 如何用 DDL 创建一个 Kafka 源表和 MySQL 结果表

  4. 运行一个从 Kafka 读取数据 ， 计算 PVUV ， 并写入 MySQL 的作业

  5. 设置调优参数 ， 观察对作业的影响

SqlSubmit 的实现

笔者一开始是想用 SQL Client 来贯穿整个演示环节 ， 但可惜 1.9 版本 SQL CLI 还不支持处理 CREATE TABLE 语句 。 所以笔者就只好自己写了个简单的提交脚本 。 后来想想 ， 也挺好的 ， 可以让听众同时了解如何通过 SQL 的方式 ， 和编程的方式使用 Flink SQL 。

推荐阅读


上一篇：一本手账漂遍20多座城市 江苏女孩发起手账漂流为“阿中哥哥”庆生

下一篇：“魔豆绣娘”传承非遗手艺带动脱贫，获评CCTV年度慈善人物