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 17626017841 <17...@163.com> on 2020/07/01 02:53:22 UTC

回复：【Flink的transformations】

hi，
除了source、sink、union之类有特有的Transformation，大部分算子都属于OneInputTransformation
 原始邮件 
发件人: 忝忝向仧<15...@qq.com>
收件人: user-zh<us...@flink.apache.org>
发送时间: 2020年6月29日(周一) 22:29
主题: 【Flink的transformations】


Hi,all: 请教下，Flink的应用程序首先都会转为逻辑映射也就是transformations，我看org.apache.flink.streaming.api.transformations包下面目前有17种Transformation类(SourceTransformation,SplitTransformation,TwoInputTransformation等)，有没有一个映射关系列表，也就是说应用程序里面哪些算子或者操作(比如map,flatmap,filter,connect,select等)会对应到哪一个Transformation类. 谢谢.