Make stopReceivers private

zsxwing · zsxwing · commit c41ee9464b0a · 2015-05-22T13:06:50.000-07:00
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceiverTracker.scala b/streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceiverTracker.scala
@@ -374,7 +374,7 @@ class ReceiverTracker(ssc: StreamingContext, skipReceiverLaunch: Boolean = false
     }
 
     /** Stops the receivers. */
-    def stopReceivers() {
+    private def stopReceivers() {
       // Signal the receivers to stop
       receiverInfo.values.flatMap { info => Option(info.endpoint)}
                          .foreach { _.send(StopReceiver) }

Original file line number	Diff line number	Diff line change
`@@ -374,7 +374,7 @@ class ReceiverTracker(ssc: StreamingContext, skipReceiverLaunch: Boolean = false`
`374`	`374`	`}`
`375`	`375`
`376`	`376`	`/** Stops the receivers. */`
`377`		`- def stopReceivers() {`
	`377`	`+ private def stopReceivers() {`
`378`	`378`	`// Signal the receivers to stop`
`379`	`379`	`receiverInfo.values.flatMap { info => Option(info.endpoint)}`
`380`	`380`	`.foreach { _.send(StopReceiver) }`