alluxio.master.metastore.heap

Class HeapBlockStore

java.lang.Object

alluxio.master.metastore.heap.HeapBlockStore

All Implemented Interfaces:

BlockStore, Iterable<BlockStore.Block>

@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()

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)
List<Block.BlockLocation>	getLocations(long blockid) Gets locations for a block.
Iterator<BlockStore.Block>	iterator()
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.

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

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()

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

iterator

public Iterator<BlockStore.Block> iterator()

Specified by:

iterator in interface Iterable<BlockStore.Block>

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

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