aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMosharaf Chowdhury <mosharaf@cs.berkeley.edu>2012-07-09 22:07:46 -0700
committerMosharaf Chowdhury <mosharaf@cs.berkeley.edu>2012-07-09 22:07:46 -0700
commitcf1c60a1dec3e0e41ef639c4f487fc61c2257aa9 (patch)
tree789c419b35a591d9fdf38f43b4c43f29efbfce7f
parente71f69ad3d808166e4504385fd8fc18bdf61df9c (diff)
downloadspark-cf1c60a1dec3e0e41ef639c4f487fc61c2257aa9.tar.gz
spark-cf1c60a1dec3e0e41ef639c4f487fc61c2257aa9.tar.bz2
spark-cf1c60a1dec3e0e41ef639c4f487fc61c2257aa9.zip
Refactoring
-rw-r--r--core/src/main/scala/spark/broadcast/Broadcast.scala10
-rw-r--r--core/src/main/scala/spark/broadcast/MultiTracker.scala10
2 files changed, 10 insertions, 10 deletions
diff --git a/core/src/main/scala/spark/broadcast/Broadcast.scala b/core/src/main/scala/spark/broadcast/Broadcast.scala
index d1e84da739..3126715d6b 100644
--- a/core/src/main/scala/spark/broadcast/Broadcast.scala
+++ b/core/src/main/scala/spark/broadcast/Broadcast.scala
@@ -73,13 +73,3 @@ object Broadcast extends Logging with Serializable {
def MasterHostAddress = MasterHostAddress_
}
-
-case class BroadcastBlock(blockID: Int, byteArray: Array[Byte])
-extends Serializable
-
-case class VariableInfo(@transient arrayOfBlocks : Array[BroadcastBlock],
- totalBlocks: Int,
- totalBytes: Int)
-extends Serializable {
- @transient var hasBlocks = 0
-}
diff --git a/core/src/main/scala/spark/broadcast/MultiTracker.scala b/core/src/main/scala/spark/broadcast/MultiTracker.scala
index 10f6fa923f..d75040b1f9 100644
--- a/core/src/main/scala/spark/broadcast/MultiTracker.scala
+++ b/core/src/main/scala/spark/broadcast/MultiTracker.scala
@@ -327,3 +327,13 @@ extends Logging {
return retVal
}
}
+
+case class BroadcastBlock(blockID: Int, byteArray: Array[Byte])
+extends Serializable
+
+case class VariableInfo(@transient arrayOfBlocks : Array[BroadcastBlock],
+ totalBlocks: Int,
+ totalBytes: Int)
+extends Serializable {
+ @transient var hasBlocks = 0
+}