如何以多种状态引导flink运算符

问题描述

新的状态流程API非常适合在操作员中引导状态对象。但是，我找不到如何从单个运算符引导多个状态的任何示例。查看代码似乎不受支持。想知道是否有人对如何解决此问题提出建议。我的用例是我实现了一个包含左右状态的自定义联接运算符。我需要使用蜂巢表中的数据来引导两种状态。

解决方法

我看到的唯一解决方案是构造一个具有可容纳所有数据的类型的单个DataSet，例如元组或Map（针对每个键），然后使用该单个复合DataSet来引导所有各州。