You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by yidan zhao <hi...@gmail.com> on 2021/10/09 03:19:24 UTC

为啥OneInputStreamOperator和TwoInputStreamOperator的processElementXX方法放到不同地方

如题，类似奇怪地方其实很多，举例如上。

OneInputStreamOperator中的processElement方法是通过继承Input接口的。

TwoInputStreamOperator中则是自己定义这部分接口方法。

我感觉要么都自己定义，要么搞个Input1，Input2接口，然后一个只继承Input1，另一个继承Input1和Input2这样不好吗。