然后我们再来看实际上,flink对数据的处理,反应到代码上可以看到都是对DataStream的处理对吧,然后我们看,可以分成3个部分,一个是source部分,这里就是对源数据流的读取,

然后transformation这个是转换的意思对吧,是对数据流的转换,然后再看sink这个是对数据流的输出

对吧.

transformation这个步跟spark不一样,不会区分转换算子和启动算子.

 

      然后我们再看,把上面的 程序代码分成了3个部分以后,再去看可以看成一个数据流图了,

其实就是数据流的流动对吧,流动的各个阶段做了各种处理,这里要注意,可以看到输入source,这里

可以有多个,源数据的流也可以有多个,然后sink,也可以有多个对吧,因为这里输出sink,可以输出到

mysql,也可以输出到redis,csv等等,可以有多个输出.

      然后上面的这个数据流图可以看到他是一个有向无环图对吧.