Flink源碼解析——數據源讀入原理

Flink是分佈式並行計算框架，因此Flink程序內在是分佈和並行的，其並行的特性可在下述代碼片斷體現：php val env = ExecutionEnvironment.getExecutionEnvironment val text = env.readTextFile(inputPath) val data = text.flatMap(_.split(" "))

>>阅读原文<<