我用夸克网盘分享了「Flink 原理、实战与性能优化.epub」，点击链接即可保存。打开「夸克APP」在线查看，支持多种文档格式转换。

内容简介

这是一部以实战为导向，能指导读者零基础掌握Flink并快速完成进阶的著作，从功能、原理、实战和调优等4个维度循序渐进地讲解了如何利用Flink进行分布式流式应用开发。作者是该领域的资深专家，现就职于第四范式，曾就职于明略数据。 全书一共10章，逻辑上可以分为三个部分： 第一部分（第1~2章） 主要介绍了Flink的核心概念、特性、应用场景、基本架构，开发环境的搭建和配置，以及源代码的编译。 第二部分（第3~9章） 详细讲解了Flink的编程范式，各种编程接口的功能、应用场景和使用方法，以及核心模块和组件的原理和使用。 第三部分（第10章） 重点讲解了Flink的监控和优化，参数调优，以及对反压、Checkpoint和内存的优化。

作者简介

张利兵 资深架构师，流式计算领域专家，第四范式华东区AI项目架构师，原明略数据华东区大数据架构师。 有多年大数据、流式计算方面的开发经验，对Hadoop、Spark、Flink等大数据计算引擎有着非常深入的理解，积累了丰富的项目实践经验。先后利用相关技术为银行、证券、地铁等领域的头部企业构建了内部大数据平台，参与了基于Flink的实时反欺诈风控、实时地铁故障预警等流式计算平台的设计和研发。

网友热评

啊哈: 草草读一遍，有一个大体了解~~ 总体来说，太多 api 使用，太少原理部分~~ ttttttankcat: 看了感兴趣的几章节，感觉是把官网零散的文档系统化地整理了一番，笔误的地方还挺多的

图书目录

