2026/3/29 3:27:00
网站建设
项目流程
网站流量不正常,贸易网站设计,抖音代运营的资源,建筑用模板多少钱一块本文重点
在前面的课程中,我们学习了Flink中的状态,在Flink中状态有多种数据结构,不同的数据结构适应不同的任务,本文对此进行学习。
状态支持的数据结构 值状态(ValueState) 列表状态(ListState) 映射状态(MapState) 聚合状态(AggregatingState) 归约状态(Redu…本文重点在前面的课程中,我们学习了Flink中的状态,在Flink中状态有多种数据结构,不同的数据结构适应不同的任务,本文对此进行学习。状态支持的数据结构值状态(ValueState)列表状态(ListState)映射状态(MapState)聚合状态(AggregatingState)归约状态(ReducingState)值状态public interface ValueStateT extends State { T value() throws IOException; void update(T value) throws IOException; }ValueState接口有一个泛型,表示值类型,接口有两个方法,value表示获取值,update表示更新值。ValueState表示一个变量,我们在使用变量的时候还要为变量指定名称,所以ValueState需要搭配ValueStateDescriptor一起使用。ValueStateDescriptor就是状态描述符,可以指定状态的名称和类型。它的定义如下:public ValueStateDescriptor(String name, ClassT typeClass) { super(name, typeClass, null); }所以我们可以在一个算子中定义多个ValueState状态,只要名称