给定的flink状态被保存在一个操作符中。但是这个操作符可以是一个 RichCoFlatmap 或者 CoProcessFunction ，并接收和处理来自两个流的输入（如果涉及两个以上的流，则可以级联这些输入）。
您的问题非常广泛，因此不清楚这种方法是否符合您所考虑的用例。