Flink原理、实战与性能优化

封面

版权信息

前言

致谢

第1章 Apache Flink介绍

1.1 Apache Flink是什么

1.2 数据架构的演变

1.3 Flink应用场景

1.4 Flink基本架构

1.5 本章小结

第2章 环境准备

2.1 运行环境介绍

2.2 Flink项目模板

2.3 Flink开发环境配置

2.4 运行Scala REPL

2.5 Flink源码编译

2.6 本章小结

第3章 Flink编程模型

3.1 数据集类型

3.2 Flink编程接口

3.3 Flink程序结构

3.4 Flink数据类型

3.5 本章小结

第4章 DataStream API介绍与使用

4.1 DataStream编程模型

4.2 时间概念与Watermark

4.3 Windows窗口计算

4.4 作业链和资源组

4.5 Asynchronous I/O异步操作

4.6 本章小结

第5章 Flink状态管理和容错

5.1 有状态计算

5.2 Checkpoints和Savepoints

5.3 状态管理器

5.4 Querable State

5.5 本章小结

第6章 DataSet API介绍与使用

6.1 DataSet API

6.2 迭代计算

6.3 广播变量与分布式缓存

6.4 语义注解

6.5 本章小结

第7章 Table API & SQL介绍与使用

7.1 TableEnviroment概念

7.2 Flink Table API

7.3 Flink SQL使用

7.4 自定义函数

7.5 自定义数据源

7.6 本章小结

第8章 Flink组件栈介绍与使用

8.1 Flink复杂事件处理

8.2 Flink Gelly图计算应用

8.3 FlinkML机器学习应用

8.4 本章小结

第9章 Flink部署与应用

9.1 Flink集群部署

9.2 Flink高可用配置

9.3 Flink安全管理

9.4 Flink集群升级

9.5 本章小结

第10章 Flink监控与性能优化

10.1 监控指标

10.2 Backpressure监控与优化

10.3 Checkpointing监控与优化

10.4 Flink内存优化