前言 第1章　ApacheFlink介绍1 1.1　ApacheFlink是什么1 1.2　数据架构的演变2 1.2.1　传统数据基础架构3 1.2.2　大数据数据架构4 1.2.3　有状态流计算架构5 1.2.4　为什么会是Flink6 1.3　Flink应用场景8 1.4　Flink基本架构10 1.4.1　基本组件栈10 1.4.2　基本架构图11 1.5　本章小结13 第2章　环境准备14 2.1　运行环境介绍14 2.2　Flink项目模板15 2.2.1　基于Java实现的项目模板15 2.2.2　基于Scala实现的项目模板18 2.3　Flink开发环境配置20 2.3.1　下载IntelliJIDEAIDE21 2.3.2　安装ScalaPlugins21 2.3.3　导入Flink应用代码22 2.3.4　项目配置22 2.4　运行ScalaREPL24 2.4.1　环境支持24 2.4.2　运行程序24 2.5　Flink源码编译25 2.6　本章小结26 第3章　Flink编程模型27 3.1　数据集类型27 3.2　Flink编程接口29 3.3　Flink程序结构30 3.4　Flink数据类型37 3.4.1　数据类型支持37 3.4.2　TypeInformation信息获取40 3.5　本章小结43 第4章　DataStreamAPI介绍与使用44 4.1　DataStream编程模型44 4.1.1　DataSources数据输入45 4.1.2　DataSteam转换操作49 4.1.3　DataSinks数据输出59 4.2　时间概念与Watermark61 4.2.1　时间概念类型61 4.2.2　EventTime和Watermark63 4.3　Windows窗口计算69 4.3.1　WindowsAssigner70 4.3.2　WindowsFunction77 4.3.3　Trigger窗口触发器83 4.3.4　Evictors数据剔除器87 4.3.5　延迟数据处理88 4.3.6　连续窗口计算89 4.3.7　Windows多流合并90 4.4　作业链和资源组95 4.4.1　作业链95 4.4.2　Slots资源组96 4.5　AsynchronousI/O异步操作97 4.6　本章小结98 第5章　Flink状态管理和容错100 5.1　有状态计算100 5.2　Checkpoints和Savepoints109 5.2.1　Checkpoints检查点机制109 5.2.2　Savepoints机制111 5.3　状态管理器114 5.3.1　StateBackend类别114 5.3.2　状态管理器配置116 5.4　QuerableState118 5.5　本章小结123 第6章　DataSetAPI介绍与使用124 6.1　DataSetAPI124 6.1.1　应用实例125 6.1.2　DataSources数据接入126 6.1.3　DataSet转换操作128 6.1.4　DataSinks数据输出134 6.2　迭代计算136 6.2.1　全量迭代136 6.2.2　增量迭代137 6.3　广播变量与分布式缓存139 6.3.1　广播变量139 6.3.2　分布式缓存140 6.4　语义注解141 6.4.1　ForwardedFileds注解141 6.4.2　Non-ForwardedFileds注解143 6.4.3　ReadFields注解144 6.5　本章小结145 第7章　TableAPI&SQL介绍与使用146 7.1　TableEnviroment概念146 7.1.1　开发环境构建147 7.1.2　TableEnvironment基本操作147 7.1.3　外部连接器155 7.1.4　时间概念162 7.1.5　TemporalTables临时表166 7.2　FlinkTableAPI167 7.2.1　TableAPI应用实例167 7.2.2　数据查询和过滤168 7.2.3　窗口操作168 7.2.4　聚合操作173 7.2.5　多表关联175 7.2.6　集合操作177 7.2.7　排序操作178 7.2.8　数据写入179 7.3　FlinkSQL使用179 7.3.1　FlinkSQL实例179 7.3.2　执行SQL180 7.3.3　数据查询与过滤181 7.3.4　GroupWindows窗口操作182 7.3.5　数据聚合184 7.3.6　多表关联186 7.3.7　集合操作187 7.3.8　数据输出189 7.4　自定义函数189 7.4.1　ScalarFunction189 7.4.2　TableFunction191 7.4.3　AggregationFunction192 7.5　自定义数据源193 7.5.1　TableSource定义193 7.5.2　TableSink定义196 7.5.3　TableFactory定义199 7.6　本章小结201 第8章　Flink组件栈介绍与使用202 8.1　Flink复杂事件处理202 8.1.1　基础概念203 8.1.2　PatternAPI204 8.1.3　事件获取210 8.1.4　应用实例212 8.2　FlinkGelly图计算应用213 8.2.1　基本概念213 8.2.2　GraphAPI214 8.2.3　迭代图处理220 8.2.4　图生成器226 8.3　FlinkML机器学习应用227 8.3.1　基本概念227 8.3.2　有监督学习算子229 8.3.3　数据预处理231 8.3.4　推荐算法234 8.3.5　PipelinesInFlinkML235 8.4　本章小结236 第9章　Flink部署与应用237 9.1　Flink集群部署237 9.1.1　StandaloneCluster部署238 9.1.2　YarnCluster部署240 9.1.3　KubernetesCluster部署244 9.2　Flink高可用配置247 9.2.1　Standalone集群高可用配置248 9.2.2　YarnSession集群高可用配置250 9.3　Flink安全管理251 9.3.1　认证目标251 9.3.2　认证配置252 9.3.3　SSL配置253 9.4　Flink集群升级255 9.4.1　任务重启256 9.4.2　状态维护256 9.4.3　版本升级257 9.5　本章小结258 第10章　Flink监控与性能优化259 10.1　监控指标259 10.1.1　系统监控指标259 10.1.2　监控指标注册261 10.1.3　监控指标报表264 10.2　Backpressure监控与优化266 10.2.1　Backpressure进程抽样266 10.2.2　Backpressure页面监控267 10.2.3　Backpressure配置268 10.3　Checkpointing监控与优化268 10.3.1　Checkpointing页面监控268 10.3.2　Checkpointing优化271 10.4　Flink内存优化273 10.4.1　Flink内存配置274 10.4.2　NetworkBuffers配置275 10.5　本章小结277