首页
Python
Java
前端
数据库
Linux
Chatgpt专题
开发者工具箱
coprocessfunction专题
Flink实战案例(二十二):自定义时间和窗口的操作符(三)CoProcessFunction
CoProcessFunction 对于两条输入流,DataStream API提供了CoProcessFunction这样的low-level操作。CoProcessFunction提供了操作每一个输入流的方法: processElement1()和processElement2()。 类似于ProcessFunction,这两种方法都通过Context对象来调用。这个Conte
阅读更多...