Class LocalBlockStore

    • Constructor Detail

      • LocalBlockStore

        protected LocalBlockStore​(SerializerManager coderManager,
                                  MemoryPoolAssigner memoryPoolAssigner)
        Constructor.
        Parameters:
        coderManager - the coder manager.
        memoryPoolAssigner - the memory pool assigner.
    • Method Detail

      • readBlock

        public final Optional<Block> readBlock​(String blockId)
        Reads a committed block from this store.
        Parameters:
        blockId - of the target partition.
        Returns:
        the target block (if it exists).
      • getBlockMap

        protected final Map<String,​Block> getBlockMap()
        Returns:
        the map between the IDs and Block.