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

Variable renaming.

Browse source
This commit is contained in:
Mosharaf Chowdhury 2010-11-29 14:13:35 -08:00
parent 19a6b194a9
commit bb3e7fbf61
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
src/scala/spark/ChainedBroadcast.scala
View file

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