Flink技术内幕：架构设计与实现原理

封面

版权信息

内容简介

作者简介

推荐语

前言

第1章 阅读Flink源代码前的准备

1.1 环境准备

1.2 获取、编译和调试Flink的源代码

1.3 Flink源代码的目录结构

1.4 Flink设计理念与基本架构

1.5 本章小结

第2章 编程模型与API

2.1 DataStream

2.2 算子

2.3 窗口

2.4 本章小结

第3章 运行时组件与通信

3.1 运行时组件

3.2 组件间通信

3.3 运行时组件的高可用

3.4 本章小结

第4章 状态管理与容错

4.1 状态

4.2 检查点

4.3 状态后端

4.4 本章小结

第5章 任务提交与执行

5.1 任务提交整体流程

5.2 DAG转换

5.3 Slot分配

5.4 任务执行机制

5.5 本章小结

第6章 Flink网络栈

6.1 内存管理

6.2 网络传输

6.3 流批一体的shuffle架构

6.4 本章小结

第7章 Flink Connector的设计与实现

7.1 Kafka Connector实现原理

7.2 HBase Table Connector实现原理

7.3 本章小结

第8章 部署模式

8.1 Local部署

8.2 Standalone部署

8.3 Flink on YARN模式

8.4 Flinkon Kubernetes模式

8.5 本章小结

第9章 Flink Table与SQL

9.1 StreamTableEnvironment类介绍

9.2 SQL解析过程

9.3 Table Connector

9.4 UDF与内置算子

9.5 本章小结

第10章 Flink CEP原理解析

10.1 CEP的基本概念

10.2 CEP内部实现原理

10.3 本章小结

第11章 Flink监控

11.1 监控指标

11.2 常用系统指标

11.3 监控体系建设