ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Corrections in documentation comment

Browse source
This commit is contained in:
Prashant Sharma 2013-08-23 09:40:28 +05:30
parent 39a1d58da4
commit 3049415e24
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
streaming/src/main/scala/spark/streaming/dstream/NetworkInputDStream.scala
View file

@ -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.