從零開始寫一個Spark Structured Streaming程序來統計單詞個數

本文將從零開始寫一個Spark Structured Streaming程序來統計單詞的個數。單詞的來源是socket，讀者也可以換成kafka，計算的結果輸出到控制檯，讀者也可以改成輸出到kafka的某個topic。 準備環境： JDK和Scala安裝，並配置好環境變量JAVA_HOME和SCALA_HOME下面是配置好的環境信息： pilafiMac:~ pilaf$ java -versio

>>阅读原文<<