序言
本作品已使用人工智能进行翻译。欢迎您提供反馈和意见:translation-feedback@oreilly.com
你将从本书中学到什么
本书将向您传授使用 Apache Flink 进行流处理所需的一切知识。本书由 11 章组成,希望能讲述一个连贯的故事。有些章节是描述性的,旨在介绍高层次的设计概念,而其他章节则更注重实践,包含许多代码示例。
虽然我们在编写本书时打算按章节顺序阅读,但熟悉某一章内容的读者可能想跳过这一章。而对立即编写 Flink 代码更感兴趣的读者则可能希望先阅读实用章节。在下文中,我们将简要介绍每一章的内容,这样您就可以直接跳到您最感兴趣的章节。
-
第 1 章概述了有状态流处理、数据处理应用架构、应用设计以及流处理相对于传统方法的优势。本章还简要介绍了在本地 Flink 实例上运行第一个流处理应用程序的情况。
-
第 2 章讨论流处理的基本概念和挑战,与 Flink 无关。
-
第 3 章介绍了 Flink 的系统架构和内部结构。它讨论了分布式架构、流式应用中的时间和状态处理以及 Flink 的容错机制。
-
第 4 章介绍如何设置开发和调试 Flink 应用程序的环境。
-
第 5 章将介绍 Flink DataStream API 的基础知识。您将了解如何实现 DataStream 应用程序,以及支持哪些流转换、函数和数据类型。
-
第 6 章讨论 DataStream API 的基于时间的操作符。这包括 Windows 操作符和基于时间的连接以及流程函数,它们在流式应用中处理时间时提供了最大的灵活性。
-
第 7 章介绍了如何实现有状态函数,并讨论了围绕这一主题的所有问题,如有状态函数的性能、健壮性和演进。它还展示了如何使用 Flink 的可查询状态。
-
第 8 章介绍了 Flink 最常用的源和汇连接器。它讨论了 Flink 的端到端应用程序一致性方法,以及如何实施自定义连接器,以从外部系统获取数据并将数据发送到外部系统。
-
第 9 章讨论如何在各种环境中设置和配置 Flink 群集。
-
第 10 章介绍全天候运行的流媒体应用程序的操作、监控和维护。
-
最后,第 11 章包含了一些资源,您可以用来提问、参加 Flink 相关活动,以及了解 Flink 目前的使用情况。
本书使用的约定
本书使用以下排版规则:
- 斜体
-
表示新术语、URL、电子邮件地址、文件名和文件扩展名。
Constant width-
用于程序列表以及段落中的程序元素,如变量或函数名称、数据库、数据类型、环境变量、语句和关键字。还用于模块和软件包名称,以及显示应由用户按字面意思键入的命令或其他文本以及命令的输出。
Constant width italic-
显示应替换为用户提供的值或根据上下文确定的值的文本。
提示
该元素表示提示或建议。
备注
该元素表示一般性说明。
警告
该元素表示警告或警示。
使用代码示例
补充材料(Java 和 Scala 示例代码)可从https://github.com/streaming-with-flink 下载。
本书旨在帮助您完成工作。一般来说,如果本书提供了示例代码,您可以在您的程序和文档中使用。除非你要复制代码的重要部分,否则不需要联系我们获得许可。例如,编写一个使用了本书多段代码的程序并不需要获得许可。销售或分发 O'Reilly 书籍中示例的 CD-ROM 需要获得许可。通过引用本书和示例代码回答问题不需要许可。将本书中的大量示例代码纳入您的产品文档需要获得许可。 ...
Become an O’Reilly member and get unlimited access to this title plus top books and audiobooks from O’Reilly and nearly 200 top publishers, thousands of courses curated by job role, 150+ live events each month,
and much more.
Read now
Unlock full access