Skip to content

Commit 2941c89

Browse files
committed
Clean up BlockStore (minor)
1 parent a8f181d commit 2941c89

File tree

1 file changed

+14
-8
lines changed

1 file changed

+14
-8
lines changed

core/src/main/scala/org/apache/spark/storage/BlockStore.scala

Lines changed: 14 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -24,11 +24,11 @@ import scala.collection.mutable.ArrayBuffer
2424
import org.apache.spark.Logging
2525

2626
/**
27-
* Abstract class to store blocks
27+
* Abstract class to store blocks.
2828
*/
29-
private[spark]
30-
abstract class BlockStore(val blockManager: BlockManager) extends Logging {
31-
def putBytes(blockId: BlockId, bytes: ByteBuffer, level: StorageLevel) : PutResult
29+
private[spark] abstract class BlockStore(val blockManager: BlockManager) extends Logging {
30+
31+
def putBytes(blockId: BlockId, bytes: ByteBuffer, level: StorageLevel): PutResult
3232

3333
/**
3434
* Put in a block and, possibly, also return its content as either bytes or another Iterator.
@@ -37,11 +37,17 @@ abstract class BlockStore(val blockManager: BlockManager) extends Logging {
3737
* @return a PutResult that contains the size of the data, as well as the values put if
3838
* returnValues is true (if not, the result's data field can be null)
3939
*/
40-
def putValues(blockId: BlockId, values: Iterator[Any], level: StorageLevel,
41-
returnValues: Boolean) : PutResult
40+
def putValues(
41+
blockId: BlockId,
42+
values: Iterator[Any],
43+
level: StorageLevel,
44+
returnValues: Boolean): PutResult
4245

43-
def putValues(blockId: BlockId, values: ArrayBuffer[Any], level: StorageLevel,
44-
returnValues: Boolean) : PutResult
46+
def putValues(
47+
blockId: BlockId,
48+
values: ArrayBuffer[Any],
49+
level: StorageLevel,
50+
returnValues: Boolean): PutResult
4551

4652
/**
4753
* Return the size of a block in bytes.

0 commit comments

Comments
 (0)