Flink 原理、实战与性能优化 - (EPUB全文下载)
文件大小:0.41 mb。
文件格式:epub 格式。
书籍内容:
Flink 原理、实战与性能优化
第1章 Apache Flink介绍
1.1 Apache Flink是什么
1.2 数据架构的演变
1.2.1 传统数据基础架构
1.2.2 大数据数据架构
1.2.3 有状态流计算架构
1.2.4 为什么会是Flink
1.3 Flink应用场景
1.4 Flink基本架构
1.4.2 基本架构图
1.5 本章小结
第2章 环境准备
2.1 运行环境介绍
2.2 Flink项目模板
2.2.1 基于Java实现的项目模板
2.2.2 基于Scala实现的项目模板
2.3 Flink开发环境配置
2.3.1 下载IntelliJ IDEA IDE
2.3.2 安装Scala Plugins
2.3.3 导入Flink应用代码
2.3.4 项目配置
2.4 运行Scala REPL
2.4.1 环境支持
2.4.2 运行程序
2.5 Flink源码编译
2.6 本章小结
第3章 Flink编程模型
3.1 数据集类型
3.2 Flink编程接口
3.3 Flink程序结构
3.4 Flink数据类型
3.4.2 TypeInformation信息获取
3.5 本章小结
第4章 DataStream API介绍与使用
4.1 DataStream编程模型
4.1.1 DataSources数据输入
4.1.2 DataSteam转换操作
4.1.3 DataSinks数据输出
4.2 时间概念与Watermark
4.2.2 EventTime和Watermark
4.3 Windows窗口计算
4.3.1 Windows Assigner
4.3.2 Windows Function
4.3.3 Trigger窗口触发器
4.3.4 Evictors数据剔除器
4.3.5 延迟数据处理
4.3.6 连续窗口计算
4.3.7 Windows多流合并
4.4 作业链和资源组
4.4.1 作业链
4.4.2 Slots资源组
4.5 Asynchronous I/O异步操作
4.6 本章小结
第5章 Flink状态管理和容错
5.1 有状态计算
5.2 Checkpoints和Savepoints
5.2.2 Savepoints机制
5.3 状态管理器
5.3.1 StateBackend类别
5.3.2 状态管理器配置
5.4 Querable State
5.5 本章小结
第6章 DataSet API介绍与使用
6.1 DataSet API
6.1.1 应用实例
6.1.2 DataSources数据接入
6.1.3 DataSet转换操作
6.1.4 DataSinks数据输出
6.2 迭代计算
6.2.1 全量迭代
6.2.2 增量迭代
6.3 广播变量与分布式缓存
6.3.2 分布式缓存
6.4 语义注解
6.4.1 Forwarded Fileds注解
6.4.2 Non-Forwarded Fileds注解
6.4.3 Read Fields注解
6.5 本章小结
第7章 Table API & SQL介绍与使用
7.1 TableEnviroment概念
7.1.1 开发环境构建
7.1.2 TableEnvironment基本操作
7.1.3 外部连接器
7.1.4 时间概念
7.1.5 Temporal Tables临时表
7.2 Flink Table API
7.2.1 Table API应用实例
7.2.2 数据查询和过滤
7.2.3 窗口操作
7.2.4 聚合操作
7.2.5 多表关联
7.2.6 集合操作
7.2.7 排序操作
7.2.8 数据写入
7.3 Flink SQL使用
7.3.1 Flink SQL实例
7.3.2 执行SQL
7.3.3 数据查询与过滤
7.3.4 Group Windows窗口操作
7.3.5 数据聚合
7.3.6 多表关联
7.3.7 集合操作
7.3.8 数据输出
7.4 自定义函数
7.4.1 Scalar Function
7.4.2 Table Function
7.4.3 Aggregation Function
7.5 自定义数据源
7.5.1 TableSource定义
7.5.2 TableSink定义
7.5.3 TableFactory定义
7.6 本章小结
第8章 Flink组件栈介绍与使用
8.1 Flink复杂事件处理
8.1.1 基础概念
8.1.2 Pattern API
8.1.3 事件获取
8.1.4 应用实例
8.2 Flink Gelly图计算应用
8.2.1 基本概念
8.2.2 Graph API
8.2.3 迭代图处理
8.2.4 图生成器
8.3 FlinkML机器学习应用
8.3.1 基本概念
8.3.2 有监督学习算子
8.3.3 数据预处理
8.3.4 推荐算法
8.3.5 Pipelines In FlinkML
8.4 本章小结
第9章 Flink部署与应用
9.1 Flink集群部署
9.1.1 Standalone Cluster部署
9.1.2 Yarn Cluster部署
9.1.3 Kubernetes Cluster部署
9.2 Flink高可用配置
9.2.1 Standalone集群高可用配置
9.2.2 Yarn Session集群高可用配置
9.3 Flink安全管理
9.3.1 认证目标
9.3.2 认证配置
9.3.3 SSL配置
9.4 Flink集群升级
9.4.1 任务重启
9.4.2 状态维护
9.4.3 版本升级
9.5 本章小结
第10章 Flink监控与性能优化
10.1 监控指标
10.1.1 系统监控指标
10.1.2 监控指标注册
10.1.3 监控指标报表
10.2 Backpressure监控与优化
10.2.1 Backpressure进程抽样
10.2.2 Backpressure页面监控
10. ............
以上为书籍内容预览,如需阅读全文内容请下载EPUB源文件,祝您阅读愉快。
书云 Open E-Library » Flink 原理、实战与性能优化 - (EPUB全文下载)