Package org.apache.spark.streaming.receiver

Interface ReceivedBlockHandler

public interface ReceivedBlockHandler
Trait that represents a class that handles the storage of blocks received by receiver

  • Method Details

    • cleanupOldBlocks

      void cleanupOldBlocks(long threshTime)
      Cleanup old blocks older than the given threshold time

    • storeBlock

      ReceivedBlockStoreResult storeBlock(StreamBlockId blockId, ReceivedBlock receivedBlock)
      Store a received block with the given block id and return related metadata