Flink源码解析——数据源读入原理

Flink是分布式并行计算框架，因此Flink程序内在是分布和并行的，其并行的特性可在下述代码片断体现：php val env = ExecutionEnvironment.getExecutionEnvironment val text = env.readTextFile(inputPath) val data = text.flatMap(_.split(" "))

>>阅读原文<<