Flink的DataStream API

对于Flink的 DataStream API 的使用无非是下面的流程： graph LR a[执行环境] b[数据源] c[转换] d[输出] a-->b b-->c c-->d 执行环境 Execution Environment 获取执行环境最简单最常见的方法就是： import org.ap