Package org.apache.nemo.runtime.executor.data.stores

Class LocalBlockStore

java.lang.Object

org.apache.nemo.runtime.executor.data.stores.AbstractBlockStore

org.apache.nemo.runtime.executor.data.stores.LocalBlockStore

All Implemented Interfaces:

BlockStore

Direct Known Subclasses:

LocalFileStore, MemoryStore, SerializedMemoryStore

public abstract class LocalBlockStore
extends AbstractBlockStore

This abstract class represents BlockStore which contains the (meta)data of the Blocks in local. Because of this, store can maintain all blocks in a single map (mapped with their IDs).

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	LocalBlockStore(SerializerManager coderManager, MemoryPoolAssigner memoryPoolAssigner)	Constructor.

Method Summary

Modifier and Type	Method	Description
protected java.util.Map<java.lang.String,Block>	getBlockMap()
java.util.Optional<Block>	readBlock(java.lang.String blockId)	Reads a committed block from this store.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.nemo.runtime.executor.data.stores.BlockStore

createBlock, deleteBlock, writeBlock

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 java.util.Optional<Block> readBlock(java.lang.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 java.util.Map<java.lang.String,Block> getBlockMap()

Returns:

the map between the IDs and Block.