Flink读写数据（hdfs）（DataSet）

读数据 DataSet<String> hdfslines=env.readTextFile("your hdfs path") 写数据 hdfslines.writeAsText("your hdfs path") 以上会根据你的默认的线程数来生成多少个分区文件，若是你想最后生成一个文件的话，能够在后面使用setParallelism(1)，这样最后就只会生成一个文件了。javascript

>>阅读原文<<