diff options
| author | Chen Chao <crazyjvm@gmail.com> | 2014-04-16 17:30:01 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@apache.org> | 2014-04-16 17:30:01 -0700 |
| commit | 016a87764a7eb1092b6489e5f411d9e67c56e027 (patch) | |
| tree | a3baf5bd20acffaef81d3dd9f75bdf53903de3a4 /core | |
| parent | 17d323455a9c8b640f149be4a81139ed638765b5 (diff) | |
| download | spark-016a87764a7eb1092b6489e5f411d9e67c56e027.tar.gz spark-016a87764a7eb1092b6489e5f411d9e67c56e027.tar.bz2 spark-016a87764a7eb1092b6489e5f411d9e67c56e027.zip | |
remove unnecessary brace and semicolon in 'putBlockInfo.synchronize' block
delete semicolon
Author: Chen Chao <crazyjvm@gmail.com>
Closes #411 from CrazyJvm/patch-5 and squashes the following commits:
72333a3 [Chen Chao] remove unnecessary brace
de5d9a7 [Chen Chao] style fix
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/storage/BlockManager.scala | 11 |
1 files changed, 4 insertions, 7 deletions
diff --git a/core/src/main/scala/org/apache/spark/storage/BlockManager.scala b/core/src/main/scala/org/apache/spark/storage/BlockManager.scala index f14017051f..f15fa4dd7f 100644 --- a/core/src/main/scala/org/apache/spark/storage/BlockManager.scala +++ b/core/src/main/scala/org/apache/spark/storage/BlockManager.scala @@ -658,10 +658,9 @@ private[spark] class BlockManager( memoryStore.putValues(blockId, iterator, level, true) case ArrayBufferValues(array) => memoryStore.putValues(blockId, array, level, true) - case ByteBufferValues(bytes) => { + case ByteBufferValues(bytes) => bytes.rewind() memoryStore.putBytes(blockId, bytes, level) - } } size = res.size res.data match { @@ -677,10 +676,9 @@ private[spark] class BlockManager( tachyonStore.putValues(blockId, iterator, level, false) case ArrayBufferValues(array) => tachyonStore.putValues(blockId, array, level, false) - case ByteBufferValues(bytes) => { - bytes.rewind(); + case ByteBufferValues(bytes) => + bytes.rewind() tachyonStore.putBytes(blockId, bytes, level) - } } size = res.size res.data match { @@ -697,10 +695,9 @@ private[spark] class BlockManager( diskStore.putValues(blockId, iterator, level, askForBytes) case ArrayBufferValues(array) => diskStore.putValues(blockId, array, level, askForBytes) - case ByteBufferValues(bytes) => { + case ByteBufferValues(bytes) => bytes.rewind() diskStore.putBytes(blockId, bytes, level) - } } size = res.size res.data match { |