Flink keyed process function 可以有多个状态描述符吗？

Question

我正在使用 Keyed 进程函数来使用 RocksDB 状态后端。我想为同一个键保持两个不同的状态；

• 状态 1 类型：ValueState[String]
• 状态 2 类型：MapState[String, Long]

在这种情况下，我必须在同一个键控过程函数中创建两个状态描述符。这在 flink 中可能吗？

Answer 1

是的，您可以在键控过程函数中拥有任意数量的状态描述符。每个都必须有一个唯一的名称（范围为 operator/function）。

有关示例，请参阅 the solution to the Rides and Fares training exercise。