企业官网建设流程全解析

本文重点

在前面的课程中，我们学习了Flink中的状态，在Flink中状态有多种数据结构，不同的数据结构适应不同的任务，本文对此进行学习。

状态支持的数据结构

值状态（ValueState）

列表状态（ListState）

映射状态（MapState）

聚合状态（AggregatingState）

归约状态（ReducingState）

值状态

public interface ValueState<T> extends State { T value() throws IOException; void update(T value) throws IOException; }

ValueState接口有一个泛型，表示值类型，接口有两个方法，value表示获取值，update表示更新值。

ValueState表示一个变量，我们在使用变量的时候还要为变量指定名称，所以ValueState需要搭配ValueStateDescriptor一起使用。ValueStateDescriptor就是状态描述符，可以指定状态的名称和类型。它的定义如下：

public ValueStateDescriptor(String name, Class<T> typeClass) { super(name, typeClass, null); }

所以我们可以在一个算子中定义多个ValueState状态，只要名称