深入了解ProcessFunction的状态操作(Flink-1.10)

学习Flink的ProcessFunction过程中,官方文档中涉及状态处理的时候,不止一次提到只适用于keyed stream的元素,如下图红框所示: 之前写过一些flink应用,keyed stream常用但不是必须用的,所以产生了疑问: 为何只有keyed stream的元素能读写状态? 每个key对应的状态是如何操作的? Flink的"状态" 先去回顾Flink"状态"的知识点: 官方文档
相关文章
相关标签/搜索