Spark之Streaming實時監聽Hdfs文件目錄

應用場景：咱們使用Streaming實時監聽指定的Hdfs目錄，當該目錄有新的文件增長會讀取它，並完成單詞計數的操做。 這裏和上一篇的差異就是：上一篇用的是socketTextStream而這裏用的是：textFileStream。 其餘沒有不一樣。 代碼展現：java import java.util.Arrays; import org.apache.spark.SparkConf; impo

>>阅读原文<<