科技 类型
可以朗读 语音朗读
350千字 字数
2022-01-01 发行日期
展开全部

主编推荐语

本书四位作者都是非常资深的Flink专家，部分作者是Flink源代码的维护者和改造者，本书总结了他们在阿里巴巴、蚂蚁集团、滴滴等企业的大规模Flink实践经验。

内容简介

这是一部从源代码角度出发，通过分析Flink的各个功能模块的实现来剖析Flink的架构设计和实现原理的著作。它将能指导读者更好地对Flink进行性能调优、可用性保障、效能优化和二次开发。

目录

  • 版权信息
  • 内容简介
  • 作者简介
  • 推荐语
  • 前言
  • 第1章 阅读Flink源代码前的准备
  • 1.1 环境准备
  • 1.2 获取、编译和调试Flink的源代码
  • 1.2.1 获取与导入Flink源代码
  • 1.2.2 编译与调试Flink源代码
  • 1.3 Flink源代码的目录结构
  • 1.4 Flink设计理念与基本架构
  • 1.4.1 Flink与主流计算引擎对比
  • 1.4.2 Flink基本架构
  • 1.5 本章小结
  • 第2章 编程模型与API
  • 2.1 DataStream
  • 2.2 算子
  • 2.3 窗口
  • 2.3.1 窗口的基本概念
  • 2.3.2 窗口的执行流程
  • 2.3.3 窗口分配器
  • 2.3.4 触发器
  • 2.3.5 窗口函数
  • 2.4 本章小结
  • 第3章 运行时组件与通信
  • 3.1 运行时组件
  • 3.1.1 REST
  • 3.1.2 Dispatcher
  • 3.1.3 ResourceManager
  • 3.1.4 JobMaster
  • 3.1.5 TaskExecutor
  • 3.2 组件间通信
  • 3.2.1 Akka与Actor模型
  • 3.2.2 组件间通信实现
  • 3.3 运行时组件的高可用
  • 3.3.1 Master节点上组件的高可用
  • 3.3.2 现有运行时组件高可用存在的问题及其解决方案
  • 3.4 本章小结
  • 第4章 状态管理与容错
  • 4.1 状态
  • 4.1.1 状态的原理与实现
  • 4.1.2 状态生存时间的原理与实现
  • 4.2 检查点
  • 4.2.1 检查点机制原理
  • 4.2.2 检查点执行过程
  • 4.2.3 任务容错
  • 4.3 状态后端
  • 4.4 本章小结
  • 第5章 任务提交与执行
  • 5.1 任务提交整体流程
  • 5.2 DAG转换
  • 5.2.1 DAG的4层转换
  • 5.2.2 WordCount转换过程
  • 5.3 Slot分配
  • 5.3.1 相关概念和实现类
  • 5.3.2 Slot申请流程
  • 5.3.3 任务部署
  • 5.4 任务执行机制
  • 5.4.1 任务执行过程
  • 5.4.2 MailBox线程模型
  • 5.5 本章小结
  • 第6章 Flink网络栈
  • 6.1 内存管理
  • 6.2 网络传输
  • 6.2.1 什么是Flink网络栈
  • 6.2.2 非流控模型的网络传输流程
  • 6.2.3 流控模型的网络传输流程
  • 6.3 流批一体的shuffle架构
  • 6.3.1 生命周期管理
  • 6.3.2 数据shuffle
  • 6.4 本章小结
  • 第7章 Flink Connector的设计与实现
  • 7.1 Kafka Connector实现原理
  • 7.1.1 Kafka Source Connector实现
  • 7.1.2 Kafka Sink Connector实现
  • 7.2 HBase Table Connector实现原理
  • 7.2.1 HBase Source Connector和Sink Connector的工厂实现
  • 7.2.2 HBase维表实现
  • 7.3 本章小结
  • 第8章 部署模式
  • 8.1 Local部署
  • 8.2 Standalone部署
  • 8.3 Flink on YARN模式
  • 8.3.1 YARN基本架构
  • 8.3.2 Flink on YARN模式介绍
  • 8.3.3 Flink on YARN启动过程
  • 8.4 Flinkon Kubernetes模式
  • 8.5 本章小结
  • 第9章 Flink Table与SQL
  • 9.1 StreamTableEnvironment类介绍
  • 9.1.1 StreamExecutionEnvironment类
  • 9.1.2 EnvironmentSettings类
  • 9.1.3 TableConfig类
  • 9.1.4 StreamTableEnvironment的创建过程
  • 9.2 SQL解析过程
  • 9.2.1 SQL解析
  • 9.2.2 SQL优化
  • 9.2.3 RelNode转换
  • 9.3 Table Connector
  • 9.3.1 TableSource
  • 9.3.2 TableSink
  • 9.3.3 SPI机制在Table Connector中的应用
  • 9.4 UDF与内置算子
  • 9.4.1 UDF
  • 9.4.2 内置算子
  • 9.5 本章小结
  • 第10章 Flink CEP原理解析
  • 10.1 CEP的基本概念
  • 10.1.1 什么是Flink CEP
  • 10.1.2 Pattern
  • 10.1.3 量词
  • 10.1.4 条件
  • 10.1.5 连接
  • 10.1.6 Flink CEP作业编写举例
  • 10.2 CEP内部实现原理
  • 10.2.1 NFA简介
  • 10.2.2 匹配过程
  • 10.2.3 CEP状态存储
  • 10.2.4 CEP和SQL结合
  • 10.3 本章小结
  • 第11章 Flink监控
  • 11.1 监控指标
  • 11.1.1 指标类型
  • 11.1.2 系统指标及自定义指标
  • 11.1.3 指标的使用
  • 11.2 常用系统指标
  • 11.3 监控体系建设
  • 11.3.1 指标监控及展示
  • 11.3.2 日志分析处理
  • 11.3.3 定位手段
  • 11.4 本章小结
展开全部

评分及书评

评分不足
2个评分
  • 用户头像
    给这本书评了
    4.0

    flink 开发与使用者的作品，体系化和底层思考上有功底，用来理解代码和入门都不错

      转发
      评论

    出版方

    机械工业出版社有限公司

    机械工业出版社是全国优秀出版社，自1952年成立以来，坚持为科技、为教育服务，以向行业、向学校提供优质、权威的精神产品为宗旨，以“服务社会和人民群众需求，传播社会主义先进文化”为己任，产业结构不断完善，已由传统的图书出版向着图书、期刊、电子出版物、音像制品、电子商务一体化延伸，现已发展为多领域、多学科的大型综合性出版社，涉及机械、电工电子、汽车、计算机、经济管理、建筑、ELT、科普以及教材、教辅等领域。