《Flink实战教程》

一、Flink部署与开发

• 第001章：第四代通用大数据处理引擎简介

• 第002章：StandAlone模式下集群无HA部署实战

• 第003章：StandAlone模式下集群有HA部署实战

• 第004章：FlinkOnYarn模式下集群最简部署实战

• 第005章：基于IntelliJ IDEA搭建不用maven管理的集成开发环境

• 第006章：基于IntelliJ IDEA搭建使用maven管理的集成开发环境

二、Flink批处理API详解与编程实战

• 第007章：DateSet实用API详解一

• 第008章：DateSet实用API详解二

• 第009章：DateSet实用API详解三

• 第010章：DateSet实用API详解四

• 第011章：DataSet实用Function详解(Scala版)

• 第012章：DataSet实用Function详解(Java版)

三、Flink高级特性与高级应用

• 第013章：Flink的内存管理

• 第014章：Flink的作业调度情况

• 第015章：Slot和Parallelism的深入分析

• 第016章：Flink在批处理中常见的sink和source

• 第017章：Flink中广播变量和分布式缓存

• 第018章：Flink中参数传递和容错设定

• 第019章：Flink中OutFormat设置(Scala版)

四、Flink流处理API详解与编程实战

• 第000章：Flink基于流的wordcount示例

• 第000章：Flink基于流的window操作

• 第000章：DataStream与MySql自定义sink和source(Scala版)

• 第000章：DataStream与MySql自定义sink和source(Java版)

• 第000章：Flink在流处理中常见的sink和source

五、待整理部分

• 第000章：Flink基于流的SessionWindow操作

• 第000章：Flink基于流的windowAndFunction操作

• 第000章：Flink基于流的watermark操作

• 第000章：Flink基于流的join操作

• 第000章：Flink基于流的checkpoint操作

• 第000章：Flink基于流的customSource操作

• 第000章：flink的背压机制

• 第000章：error

• 第000章：data

• 第000章：other

/Users/liguohua/Documents/F/code/idea/git/simple-flink/book/

六、重点参考链接：

https://www.oreilly.com/ideas/the-world-beyond-batch-streaming-101
https://www.oreilly.com/ideas/the-world-beyond-batch-streaming-102
http://data-artisans.com/blog/
http://data-artisans.com/how-apache-flink-enables-new-streaming-applications-part-1/
http://data-artisans.com/how-apache-flink-enables-new-streaming-applications/
http://data-artisans.com/session-windowing-in-flink/

七、TODO LIST

批处理：
累加器
/Users/liguohua/Documents/F/code/idea/git/simple-flink/src/main/scala/code/book/batch/outputformat

/Users/liguohua/Documents/F/code/idea/git/simple-flink/src/main/scala/code/book/stream/window/advance/EventTimeExample02.scala