public class BlockManagerBasedBlockHandler extends Object implements ReceivedBlockHandler, Logging
ReceivedBlockHandler
which
stores the received blocks into a block manager with the specified storage level.Constructor and Description |
---|
BlockManagerBasedBlockHandler(BlockManager blockManager,
StorageLevel storageLevel) |
Modifier and Type | Method and Description |
---|---|
void |
cleanupOldBlocks(long threshTime)
Cleanup old blocks older than the given threshold time
|
ReceivedBlockStoreResult |
storeBlock(StreamBlockId blockId,
ReceivedBlock block)
Store a received block with the given block id and return related metadata
|
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 BlockManagerBasedBlockHandler(BlockManager blockManager, StorageLevel storageLevel)
public ReceivedBlockStoreResult storeBlock(StreamBlockId blockId, ReceivedBlock block)
ReceivedBlockHandler
storeBlock
in interface ReceivedBlockHandler
public void cleanupOldBlocks(long threshTime)
ReceivedBlockHandler
cleanupOldBlocks
in interface ReceivedBlockHandler