alluxio.master.metastore.rocks

Class RocksBlockStore

java.lang.Object

alluxio.master.metastore.rocks.RocksBlockStore

All Implemented Interfaces:

BlockStore, Iterable<BlockStore.Block>

@ThreadSafe
public class RocksBlockStore
extends Object
implements BlockStore

Block store backed by RocksDB.

Nested Class Summary

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

BlockStore.Block, BlockStore.Factory

Constructor Summary

Constructors

Constructor and Description
RocksBlockStore(String baseDir) Creates and initializes a rocks block store.

Method Summary

Modifier and Type	Method and Description
void	addLocation(long id, 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 id) 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.
long	size()

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

Constructor Detail

RocksBlockStore

public RocksBlockStore(String baseDir)

Creates and initializes a rocks block store.

Parameters:

baseDir - the base directory in which to store block store metadata

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

clear

public void clear()

Description copied from interface: BlockStore

Removes all metadata from the block store.

Specified by:

clear in interface BlockStore

size

public long size()

Specified by:

size in interface BlockStore

Returns:

size of the block store

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

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:

id - a block id

Returns:

the locations of the block

addLocation

public void addLocation(long id,
                        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:

id - 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

iterator

public Iterator<BlockStore.Block> iterator()

Specified by:

iterator in interface Iterable<BlockStore.Block>