[FLINK-5250] Unwrap WrappingFunction in AbstractStreamOperator.setOutputType()
This makes InternalWindowFunction subclasses WrappingFunctions and correctly forwards calls to setOutputType() by unwrapping WrappingFunction in the newly added StreamingFunctionUtils.
Showing
想要评论请 注册 或 登录