diff options
author | Mosharaf Chowdhury <mosharaf@mosharaf-ubuntu.(none)> | 2010-11-29 14:13:35 -0800 |
---|---|---|
committer | Mosharaf Chowdhury <mosharaf@mosharaf-ubuntu.(none)> | 2010-11-29 14:13:35 -0800 |
commit | bb3e7fbf61ed26a107e43f0addfa718125a754f6 (patch) | |
tree | 08cffe3279e257307476f3a7fa56c8e446609aa3 | |
parent | 19a6b194a9aceb3d7997f0acfc99530ac2792be4 (diff) | |
download | spark-bb3e7fbf61ed26a107e43f0addfa718125a754f6.tar.gz spark-bb3e7fbf61ed26a107e43f0addfa718125a754f6.tar.bz2 spark-bb3e7fbf61ed26a107e43f0addfa718125a754f6.zip |
Variable renaming.
-rw-r--r-- | src/scala/spark/ChainedBroadcast.scala | 8 |
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 } |