Flink入門示例——wordCount(二)

說明（批處理） 讀取HDFS數據 將處理結果寫入HDFS 代碼示例 package com.test import org.apache.flink.api.scala._ import org.apache.flink.core.fs.FileSystem.WriteMode /** * 讀取hdfs數據，把處理結果結果再寫入HDFS */ object WordCountBatch{

>>阅读原文<<