Flink 简易使用教程

Flink 是一款能够同时支持高吞吐/低延迟/高性能的分布式处理框架.

本系列叫做 <Flink简易使用教程>, 目的是记录自己学习 flink 的过程,并且把使用flink的方方面面介绍给大家.尽量用简单的话把使用方法说清楚,在使用某个具体功能的时候能够快速的查找到该使用方法.

本系列的主要例子会从 flink 官方仓库的 example 出发, 通过这些代码来使用 flink 的一些基本操作.

文字部分借鉴**<Flink原理,实战与性能优化>**一书,本书对于初学者十分良好,值得推荐!

1. flink使用01-本系列简介

2. flink使用02-从WordCount开始 (Code Link)

3. flink使用03-数据输入的几种不同方法 (Code Link)

4. flink使用04-几种时间概念和watermark (Code Link)

5. flink使用05-窗口简介和简单的使用 (Code Link)

6. flink使用06-如何处理窗口内的数据 (Code Link)

7. flink使用07-通过join合并流的操作 (Code Link)

8. flink使用08-在dataStream中使用AsyncFunction (Code Link)

9. flink使用09-DataSet初体验之通过Inputformat构建dataSet (Code Link)

10. flink使用10-通过Bulk-iterator计算圆周率 (Code Link)

11. flink使用11-了解broadcast的用法 (Code Link)

12. flink使用12-用 table API 实现WordCount (Code Link)

13. flink使用13-开始体验 Flink SQL (Code Link)

14. flink使用14-使用SQL操作几种window (Code Link)

15. flink使用15-在Flink-SQL中连接kafka和mysql (Code Link)

16. flink使用16-正确打包Flink程序并使用Cli提交任务 (Code Link)

17. flink使用17-如何自定义各种UDF并在SQL中使用 (Code Link)