alluxio.master.metastore.heap

Class HeapBlockStore

java.lang.Object

alluxio.master.metastore.heap.HeapBlockStore

All Implemented Interfaces:

BlockStore

@ThreadSafe
public class HeapBlockStore
extends Object
implements BlockStore

This class requires external synchronization for operations on the same block id. Operations on different block ids can be performed concurrently.

Nested Class Summary

Nested classes/interfaces inherited from interface alluxio.master.metastore.BlockStore

BlockStore.Block, BlockStore.Factory

Field Summary

Fields

Modifier and Type	Field and Description
TwoKeyConcurrentMap<Long,Long,Block.BlockLocation,Map<Long,Block.BlockLocation>>	mBlockLocations
Map<Long,Block.BlockMeta>	mBlocks

Constructor Summary

Constructors

Constructor and Description
HeapBlockStore() constructor a HeapBlockStore.

Method Summary

Modifier and Type	Method and Description
void	addLocation(long blockId, Block.BlockLocation location) Adds a new block location.
void	clear() Removes all metadata from the block store.
void	close() Closes the block store and releases all resources.
Optional<Block.BlockMeta>	getBlock(long id)
CloseableIterator<BlockStore.Block>	getCloseableIterator() Gets a CloseableIterator over the blocks.
List<Block.BlockLocation>	getLocations(long blockid) Gets locations for a block.
void	putBlock(long id, Block.BlockMeta meta) Adds block metadata to the block store.
void	removeBlock(long id) Removes a block, or does nothing if the block does not exist.
void	removeLocation(long blockId, long workerId) Removes a block location.
long	size()

Methods inherited from class java.lang.Object

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

Field Detail

mBlocks

public final Map<Long,Block.BlockMeta> mBlocks

mBlockLocations

public final TwoKeyConcurrentMap<Long,Long,Block.BlockLocation,Map<Long,Block.BlockLocation>> mBlockLocations

Constructor Detail

HeapBlockStore

public HeapBlockStore()

constructor a HeapBlockStore.

Method Detail

getBlock

public Optional<Block.BlockMeta> getBlock(long id)

Specified by:

getBlock in interface BlockStore

Parameters:

id - a block id

Returns:

the block's metadata, or empty if the block does not exist

putBlock

public void putBlock(long id,
                     Block.BlockMeta meta)

Description copied from interface: BlockStore

Adds block metadata to the block store. If the block already exists, its metadata will be updated to the given metadata.

Specified by:

putBlock in interface BlockStore

Parameters:

id - the block id

meta - the block metadata

removeBlock

public void removeBlock(long id)

Description copied from interface: BlockStore

Removes a block, or does nothing if the block does not exist.

Specified by:

removeBlock in interface BlockStore

Parameters:

id - a block id to remove

getCloseableIterator

public CloseableIterator<BlockStore.Block> getCloseableIterator()

Description copied from interface: BlockStore

Gets a CloseableIterator over the blocks. The iterator must be closed properly. One option is to follow the below idiom:

   try (CloseableIterator<Block> iter =
       mBlockStore.getCloseableIterator()) {
     while (iter.hasNext()) {
       // take the element and perform operations
     }
   }
 

If the iterator must be passed to other methods, it must be closed at the end of operation or on exceptions. Otherwise there can be a leak!

Specified by:

getCloseableIterator in interface BlockStore

Returns:

a CloseableIterator over the blocks

clear

public void clear()

Description copied from interface: BlockStore

Removes all metadata from the block store.

Specified by:

clear in interface BlockStore

close

public void close()

Description copied from interface: BlockStore

Closes the block store and releases all resources.

Specified by:

close in interface BlockStore

size

public long size()

Specified by:

size in interface BlockStore

Returns:

size of the block store

getLocations

public List<Block.BlockLocation> getLocations(long blockid)

Description copied from interface: BlockStore

Gets locations for a block. If the block does not exist or has no locations, an empty list is returned.

Specified by:

getLocations in interface BlockStore

Parameters:

blockid - a block id

Returns:

the locations of the block

addLocation

public void addLocation(long blockId,
                        Block.BlockLocation location)

Description copied from interface: BlockStore

Adds a new block location. If the location already exists, this method is a no-op.

Specified by:

addLocation in interface BlockStore

Parameters:

blockId - a block id

location - a block location

removeLocation

public void removeLocation(long blockId,
                           long workerId)

Description copied from interface: BlockStore

Removes a block location. If the location doesn't exist, this method is a no-op.

Specified by:

removeLocation in interface BlockStore

Parameters:

blockId - a block id

workerId - a worker id