微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

从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

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