alluxio.worker.page

Class PagedBlockMetaStore

java.lang.Object

alluxio.worker.page.PagedBlockMetaStore

All Implemented Interfaces:

PageMetaStore

public class PagedBlockMetaStore
extends Object
implements PageMetaStore

This class manages metadata for the paged block store.

Constructor Summary

Constructors

Constructor and Description
PagedBlockMetaStore(List<PagedBlockStoreDir> dirs)
PagedBlockMetaStore(List<PagedBlockStoreDir> dirs, Allocator allocator)

Method Summary

Modifier and Type	Method and Description
void	addBlock(PagedBlockMeta blockMeta)
void	addPage(PageId pageId, PageInfo pageInfo) Adds a new page to the cache.
void	addTempBlock(PagedTempBlockMeta blockMeta) Adds a temp block for writing.
void	addTempPage(PageId pageId, PageInfo pageInfo) Adds a new temp page to the cache.
PageStoreDir	allocate(String fileId, long pageSize) Allocates a page store directory for a page of a block.
long	bytes()
PagedBlockMeta	commit(long blockId)
void	commitFile(String fileId, String newFileId) Commits a temp file so that all its pages become permanent.
PageInfo	evict(CacheScope cacheScope, PageStoreDir pageStoreDir)
ReadWriteLock	getLock()
PageInfo	getPageInfo(PageId pageId)
List<PageStoreDir>	getStoreDirs() Gets the storage directories.
PagedBlockStoreMeta	getStoreMeta()
PagedBlockStoreMeta	getStoreMetaFull()
boolean	hasBlock(long blockId) Checks if at least one page of a block is currently being stored in the cache.
boolean	hasFullBlock(long blockId) Checks if the block is fully cached in the block store.
boolean	hasPage(PageId pageId)
boolean	hasTempBlock(long blockId)
long	numPages()
void	registerBlockStoreEventListener(BlockStoreEventListener listener)
PageInfo	removePage(PageId pageId) Removes a page.
void	reset() Resets the meta store.

Methods inherited from class java.lang.Object

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

Methods inherited from interface alluxio.client.file.cache.PageMetaStore

create, evict

Constructor Detail

PagedBlockMetaStore

public PagedBlockMetaStore(List<PagedBlockStoreDir> dirs)

Parameters:

dirs - the storage dirs

PagedBlockMetaStore

public PagedBlockMetaStore(List<PagedBlockStoreDir> dirs,
                           Allocator allocator)

Parameters:

dirs - dirs

allocator - allocator

Method Detail

hasBlock

public boolean hasBlock(long blockId)

Checks if at least one page of a block is currently being stored in the cache.

Parameters:

blockId - block ID

Returns:

true if the block is stored in the cache, false otherwise

hasTempBlock

public boolean hasTempBlock(long blockId)

Parameters:

blockId -

Returns:

if

hasFullBlock

public boolean hasFullBlock(long blockId)

Checks if the block is fully cached in the block store.

Parameters:

blockId - block ID

Returns:

true if the block has been fully cached, false otherwise

allocate

public PageStoreDir allocate(String fileId,
                             long pageSize)

Allocates a page store directory for a page of a block. The implementation additionally guarantees that, as long as there is at least one page of the block is being stored, all subsequent pages always get allocated to the same directory as the firstly allocated page. However, it is unspecified whether the same directory will be chosen for a block, when all of its pages are removed from the page store and then added back.

Specified by:

allocate in interface PageMetaStore

Parameters:

fileId - the block ID

pageSize - size of the page

Returns:

the allocated page store dir

getPageInfo

public PageInfo getPageInfo(PageId pageId)
                     throws PageNotFoundException

Specified by:

getPageInfo in interface PageMetaStore

Parameters:

pageId - page identifier

Returns:

page info

Throws:

PageNotFoundException

getLock

public ReadWriteLock getLock()

Specified by:

getLock in interface PageMetaStore

Returns:

the associated lock

hasPage

public boolean hasPage(PageId pageId)

Specified by:

hasPage in interface PageMetaStore

Parameters:

pageId - page identifier

Returns:

if a page is stored in cache

addPage

public void addPage(PageId pageId,
                    PageInfo pageInfo)

Description copied from interface: PageMetaStore

Adds a new page to the cache.

Specified by:

addPage in interface PageMetaStore

Parameters:

pageId - page identifier

pageInfo - info of the page

addTempPage

public void addTempPage(PageId pageId,
                        PageInfo pageInfo)

Description copied from interface: PageMetaStore

Adds a new temp page to the cache.

Specified by:

addTempPage in interface PageMetaStore

Parameters:

pageId - page identifier

pageInfo - info of the page

commitFile

public void commitFile(String fileId,
                       String newFileId)
                throws PageNotFoundException

Description copied from interface: PageMetaStore

Commits a temp file so that all its pages become permanent.

Specified by:

commitFile in interface PageMetaStore

Parameters:

fileId - the temp file to commit

newFileId - the new file name of the file after committing

Throws:

PageNotFoundException

commit

public PagedBlockMeta commit(long blockId)

Parameters:

blockId -

Returns:

the permanent block meta after committing

getStoreDirs

public List<PageStoreDir> getStoreDirs()

Description copied from interface: PageMetaStore

Gets the storage directories.

Specified by:

getStoreDirs in interface PageMetaStore

Returns:

the storage directories

removePage

public PageInfo removePage(PageId pageId)
                    throws PageNotFoundException

Description copied from interface: PageMetaStore

Removes a page.

Specified by:

removePage in interface PageMetaStore

Parameters:

pageId - page identifier

Returns:

page info removed

Throws:

PageNotFoundException

bytes

public long bytes()

Specified by:

bytes in interface PageMetaStore

Returns:

the total size of pages stored in bytes

numPages

public long numPages()

Specified by:

numPages in interface PageMetaStore

Returns:

the number of pages stored

reset

public void reset()

Description copied from interface: PageMetaStore

Resets the meta store.

Specified by:

reset in interface PageMetaStore

evict

public PageInfo evict(CacheScope cacheScope,
                      PageStoreDir pageStoreDir)

Specified by:

evict in interface PageMetaStore

Returns:

a page to evict

addBlock

public void addBlock(PagedBlockMeta blockMeta)

Parameters:

blockMeta -

addTempBlock

public void addTempBlock(PagedTempBlockMeta blockMeta)

Adds a temp block for writing. The block is always pinned so that its pages don't get evicted before the block is committed.

Parameters:

blockMeta - the temp block to add

registerBlockStoreEventListener

public void registerBlockStoreEventListener(BlockStoreEventListener listener)

Parameters:

listener - listener

getStoreMeta

public PagedBlockStoreMeta getStoreMeta()

Returns:

brief store meta

getStoreMetaFull

public PagedBlockStoreMeta getStoreMetaFull()

Returns:

detailed store meta including all block locations