首先我们看一下,flink流的处理过程,可以看到,首先得到环境,然后
再去source获得数据源,然后transform处理数据,最后把数据存盘对吧
flink做的就是这样一个过程.
我们先看环境,Environment,这里
如果是用批处理需要创建:
ExecutionEnvironment.getExecutionEnvironment() 对吧.如果程序是独立调用没有并发执行,那么
此方法返回本地执行环境,如果是从命令行客户端,把这个写好的程序提交到了集群,那么这个方法,就会返回一个集群的执行环境对吧.可以看到他是自动判断的,这个ExecutionEnvironment.getExecutionEnvironment() 这里,会根据执行这个程序的是本地,还是集群自动返回对应的是本地环境还是集群环境.
然后,如果是用流处理来创建环境就是:
StreamExecutionEnvironment.getExecutionEnvironment() </
