Skip to content

Commit

Permalink
Merge pull request lw-lin#21 from wongxingjun/xj-branch
Browse files Browse the repository at this point in the history
Fix typo: "transformation" -> "output"
  • Loading branch information
lw-lin authored Jul 7, 2016
2 parents c001005 + b93b0d6 commit ca2bb0f
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -294,7 +294,7 @@ val lines = ssc.socketTextStream("localhost", 9999)
val words = lines.flatMap(_.split(" ")) // DStream transformation
val pairs = words.map(word => (word, 1)) // DStream transformation
val wordCounts = pairs.reduceByKey(_ + _) // DStream transformation
wordCounts.print() // DStream transformation
wordCounts.print() // DStream output
// 上面 4 行利用 DStream transformation 构造出了 lines -> words -> pairs -> wordCounts -> .print() 这样一个 DStreamGraph
// 但注意,到目前是定义好了产生数据的 SocketReceiver,以及一个 DStreamGraph,这些都是静态的

Expand Down

0 comments on commit ca2bb0f

Please sign in to comment.