Flinkx运行流程图

1. FlinkX简介

FlinkX 本质就是根据配置文件，创建一个Flink执行环境StreamExecutionEnvironment。添加source、sink，最后执行env.execute()

创建Source:  

由Reader的readData方法创建InputFormat读取数据并转化为DataStream。

创建Sink:

由Writer的writeData方法创建的OutputFormat导出到Target 数据源。

2. Flinkx Local Mode运行流程图

下图为FlinkX启动的Local模式，运行流程如下图所示：

 

3. 参考链接

https://blog.csdn.net/u013076044/article/details/106318601

https://blog.csdn.net/u013076044/category_10038738.html