coprocessfunction专题

Flink实战案例(二十二):自定义时间和窗口的操作符(三)CoProcessFunction

CoProcessFunction   对于两条输入流,DataStream API提供了CoProcessFunction这样的low-level操作。CoProcessFunction提供了操作每一个输入流的方法: processElement1()和processElement2()。   类似于ProcessFunction,这两种方法都通过Context对象来调用。这个Conte