| 目录名称 | 目录描述 | 目录名称 | 目录描述 |
|---|---|---|---|
| flink-simpleExample | flink简单例子 | wordcount | sock通信，监听端口内的单词统计 |
| flink-connectors | flink-connectors例子 | flink-kafka | kafka生产者与消费者 |
| flink_SingleMysql | kafka生成数据，kafka消费数据，单条插入Mysql数据库 | ||
| flink_BatchMysql | kafka生成数据，kafka消费数据，批量插入Mysql数据库 | ||
| flink_BatchHBase | kafka生成数据，kafka消费数据，批量插入HBase数据库 | ||
| flink-readSource | flink源码阅读 | WordCount | 流程序的 wordcount 和批程序的 wordcount 执行行行流程分析源码 |
| flink-sql | flink-sql自理 | WordCountSQL | wordcountSQL例子 |
| flink-dataset | flink-dataset学习 | DataSource | 数据加载方式 |
| DataSet | map、join、sort、join、retry的练习 | ||
| DataStream | 没有并行度的stream、有并行度的stream及自定义的stream(实现接口与继承类) | ||
| flink-advanced | flink高级进阶 | restart_distcache | 重启策略和分布式缓存 |
| flink-broadcast | 广播 | ||
| flink-windowWatermark | 窗口、时间及水印(重要！) |
-
个人网站
-
个人微信公众号
