diff options
| author | Xin Ren <iamshrek@126.com> | 2016-05-30 08:40:03 -0500 |
|---|---|---|
| committer | Sean Owen <sowen@cloudera.com> | 2016-05-30 08:40:03 -0500 |
| commit | 5728aa558e44f056f3e5a7f8726ab174d3830103 (patch) | |
| tree | 28895b5ade8f36ad38801c502386c94a6e950bc6 /examples/src | |
| parent | 1360a6d636dd812a27955fc85df8e0255db60dfa (diff) | |
| download | spark-5728aa558e44f056f3e5a7f8726ab174d3830103.tar.gz spark-5728aa558e44f056f3e5a7f8726ab174d3830103.tar.bz2 spark-5728aa558e44f056f3e5a7f8726ab174d3830103.zip | |
[SPARK-15645][STREAMING] Fix some typos of Streaming module
## What changes were proposed in this pull request?
No code change, just some typo fixing.
## How was this patch tested?
Manually run project build with testing, and build is successful.
Author: Xin Ren <iamshrek@126.com>
Closes #13385 from keypointt/codeWalkThroughStreaming.
Diffstat (limited to 'examples/src')
| -rw-r--r-- | examples/src/main/scala/org/apache/spark/examples/streaming/CustomReceiver.scala | 2 | ||||
| -rw-r--r-- | examples/src/main/scala/org/apache/spark/examples/streaming/QueueStream.scala | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/examples/src/main/scala/org/apache/spark/examples/streaming/CustomReceiver.scala b/examples/src/main/scala/org/apache/spark/examples/streaming/CustomReceiver.scala index f70975eeb5..43044d01b1 100644 --- a/examples/src/main/scala/org/apache/spark/examples/streaming/CustomReceiver.scala +++ b/examples/src/main/scala/org/apache/spark/examples/streaming/CustomReceiver.scala @@ -29,7 +29,7 @@ import org.apache.spark.streaming.{Seconds, StreamingContext} import org.apache.spark.streaming.receiver.Receiver /** - * Custom Receiver that receives data over a socket. Received bytes is interpreted as + * Custom Receiver that receives data over a socket. Received bytes are interpreted as * text and \n delimited lines are considered as records. They are then counted and printed. * * To run this on your local machine, you need to first run a Netcat server diff --git a/examples/src/main/scala/org/apache/spark/examples/streaming/QueueStream.scala b/examples/src/main/scala/org/apache/spark/examples/streaming/QueueStream.scala index 5455aed220..19bacd4497 100644 --- a/examples/src/main/scala/org/apache/spark/examples/streaming/QueueStream.scala +++ b/examples/src/main/scala/org/apache/spark/examples/streaming/QueueStream.scala @@ -43,7 +43,7 @@ object QueueStream { reducedStream.print() ssc.start() - // Create and push some RDDs into + // Create and push some RDDs into rddQueue for (i <- 1 to 30) { rddQueue.synchronized { rddQueue += ssc.sparkContext.makeRDD(1 to 1000, 10) |