diff options
author | Mosharaf Chowdhury <mosharaf@cs.berkeley.edu> | 2012-07-09 22:07:46 -0700 |
---|---|---|
committer | Mosharaf Chowdhury <mosharaf@cs.berkeley.edu> | 2012-07-09 22:07:46 -0700 |
commit | cf1c60a1dec3e0e41ef639c4f487fc61c2257aa9 (patch) | |
tree | 789c419b35a591d9fdf38f43b4c43f29efbfce7f | |
parent | e71f69ad3d808166e4504385fd8fc18bdf61df9c (diff) | |
download | spark-cf1c60a1dec3e0e41ef639c4f487fc61c2257aa9.tar.gz spark-cf1c60a1dec3e0e41ef639c4f487fc61c2257aa9.tar.bz2 spark-cf1c60a1dec3e0e41ef639c4f487fc61c2257aa9.zip |
Refactoring
-rw-r--r-- | core/src/main/scala/spark/broadcast/Broadcast.scala | 10 | ||||
-rw-r--r-- | core/src/main/scala/spark/broadcast/MultiTracker.scala | 10 |
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 +} |