连接的键控流上的coProcessFunction与keyedCoProcessFunction

Question

在参考Flink代码示例时，我观察到当使用connect运算符连接两个流时，当在键控流上操作时，coProcessFunction和keyedCoProcessFunction几乎可以互换和相同地扩展(覆盖processElement1、processElement2和onTimer(，那么，当对键控流进行操作时，与keyedCoProcessFunction相比，扩展CoProcessFunction以实现键控连接流的业务逻辑有什么区别？

谢谢。

Answer 1

KeyedCoProcessFunction和KeyedProcessFunction是最近添加的。与非键控风格相比，不同之处在于当前键在传递给各种processElement和onTimer方法的Context中可用。

如果您尝试在ProcessFunction或CoProcessFunction中使用键控状态或计时器，那么如果您实际处于键控上下文中，它将起作用，如果您不在键控上下文中将抛出异常。