主页 > 新闻资讯 > 成都大数据培训之Flink 内核状态类型

成都大数据培训之Flink 内核状态类型

作者:覃老师 浏览次数: 2021-09-06 18:11
成都大数据培训之Flink 内核状态类型
一、状态类型
在成都大数据培训中,按照数据结构的不同,Flink中定义了多种State,应用于不同的场景。如下:
1、ValueState<T>
类型为T的单值状态。这个状态与对应的Key绑定,是最简单的状态。可以通过update方法更新状态值,通过value()方法获取状态值。
2、ListState<T>
Key上的状态值为一个列表。可以通过add方法往列表中附加值,也可以通过get()方法返回一个Iterable<T>来遍历状态值。
3、ReducingState<T>
这种状态通过用户传入的reduceFunction,每次调用add方法添加值时,会调用reduceFunction,最后合并到一个单一的状态值。
成都大数据培训
4、AggregatingState<IN,OUT>
聚合State,和ReducingState不同的是,这里聚合的类型可以是不同元素的元素类型,使用add(IN)来加入元素,并使用AggregateFunction函数计算聚合结果。
5、MapState<UK,UV>
使用Map存储Key-Value对,通过put(UK,UV)或者putAll(Map<UK,UV>)来添加,使用get(UK)来获取。
6、FoldingState<T,ACC>
跟ReducingState有点类似,不过它的状态值类型可以与add方法中传入的元素类型不同。已被标位废弃,不建议使用。

以上是成都大数据培训之Flink 内核状态类型的详细介绍,如果您想了解更多细节,请点击成都卡米谷大数据官方网站!成都大数据培训学校,大数据开发培训,数据分析和挖掘,零基课程正在招生,本月的教学大纲和试学录像可以联系客户服务接入!
 

标签:
热点排行
推荐文章
立即申请>>