【问题标题】:Can Flink keyed process function have multiple state descriptors?Flink keyed process 函数可以有多个状态描述符吗?
【发布时间】:2021-09-01 17:52:33
【问题描述】:

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

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

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

【问题讨论】:

    标签: apache-flink flink-streaming


    【解决方案1】:

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

    有关示例,请参阅 the solutionRides and Fares training exercise

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2020-07-27
      相关资源
      最近更新 更多