diff options
author | Prashant Sharma <prashant.s@imaginea.com> | 2013-08-23 09:40:28 +0530 |
---|---|---|
committer | Prashant Sharma <prashant.s@imaginea.com> | 2013-08-23 09:40:28 +0530 |
commit | 3049415e245eefac0593a3e33ee7c8a845eeb800 (patch) | |
tree | 3129050796014f6adf2ef72f661796b34820e980 /streaming/src | |
parent | 39a1d58da484165790c61a924550b58837997f0d (diff) | |
download | spark-3049415e245eefac0593a3e33ee7c8a845eeb800.tar.gz spark-3049415e245eefac0593a3e33ee7c8a845eeb800.tar.bz2 spark-3049415e245eefac0593a3e33ee7c8a845eeb800.zip |
Corrections in documentation comment
Diffstat (limited to 'streaming/src')
-rw-r--r-- | streaming/src/main/scala/spark/streaming/dstream/NetworkInputDStream.scala | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/streaming/src/main/scala/spark/streaming/dstream/NetworkInputDStream.scala b/streaming/src/main/scala/spark/streaming/dstream/NetworkInputDStream.scala index 122a529bb7..d98d73a5a8 100644 --- a/streaming/src/main/scala/spark/streaming/dstream/NetworkInputDStream.scala +++ b/streaming/src/main/scala/spark/streaming/dstream/NetworkInputDStream.scala @@ -128,8 +128,8 @@ abstract class NetworkReceiver[T: ClassManifest]() extends Serializable with Log } /** - * Stops the receiver and reports to exception to the tracker. - * This should be called whenever an exception has happened on any thread + * Stops the receiver and reports exception to the tracker. + * This should be called whenever an exception is to be handled on any thread * of the receiver. */ protected def stopOnError(e: Exception) { @@ -185,7 +185,7 @@ abstract class NetworkReceiver[T: ClassManifest]() extends Serializable with Log } /** - * Batches objects created by a [[spark.streaming.NetworkReceiver]] and puts them into + * Batches objects created by a [[spark.streaming.dstream.NetworkReceiver]] and puts them into * appropriately named blocks at regular intervals. This class starts two threads, * one to periodically start a new batch and prepare the previous batch of as a block, * the other to push the blocks into the block manager. |