Fix spacing per code review

David McGuire · David McGuire · commit 8be6934030ac · 2015-04-20T09:36:38.000-07:00
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/receiver/RateLimiter.scala b/streaming/src/main/scala/org/apache/spark/streaming/receiver/RateLimiter.scala
@@ -37,7 +37,7 @@ private[receiver] abstract class RateLimiter(conf: SparkConf) extends Logging {
   private lazy val rateLimiter = GuavaRateLimiter.create(desiredRate)
 
   def waitToPush() {
-    if( desiredRate > 0 ) {
+    if (desiredRate > 0) {
       rateLimiter.acquire()
     }
   }

Original file line number	Diff line number	Diff line change
`@@ -37,7 +37,7 @@ private[receiver] abstract class RateLimiter(conf: SparkConf) extends Logging {`
`37`	`37`	`private lazy val rateLimiter = GuavaRateLimiter.create(desiredRate)`
`38`	`38`
`39`	`39`	`def waitToPush() {`
`40`		`- if( desiredRate > 0 ) {`
	`40`	`+ if (desiredRate > 0) {`
`41`	`41`	`rateLimiter.acquire()`
`42`	`42`	`}`
`43`	`43`	`}`