本书以PyFlink为核心,系统讲解了基于Python语言进行实时流处理和大数据开发的完整技术栈。全书共分为6章,内容编排由浅入深,兼顾基础理论与实战应用。第1章为入门基础;第2章聚焦核心API,深入阐述PyFlink的DataStream API;第3章探讨状态管理与容错,围绕流处理中的关键问题——状态一致性展开;第4章介绍复杂事件处理,即Flink CEP库;第5章讲解关系型API,即Table API & SQL;第6章介绍机器学习扩展,即Flink ML。
本书既可作为高等院校大数据相关专业的教材,也适合作为大数据开发工程师、数据架构师及对实时流处理技术感兴趣的技术人员的参考用书。