在本节中,您将了解 Flink 为编写有状态程序提供的 API。请看一下 Stateful Stream Processing,了解有状态流处理背后的概念。
下一步怎么走? #
- 使用状态。展示如何在 Flink 应用中使用状态,并解释不同类型的状态。
- 广播状态模式。解释如何连接一个广播流和一个非广播流,并使用状态在它们之间交换信息。
- 检查点。描述了如何启用和配置检查点以实现容错。
- 可查询状态。说明如何在运行时从 Flink 外部访问状态。
- 状态模式演化:介绍如何在运行时从外部访问状态。展示了状态类型的模式如何演化。
- 管理状态的自定义序列化。讨论如何实现自定义序列化,特别是针对模式演化。