aboutsummaryrefslogtreecommitdiff
path: root/core
diff options
context:
space:
mode:
authorReynold Xin <rxin@apache.org>2014-08-09 23:06:54 -0700
committerReynold Xin <rxin@apache.org>2014-08-09 23:06:54 -0700
commit482c5afbf6f3f12ac23851300a33249b26ddff3c (patch)
treefbb5cf9ba376abe620c34c70afce00b3d7c8b76b /core
parent5b6585de6b939837d5bdc4b1a44634301949add6 (diff)
downloadspark-482c5afbf6f3f12ac23851300a33249b26ddff3c.tar.gz
spark-482c5afbf6f3f12ac23851300a33249b26ddff3c.tar.bz2
spark-482c5afbf6f3f12ac23851300a33249b26ddff3c.zip
Turn UpdateBlockInfo into case class.
This helps us log UpdateBlockInfo properly once #1870 is merged. Author: Reynold Xin <rxin@apache.org> Closes #1872 from rxin/UpdateBlockInfo and squashes the following commits: 0cee1c2 [Reynold Xin] Turn UpdateBlockInfo into case class.
Diffstat (limited to 'core')
-rw-r--r--core/src/main/scala/org/apache/spark/storage/BlockManagerMessages.scala20
1 files changed, 1 insertions, 19 deletions
diff --git a/core/src/main/scala/org/apache/spark/storage/BlockManagerMessages.scala b/core/src/main/scala/org/apache/spark/storage/BlockManagerMessages.scala
index 10b65286fb..2ba16b8476 100644
--- a/core/src/main/scala/org/apache/spark/storage/BlockManagerMessages.scala
+++ b/core/src/main/scala/org/apache/spark/storage/BlockManagerMessages.scala
@@ -53,7 +53,7 @@ private[spark] object BlockManagerMessages {
sender: ActorRef)
extends ToBlockManagerMaster
- class UpdateBlockInfo(
+ case class UpdateBlockInfo(
var blockManagerId: BlockManagerId,
var blockId: BlockId,
var storageLevel: StorageLevel,
@@ -84,24 +84,6 @@ private[spark] object BlockManagerMessages {
}
}
- object UpdateBlockInfo {
- def apply(
- blockManagerId: BlockManagerId,
- blockId: BlockId,
- storageLevel: StorageLevel,
- memSize: Long,
- diskSize: Long,
- tachyonSize: Long): UpdateBlockInfo = {
- new UpdateBlockInfo(blockManagerId, blockId, storageLevel, memSize, diskSize, tachyonSize)
- }
-
- // For pattern-matching
- def unapply(h: UpdateBlockInfo)
- : Option[(BlockManagerId, BlockId, StorageLevel, Long, Long, Long)] = {
- Some((h.blockManagerId, h.blockId, h.storageLevel, h.memSize, h.diskSize, h.tachyonSize))
- }
- }
-
case class GetLocations(blockId: BlockId) extends ToBlockManagerMaster
case class GetLocationsMultipleBlockIds(blockIds: Array[BlockId]) extends ToBlockManagerMaster