如何引导具有多个状态的flink算子

Question

新的状态处理API可以很好地引导操作符中的状态对象。但是，我找不到任何如何从单个操作符引导多个状态的示例。看一下代码，它似乎不受支持。不知道有没有人有解决这个问题的建议。我的用例是，我实现了一个自定义的连接操作符，它包含左状态和右状态。我需要用hive表中的数据引导这两个状态。

Answer 1

我能看到的唯一解决方案是构造一个包含可以保存所有数据的类型的DataSet，比如元组或映射(每个键)，然后使用这个复合DataSet来引导所有状态。