Yeah, I wanted to chat it person about that at first because I confused on
what will change. Then I got it. Will do.

On Tue, Jan 28, 2014 at 1:50 PM, Patrick Wendell
<notifications@github.com>wrote:

> In docs/streaming-programming-guide.md:
>
> >
> > -// Split the lines into words, count them, and print some of the counts on the master
> > -val words = lines.flatMap(_.split(" "))
> > -val wordCounts = words.map(x => (x, 1)).reduceByKey(_ + _)
> > -wordCounts.print()
> > +The update function will be called for each word, with `newValues` having a sequence of 1's (from
> > +the `(word, 1)` pairs) and the `runningCount` having the previous count. For the complete
> > +Scala code, take a look at the example
> > +[StatefulNetworkWordCount](https://github.com/apache/incubator-spark/blob/master/examples/src/
>
> TD - any thoughts on this one? We'll just have to do a big substitution
> otherwise when we move the site, seems like it would make sense to make it
> a variable.
>
> --
> Reply to this email directly or view it on GitHub<https://github.com/apache/incubator-spark/pull/497/files#r9246624>
> .
>