本文转自个人微信公众号,原文链接。
Apache Flink is a framework and distributed processing engine for stateful computations over unbounded and bounded data streams. Flink has been designed to run in all common cluster environments, perform computations at in-memory speed and at any scale.
Bounded Streams 可以理解为有开始也有结束的数据流,处理这类数据流可以等所有数据都到了再处理,也就是常说的批处理。
Unbounded Streams 可以理解为有开始没有结束的数据流,这类数据流持续产生数据,所以,也要持续的进行处理而不能等数据流结束再处理,也就是常说的流处理。
Apache Flink 既能处理Bounded Streams 也擅长处理Unbounded Streams,既能做批处理也能做流处理。
Apache Flink 是一个分布式系统,需要资源以运行其它应用,Apache Flink 支持常见的资源管理器,包括Yarn、 Mesos、K8S,也可以以Stand-Alone Cluster的方式运行。
Apache Flink Runtime 是一个典型的master-slave架构, 包括Jobmanagers 和 Taskmanagers 两部分:
另外,Clients 不是Apache Flink Runtime的一部分,但常用于准备和提交Job到 Jobmanager。
Apache Flink 提供了不同的抽象级别以开发Flink 应用。
Apache Flink 程序一般包括data streams和 transformations 两部分,其中,data streams 是数据流,transformations 是操作数据流的算子,以一个或多个数据流为输入,输出一个或多个数据流。
当Apache Flink 程序运行时,Flink 程序可以理解为包含streams 和 transformation operators 的streaming dataflow,每个dataflow 以一个或多个sources开始并以一个或多个sinks 结束,这个dataflow 类似于DAGs(directed acyclic graphs)。(有没有一种熟悉的感觉,比如Spark、Flume…)
在流计算中,Time包括三种:
Apache 可以支持这三种Time,每种Time都有特定的用途,后序文章会详细进行说明。
不同于批计算,流计算的计算一般是针对一个窗口的数据的计算,比如“统计过去5分钟的记录数”、“过去100个数据的平均值”等。
窗口包括按时间进行划分的和按数据进行划分的,典型的包括 tumbling windows、 sliding windows, session windows,每种窗口应用于不同的场景。
有些操作只需要知道当前数据记录即可,还有些操作需要其它数据记录,我们称这种操作是stateful operations,比如要计算Sum、Avg等,这些值是需要存储的,因为会不断变化,这些值就可以理解为 state。
Apache Flink 提供了内置的状态管理,这也是Flink 区别于其它流计算引擎的最主要的区别。
Apache Flink的checkpoints 可以理解为输入数据流在某一点以及所有operators对应的state,Apache Flink 基于checkpoints 和 stream replay 实现容错,并基于此实现数据一致性(exactly-once)。
上面主要介绍Flink 中的核心概念,总结下为什么选择Flink:
下篇文章,开始编写第一个Flink 程序。
扫描下方二维码关注我。