Flinkx运行流程图

1. FlinkX简介 FlinkX 本质就是根据配置文件,创建一个Flink执行环境StreamExecutionEnvironment。添加source、sink,最后执行env.execute() 创建Source:   由Reader的readData方法创建InputFormat读取数据并转化为DataStream。 创建Sink: 由Writer的writeData方法创建的Outpu
相关文章
相关标签/搜索