从0到1Flink的成长之路(十七)-高级特性(Flink四大基石)

Flink 高级特性(一)

1. Flink 四大基石

Flink之所以能这么流行,离不开它最重要的四个基石:CheckpointStateTimeWindow

在这里插入图片描述

Checkpoint
Flink最重要的一个特性,Flink基于Chandy-Lamport算法实现了一个分布式的一致性的快
照,从而提供了一致性的语义。
Chandy-Lamport算法实际上在1985年的时候已经被提出来,但并没有被很广泛的应用,
而Flink则把这个算法发扬光大了。
checkpoint
State
提供了一致性的语义之后,Flink为了让用户在编程时能够更轻松、更容易地去管理状态,
还提供了一套非常简单明了的State API,包括ValueState、ListState、MapState,
broadcastState。
state
Time
除此之外,Flink还实现了Watermark的机制,能够支持基于事件时间的处理,能够容忍迟
到/乱序的数据。
time
Window
另外流计算中一般在对流数据进行操作之前都会先进行开窗,即基于一个什么样的窗口上
做这个计算。Flink提供了开箱即用的各种窗口,比如滑动窗口、滚动窗口、会话窗口以及
非常灵活的自定义的窗口。
window

相关文章

Flink-core小总结1.实时计算和离线计算1.1离线计算离线计算的...
2022年7月26日,Taier1.2版本正式发布!本次版本发布更新功能...
关于Flink相关的概念性东西就不说了,网上都有,官网也很详尽...
最近准备用flink对之前项目进行重构,这是一个有挑战(但我很...
Thispostoriginallyappearedonthe ApacheFlinkblog.Itwasre...
Flink配置文件对于管理员来说,差不多经常调整的就只有conf下...