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

Posted to issues@flink.apache.org by "jianzhang.yjz (Jira)" <ji...@apache.org> on 2021/10/29 08:18:00 UTC

[jira] [Created] (FLINK-24698) Unified operator used in transformation

jianzhang.yjz created FLINK-24698:
-------------------------------------

             Summary: Unified operator used in transformation
                 Key: FLINK-24698
                 URL: https://issues.apache.org/jira/browse/FLINK-24698
             Project: Flink
          Issue Type: Improvement
          Components: API / DataStream
            Reporter: jianzhang.yjz
             Fix For: 1.15.0


I found that all _*Transformation*_ expect *_ReduceTransformation_* are passed _*StreamOperatorFactory*_ to construct _*XxxTranformation*_(such as *_OneInputTransformation_*). I think _*ReduceTransformation*_ should also be unified here, instead of transforming in _*ReduceTransformationTranslator*_.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)