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

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

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

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

回复