diff options
| author | rmishra <rmishra@pivotal.io> | 2016-03-07 09:55:49 +0000 |
|---|---|---|
| committer | Sean Owen <sowen@cloudera.com> | 2016-03-07 09:55:49 +0000 |
| commit | 4b13896ebf7cecf9d50514a62165b612ee18124a (patch) | |
| tree | 576ca16f98e4bb5ec17f0c8a5ed43c367979b56f /docs/streaming-programming-guide.md | |
| parent | bc7a3ec290904f2d8802583bb0557bca1b8b01ff (diff) | |
| download | spark-4b13896ebf7cecf9d50514a62165b612ee18124a.tar.gz spark-4b13896ebf7cecf9d50514a62165b612ee18124a.tar.bz2 spark-4b13896ebf7cecf9d50514a62165b612ee18124a.zip | |
[SPARK-13705][DOCS] UpdateStateByKey Operation documentation incorrectly refers to StatefulNetworkWordCount
## What changes were proposed in this pull request?
The reference to StatefulNetworkWordCount.scala from updateStatesByKey documentation should be removed, till there is a example for updateStatesByKey.
## How was this patch tested?
Have tested the new documentation with jekyll build.
Author: rmishra <rmishra@pivotal.io>
Closes #11545 from rishitesh/SPARK-13705.
Diffstat (limited to 'docs/streaming-programming-guide.md')
| -rw-r--r-- | docs/streaming-programming-guide.md | 5 |
1 files changed, 1 insertions, 4 deletions
diff --git a/docs/streaming-programming-guide.md b/docs/streaming-programming-guide.md index 5d67a0a9a9..e92b01aa77 100644 --- a/docs/streaming-programming-guide.md +++ b/docs/streaming-programming-guide.md @@ -872,10 +872,7 @@ val runningCounts = pairs.updateStateByKey[Int](updateFunction _) {% endhighlight %} 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.scala]({{site.SPARK_GITHUB_URL}}/blob/master/examples/src/main/scala/org/apache -/spark/examples/streaming/StatefulNetworkWordCount.scala). +the `(word, 1)` pairs) and the `runningCount` having the previous count. </div> <div data-lang="java" markdown="1"> |