org.apache.spark.streaming.receiver

Class BlockManagerBasedBlockHandler

Object

org.apache.spark.streaming.receiver.BlockManagerBasedBlockHandler

All Implemented Interfaces:

Logging, ReceivedBlockHandler

public class BlockManagerBasedBlockHandler
extends Object
implements ReceivedBlockHandler, Logging

Implementation of a ReceivedBlockHandler which stores the received blocks into a block manager with the specified storage level.

Constructor Summary

Constructors

Constructor and Description
BlockManagerBasedBlockHandler(BlockManager blockManager, StorageLevel storageLevel)

Method Summary

Methods

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

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.spark.Logging

initializeIfNecessary, initializeLogging, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning

Constructor Detail

BlockManagerBasedBlockHandler

public BlockManagerBasedBlockHandler(BlockManager blockManager,
                             StorageLevel storageLevel)

Method Detail

storeBlock

public ReceivedBlockStoreResult storeBlock(StreamBlockId blockId,
                                  ReceivedBlock block)

Description copied from interface: ReceivedBlockHandler

Store a received block with the given block id and return related metadata

Specified by:

storeBlock in interface ReceivedBlockHandler

cleanupOldBlocks

public void cleanupOldBlocks(long threshTime)

Description copied from interface: ReceivedBlockHandler

Cleanup old blocks older than the given threshold time

Specified by:

cleanupOldBlocks in interface ReceivedBlockHandler