public abstract class BlockStore extends Object implements Logging
Constructor and Description |
---|
BlockStore(BlockManager blockManager) |
Modifier and Type | Method and Description |
---|---|
BlockManager |
blockManager() |
void |
clear() |
abstract boolean |
contains(BlockId blockId) |
abstract scala.Option<java.nio.ByteBuffer> |
getBytes(BlockId blockId) |
abstract long |
getSize(BlockId blockId)
Return the size of a block in bytes.
|
abstract scala.Option<scala.collection.Iterator<Object>> |
getValues(BlockId blockId) |
abstract PutResult |
putArray(BlockId blockId,
Object[] values,
StorageLevel level,
boolean returnValues) |
abstract PutResult |
putBytes(BlockId blockId,
java.nio.ByteBuffer bytes,
StorageLevel level) |
abstract PutResult |
putIterator(BlockId blockId,
scala.collection.Iterator<Object> values,
StorageLevel level,
boolean returnValues)
Put in a block and, possibly, also return its content as either bytes or another Iterator.
|
abstract boolean |
remove(BlockId blockId)
Remove a block, if it exists.
|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
initializeIfNecessary, initializeLogging, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning
public BlockStore(BlockManager blockManager)
public BlockManager blockManager()
public abstract PutResult putBytes(BlockId blockId, java.nio.ByteBuffer bytes, StorageLevel level)
public abstract PutResult putIterator(BlockId blockId, scala.collection.Iterator<Object> values, StorageLevel level, boolean returnValues)
public abstract PutResult putArray(BlockId blockId, Object[] values, StorageLevel level, boolean returnValues)
public abstract long getSize(BlockId blockId)
public abstract scala.Option<java.nio.ByteBuffer> getBytes(BlockId blockId)
public abstract scala.Option<scala.collection.Iterator<Object>> getValues(BlockId blockId)
public abstract boolean remove(BlockId blockId)
blockId
- the block to remove.public abstract boolean contains(BlockId blockId)
public void clear()