2017-08-29 114 views

回答

1

给定的一个Flink状态保存在一个操作符中。但是该运算符可以是RichCoFlatmapCoProcessFunction,并且接收和处理来自两个流的输入(如果涉及两个以上的流,则可以级联这些输入)。

你的问题非常广泛,所以目前还不清楚这种方法是否符合你的想法。

相关问题