alluxio.master.metastore.heap

Class HeapBlockMetaStore

java.lang.Object

alluxio.master.metastore.heap.HeapBlockMetaStore

All Implemented Interfaces:

BlockMetaStore

@ThreadSafe
public class HeapBlockMetaStore
extends Object
implements BlockMetaStore

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.BlockMetaStore

BlockMetaStore.Block, BlockMetaStore.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
HeapBlockMetaStore() 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<BlockMetaStore.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

HeapBlockMetaStore

public HeapBlockMetaStore()

constructor a HeapBlockStore.

Method Detail

getBlock

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

Specified by:

getBlock in interface BlockMetaStore

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: BlockMetaStore

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 BlockMetaStore

Parameters:

id - the block id

meta - the block metadata

removeBlock

public void removeBlock(long id)

Description copied from interface: BlockMetaStore

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

Specified by:

removeBlock in interface BlockMetaStore

Parameters:

id - a block id to remove

getCloseableIterator

public CloseableIterator<BlockMetaStore.Block> getCloseableIterator()

Description copied from interface: BlockMetaStore

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 BlockMetaStore

Returns:

a CloseableIterator over the blocks

clear

public void clear()

Description copied from interface: BlockMetaStore

Removes all metadata from the block store.

Specified by:

clear in interface BlockMetaStore

close

public void close()

Description copied from interface: BlockMetaStore

Closes the block store and releases all resources.

Specified by:

close in interface BlockMetaStore

size

public long size()

Specified by:

size in interface BlockMetaStore

Returns:

size of the block store

getLocations

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

Description copied from interface: BlockMetaStore

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 BlockMetaStore

Parameters:

blockid - a block id

Returns:

the locations of the block

addLocation

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

Description copied from interface: BlockMetaStore

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

Specified by:

addLocation in interface BlockMetaStore

Parameters:

blockId - a block id

location - a block location

removeLocation

public void removeLocation(long blockId,
                           long workerId)

Description copied from interface: BlockMetaStore

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

Specified by:

removeLocation in interface BlockMetaStore

Parameters:

blockId - a block id

workerId - a worker id