内容简介:Flink 支持有状态的操作和用户方法。例如,窗口操作使用状态维护不断追加的聚合数据,sink 操作使用状态保证一致性提供 exactly-once 语义。Flink 状态主要分为两种:Flink 支持三种状态后端:
Flink 支持有状态的操作和用户方法。例如,窗口操作使用状态维护不断追加的聚合数据,sink 操作使用状态保证一致性提供 exactly-once 语义。
Flink 状态主要分为两种:
- 操作状态
- 键状态
Flink 支持三种状态后端:
- 内存
- 文件系统
- RocksDB
操作状态
操作状态(Operator State),即每个操作状态绑定到一个并发操作实例上。
Flink 提供了以下操作状态:
- Broadcast State:
BroadcastState<K,V>
广播状态,存储在广播状态中的元素可以被所有的操作访问。
键状态
Flink 提供了以下键状态:
- Value State:
ValueState<T>
分区的单值状态。 - Map State:
MapState<UK,UV>
分区的键值状态。 - List State:
ListState<T>
分区的列表状态。 - Reducing State:
ReducingState<T>
每次调用add(T)
添加新元素,会调用 ReduceFunction 进行聚合。传入类型和返回类型相同。 - Aggregating State:
AggregatingState<IN,OUT>
每次调用add(T)
添加新元素,会调用 ReduceFunction 进行聚合。传入类型和返回类型可以不同。
状态后端
内存
适用场景:调试、无状态或可以容忍数据的丢失和重复。
文件系统
适用场景:普通状态、窗口、键值结构。
RocksDB
适用场景:超大状态、超长窗口、大型键值结构。
可查询的状态
TODO
TTL
TODO
参考
以上就是本文的全部内容,希望本文的内容对大家的学习或者工作能带来一定的帮助,也希望大家多多支持 码农网
猜你喜欢:- 科普 | 菜鸟学习状态通道,Part-2:App 定制型状态通道
- 学习 PixiJS — 精灵状态
- Flutter状态管理学习手册(三)——Bloc
- 学习如何统计 Mysql 服务器状态信息
- 如何利用机器学习进行异常检测和状态监测
- 学习 vuex 源码整体架构,打造属于自己的状态管理库
本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们。
Rust编程之道
张汉东 / 电子工业出版社 / 2019-1 / 128
Rust 是一门利用现代化的类型系统,有机地融合了内存管理、所有权语义和混合编程范式的编程语言。它不仅能科学地保证程序的正确性,还能保证内存安全和线程安全。同时,还有能与C/C++语言媲美的性能,以及能和动态语言媲美的开发效率。 《Rust编程之道》并非对语法内容进行简单罗列讲解,而是从四个维度深入全面且通透地介绍了Rust 语言。从设计哲学出发,探索Rust 语言的内在一致性;从源码分析入......一起来看看 《Rust编程之道》 这本书的介绍吧!
在线进制转换器
各进制数互转换器
图片转BASE64编码
在线图片转Base64编码工具