Class SerializedMemoryStore

  • All Implemented Interfaces:
    BlockStore

    @ThreadSafe
    public final class SerializedMemoryStore
    extends LocalBlockStore
    Serialize and store data in local memory.
    • Method Detail

      • createBlock

        public Block createBlock​(String blockId)
        Description copied from interface: BlockStore
        Creates a new block. A stale data created by previous failed task should be handled during the creation of new block.
        Parameters:
        blockId - the ID of the block to create.
        Returns:
        the created block.
        See Also:
        BlockStore.createBlock(String)
      • writeBlock

        public void writeBlock​(Block block)
        Writes a committed block to this store.
        Parameters:
        block - the block to write.
        Throws:
        BlockWriteException - if fail to write.
      • deleteBlock

        public boolean deleteBlock​(String blockId)
        Description copied from interface: BlockStore
        Deletes a block from this store.
        Parameters:
        blockId - of the block.
        Returns:
        whether the partition exists or not.
        See Also:
        BlockStore.deleteBlock(String)