public interface ReceivedBlockHandler
Modifier and Type | Method and Description |
---|---|
void |
cleanupOldBlocks(long threshTime)
Cleanup old blocks older than the given threshold time
|
ReceivedBlockStoreResult |
storeBlock(StreamBlockId blockId,
ReceivedBlock receivedBlock)
Store a received block with the given block id and return related metadata
|
void cleanupOldBlocks(long threshTime)
ReceivedBlockStoreResult storeBlock(StreamBlockId blockId, ReceivedBlock receivedBlock)