aboutsummaryrefslogtreecommitdiff
path: root/src/scala/spark/DfsBroadcast.scala
diff options
context:
space:
mode:
Diffstat (limited to 'src/scala/spark/DfsBroadcast.scala')
-rw-r--r--src/scala/spark/DfsBroadcast.scala4
1 files changed, 1 insertions, 3 deletions
diff --git a/src/scala/spark/DfsBroadcast.scala b/src/scala/spark/DfsBroadcast.scala
index 5be5f98e8c..a249961fd5 100644
--- a/src/scala/spark/DfsBroadcast.scala
+++ b/src/scala/spark/DfsBroadcast.scala
@@ -1,7 +1,5 @@
package spark
-import com.google.common.collect.MapMaker
-
import java.io._
import java.net._
import java.util.UUID
@@ -56,7 +54,7 @@ extends Broadcast with Logging {
private object DfsBroadcast
extends Logging {
- val values = new MapMaker ().softValues ().makeMap[UUID, Any]
+ val values = Cache.newKeySpace()
private var initialized = false