aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMosharaf Chowdhury <mosharaf@mosharaf-ubuntu.(none)>2010-11-29 14:13:35 -0800
committerMosharaf Chowdhury <mosharaf@mosharaf-ubuntu.(none)>2010-11-29 14:13:35 -0800
commitbb3e7fbf61ed26a107e43f0addfa718125a754f6 (patch)
tree08cffe3279e257307476f3a7fa56c8e446609aa3
parent19a6b194a9aceb3d7997f0acfc99530ac2792be4 (diff)
downloadspark-bb3e7fbf61ed26a107e43f0addfa718125a754f6.tar.gz
spark-bb3e7fbf61ed26a107e43f0addfa718125a754f6.tar.bz2
spark-bb3e7fbf61ed26a107e43f0addfa718125a754f6.zip
Variable renaming.
-rw-r--r--src/scala/spark/ChainedBroadcast.scala8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/scala/spark/ChainedBroadcast.scala b/src/scala/spark/ChainedBroadcast.scala
index 32f97ce442..3fc6a0fc90 100644
--- a/src/scala/spark/ChainedBroadcast.scala
+++ b/src/scala/spark/ChainedBroadcast.scala
@@ -1,15 +1,15 @@
package spark
+import com.google.common.collect.MapMaker
+
import java.io._
import java.net._
import java.util.{Comparator, PriorityQueue, Random, UUID}
-import com.google.common.collect.MapMaker
-
import scala.collection.mutable.{Map, Set}
@serializable
-class ChainedBroadcast[T] (@transient var value_ : T, local: Boolean)
+class ChainedBroadcast[T] (@transient var value_ : T, isLocal: Boolean)
extends Broadcast with Logging {
def value = value_
@@ -41,7 +41,7 @@ extends Broadcast with Logging {
@transient var stopBroadcast = false
// Must call this after all the variables have been created/initialized
- if (!local) {
+ if (!isLocal) {
sendBroadcast
}