Flink-1.17 实战教程从入门到精通
什么是Flink
梗概
Flink核心目标: 是“数据流上的有状态计算”( Stateful Computations over Data Streams)
具体说明: Apache Flink是一个框架和分布式处理引擎,用于对无界和有界数据流进行有状态计算。
有界流和无界流
无界数据流
- 有定义流的开始,但没有定义流的结束:
- 它们会无休止的产生数据;
- 无界流的数据必须持续处理,即数据被摄取后需要立刻处理。
- 我们不能等到所有数据都到达再处理,因为输入是无限的。
有界数据流
- 有定义流的开始,也有定义流的结束;
- 有界流可以在摄取所有数据后再进行计算:
- 有界流所有数据可以被排序,所以并不需要有序摄取:
- 有界流处理通常被称为批处理