更新时间:2021-04-14 11:31:22
封面
版权信息
序
前言
第1章 Flink入门
1.1 核心特点
1.2 架构
1.3 Flink的未来
1.4 准备工作
1.5 总结
第2章 Flink应用
2.1 Flink应用开发
2.2 API层次
2.3 数据流
2.4 数据流API
2.5 总结
第3章 核心抽象
3.1 环境对象
3.2 数据流元素
3.3 数据转换
3.4 算子
3.5 函数体系
3.6 数据分区
3.7 连接器
3.8 分布式ID
3.9 总结
第4章 时间与窗口
4.1 时间类型
4.2 窗口类型
4.3 窗口原理与机制
4.4 水印
4.5 时间服务
4.6 窗口实现
4.7 总结
第5章 类型与序列化
5.1 DataStream类型系统
5.2 SQL类型系统
5.3 数据序列化
5.4 总结
第6章 内存管理
6.1 自主内存管理
6.2 内存模型
6.3 内存数据结构
6.4 内存管理器
6.5 网络缓冲器
6.6 总结
第7章 状态原理
7.1 状态类型
7.2 状态描述
7.3 广播状态
7.4 状态接口
7.5 状态存储
7.6 状态持久化
7.7 状态重分布
7.8 状态过期
7.9 总结
第8章 作业提交
8.1 提交流程
8.2 Graph总览
8.3 流图
8.4 作业图
8.5 执行图
8.6 总结
第9章 资源管理
9.1 资源抽象
9.2 资源管理器
9.3 Slot管理器
9.4 SlotProvider
9.5 Slot选择策略
9.6 Slot资源池
9.7 Slot共享
9.8 总结
第10章 作业调度
10.1 调度
10.2 执行模式
10.3 数据交换模式
10.4 作业生命周期
10.5 关键组件
10.6 作业启动
10.7 作业停止
10.8 作业失败调度
10.9 组件容错
10.10 总结
第11章 作业执行
11.1 作业执行图
11.2 核心对象
11.3 Task执行
11.4 总结
第12章 数据交换
12.1 数据传递模式
12.2 关键组件
12.3 数据传递
12.4 数据传递过程
12.5 网络通信
12.6 总结
第13章 应用容错
13.1 容错保证语义
13.2 检查点与保存点
13.3 作业恢复
13.4 关键组件