Flink的State (概述)

文章结构概述

• 引言

  • Flink中的State类型

  • • 基础类型的分类
    • 结构形式的划分
    • State生存时间（TTL）机制

  • 另一种State实现方式：Broadcast State模式

  • State的查询能力

  • 实现自定义State的序列化与反序列化方法

  • • State序列化技术的发展历程

  • 参考文献

前言

---

在讨论Flink任务是否具备状态特性时，实际上我们所关注的核心内容是Flink框架内部的State机制。然而，此处所指的State概念已不再局限于传统意义上事件与状态之间固定的对应关系，而更应理解为运行过程中产生的动态数据信息。这类状态信息在系统进行容错处理和执行检查点操作时具有重要作用。以下将围绕Flink State的相关主题展开探讨，涵盖State的分类方式、序列化处理等内容。

Flink的State类型

---

基本类型划分方法

---

在Flink框架中，State根据基础类型被划分为以下两种形式：

• Keyed State ，这是一种与Key相关联的状态类型，其使用范围仅限于基于 KeyedStream 的操作方法。从逻辑层面来看，此类状态可视为并行操作实例与特定Key之间的对应关系，即 <par