【发布时间】:2021-09-01 17:52:33
【问题描述】:
我正在使用 Keyed 进程函数来使用 RocksDB 状态后端。我想为同一个键保存两种不同的状态;
- 状态 1 类型:ValueState[String]
- 状态 2 类型:MapState[String, Long]
在这种情况下,我必须在同一个键控进程函数中创建两个状态描述符。在 flink 中可以吗?
【问题讨论】:
标签: apache-flink flink-streaming
我正在使用 Keyed 进程函数来使用 RocksDB 状态后端。我想为同一个键保存两种不同的状态;
在这种情况下,我必须在同一个键控进程函数中创建两个状态描述符。在 flink 中可以吗?
【问题讨论】:
标签: apache-flink flink-streaming
是的,您可以在键控过程函数中拥有任意数量的状态描述符。每个都必须有一个唯一的名称(范围为运算符/函数)。
有关示例,请参阅 the solution 到 Rides and Fares training exercise。
【讨论】: