非键流的Flink检查点状态

需要非密钥状态有点不寻常，但是有包含示例的文档。

在用户代码中，通常只需要实现自定义源和接收器，这就是为什么这些示例着重于这些用例的原因。但是在a中，ProcessFunction您将执行相同的操作，即实现CheckpointedFunction接口（即initializeStateandsnapshotState方法）。

非键状态的唯一类型是ListState，UnionState和BroadcastState，并且ListState可能是您要使用的类型。UnionState与极为相似ListState，它只是在重缩放过程中使用不同的策略来重新分配状态（每个并行实例获取整个列表，而不是被分配列表的一部分，而实例负责知道做什么）。BroadcastState是BroadcastProcessFunction或使用的KeyedBroadcastProcessFunction。