Flink从文件读取数据，输出到文件

1、文件准备

在项目的resource目录下创建一个words文件

文件内容&＃xff1a;

hello word
hello scala
hello flink
hello spark

 2、数据处理

文件准备后&＃xff0c;开始读取文件&＃xff0c;将处理后数据输出到目标文件中

代码&＃xff1a;

object Wordcount {def main(args: Array[String]): Unit &＃61; {//创建环境变量val env &＃61; StreamExecutionEnvironment.getExecutionEnvironment//设置并行为1env.setParallelism(1)//文件路径val filePath&＃61;"D:\\BBQ\\bigdata-dm\\flinkemo\\src\\main\\scala\\resource\\words.txt"//读取文件val inputDS&＃61;env.readTextFile(filePath)//分词统计import org.apache.flink.api.scala._val wordcountDS &＃61;inputDS.flatMap(_.split(" ")).map((_, 1)).keyBy(0).sum(1)wordcountDS.print()wordcountDS.writeAsText("D:\\BBQ\\bigdata-dm\\flinkemo\\src\\main\\scala\\resource\\result.txt")env.execute()}
}


 结果&＃xff1a;

3、 结论&＃xff1a;

可以看到resource目录下生成了一个result.txt文件&＃xff0c;文件内容是按代码逻辑处理过的结果。