然后我们再来看实际上,flink对数据的处理,反应到代码上可以看到都是对DataStream的处理对吧,然后我们看,可以分成3个部分,一个是source部分,这里就是对源数据流的读取,
然后transformation这个是转换的意思对吧,是对数据流的转换,然后再看sink这个是对数据流的输出
对吧.
transformation这个步跟spark不一样,不会区分转换算子和启动算子.
然后我们再看,把上面的 程序代码分成了3个部分以后,再去看可以看成一个数据流图了,
其实就是数据流的流动对吧,流动的各个阶段做了各种处理,这里要注意,可以看到输入source,这里
可以有多个,源数据的流也可以有多个,然后sink,也可以有多个对吧,因为这里输出sink,可以输出到
MysqL,也可以输出到redis,csv等等,可以有多个输出.
然后上面的这个数据流图可以看到他是一个有向无环图对吧.
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。
