diff options
| author | Chen Chao <crazyjvm@gmail.com> | 2014-02-10 22:28:39 -0800 |
|---|---|---|
| committer | Reynold Xin <rxin@apache.org> | 2014-02-10 22:28:39 -0800 |
| commit | 4afe6ccf40223699c13665b1ed5e98d1604d3247 (patch) | |
| tree | fabf6b13b1464f37684c392b55fd9f45706ea7b2 /docs/streaming-programming-guide.md | |
| parent | d6a9bdc097458ee961072e67627ade8a0a9e3c58 (diff) | |
| download | spark-4afe6ccf40223699c13665b1ed5e98d1604d3247.tar.gz spark-4afe6ccf40223699c13665b1ed5e98d1604d3247.tar.bz2 spark-4afe6ccf40223699c13665b1ed5e98d1604d3247.zip | |
Merge pull request #579 from CrazyJvm/patch-1.
"in the source DStream" rather than "int the source DStream"
"flatMap is a one-to-many DStream operation that creates a new DStream by generating multiple new records from each record int the source DStream."
Author: Chen Chao <crazyjvm@gmail.com>
Closes #579 and squashes the following commits:
4abcae3 [Chen Chao] in the source DStream
Diffstat (limited to 'docs/streaming-programming-guide.md')
| -rw-r--r-- | docs/streaming-programming-guide.md | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/docs/streaming-programming-guide.md b/docs/streaming-programming-guide.md index ccc1c8bf2c..6b3262fbd7 100644 --- a/docs/streaming-programming-guide.md +++ b/docs/streaming-programming-guide.md @@ -88,7 +88,7 @@ val words = lines.flatMap(_.split(" ")) {% endhighlight %} `flatMap` is a one-to-many DStream operation that creates a new DStream by -generating multiple new records from each record int the source DStream. In this case, +generating multiple new records from each record in the source DStream. In this case, each line will be split into multiple words and the stream of words is represented as the `words` DStream. Next, we want to count these words. |