diff options
| -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. |