apache-flink - Flink keyed process 函数可以有多个状态描述符吗？

Question

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

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

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

标签： apache-flinkflink-streaming

Answer 1

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

有关示例，请参阅Rides and Fares 培训练习的解决方案。