就那官方的例子來說明，程式碼基本上有註釋

package com.lgh.sparkstreaming

import org.apache.spark.SparkConf
import org.apache.spark.storage.StorageLevel
import org.apache.spark.streaming.{Seconds, StreamingContext}

/**
  * Created by Administrator on 2017/8/22.
  */
object NetworkWordCount {
  def main(args: Array[String]) {
    if
 
 (args.length < 2) {
      System.err.println("Usage: NetworkWordCount <hostname> <port>")
      System.exit(1)
    }

    //建立SparkConf物件，在這我指定master為local[2],
    // 本地模式方便測試，另外需要注意，本地模式下local的必須大於等於2，否則就無法正確執行
    //因為接收資料和處理資料需要兩個執行緒。
    val sparkConf = new SparkConf().setAppName("NetworkWordCount"
 
).setMaster("local[2]");

    //批處理間隔，每10s，建立Streaming
    val ssc = new StreamingContext(sparkConf, Seconds(10))

    // Create a socket stream on target ip:port and count the
    // words in input stream of \n delimited text (eg. generated by 'nc')
    // Note that no duplication in storage level only for running locally.
 

    // Replication necessary in distributed scenario for fault tolerance.
    //構建資料來源為socket，
    val lines = ssc.socketTextStream(args(0), args(1).toInt, StorageLevel.MEMORY_AND_DISK_SER)

    //transform操作，資料轉換
    val words = lines.flatMap(_.split(" "))
    val wordCounts = words.map(x => (x, 1)).reduceByKey(_ + _)

    //output操作，streaming中必須至少有一個output 操作
    wordCounts.print()

    ssc.start()
    ssc.awaitTermination()
  }
}

程式執行方法：

在linux主機192.168.53.100上執行 nc -lk 9999（有不明白的大家可以百度下nc的用法）然後開始輸入單詞。

在idea中傳入引數192.168.53.100 9999，開始執行。

這個例子簡單來說呢，就是統計每10s內的單詞，然後計算這10s內的單詞個數並輸出。對於transformation以及output 的用法，可以自己查閱文件。