alluxio.client.file.cache

Class QuotaPageMetaStore

java.lang.Object

alluxio.client.file.cache.DefaultPageMetaStore

alluxio.client.file.cache.QuotaPageMetaStore

All Implemented Interfaces:

CacheStatus, PageMetaStore

@NotThreadSafe
public class QuotaPageMetaStore
extends DefaultPageMetaStore

A metastore implementation that tracking usage associated with each cache scope.

Field Summary

Fields inherited from class alluxio.client.file.cache.DefaultPageMetaStore

mLock

Constructor Summary

Constructors

Constructor and Description
QuotaPageMetaStore(CacheEvictorOptions cacheEvictorOptions, List<PageStoreDir> dirs)

Method Summary

Modifier and Type	Method and Description
void	addPage(PageId pageId, PageInfo pageInfo) Adds a new page to the cache.
long	bytes(CacheScope cacheScope)
PageInfo	evict(CacheScope cacheScope, PageStoreDir pageStoreDir)
PageInfo	getPageInfo(PageId pageId)
Optional<CacheUsage>	getUsage() Gets cache usage.
PageInfo	removePage(PageId pageId) Removes a page.
void	reset() Resets the meta store.

Methods inherited from class alluxio.client.file.cache.DefaultPageMetaStore

addTempPage, allocate, bytes, commitFile, getAllPagesByFileId, getLock, getStoreDirOfFile, getStoreDirs, hasPage, numPages, removePage

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

QuotaPageMetaStore

public QuotaPageMetaStore(CacheEvictorOptions cacheEvictorOptions,
                          List<PageStoreDir> dirs)

Parameters:

cacheEvictorOptions - options of cache evictor

dirs - storage directories

Method Detail

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

Overrides:

addPage in class DefaultPageMetaStore

Parameters:

pageId - page identifier

pageInfo - info of the page

getPageInfo

public PageInfo getPageInfo(PageId pageId)
                     throws PageNotFoundException

Specified by:

getPageInfo in interface PageMetaStore

Overrides:

getPageInfo in class DefaultPageMetaStore

Parameters:

pageId - page identifier

Returns:

page info

Throws:

PageNotFoundException

removePage

public PageInfo removePage(PageId pageId)
                    throws PageNotFoundException

Description copied from interface: PageMetaStore

Removes a page.

Specified by:

removePage in interface PageMetaStore

Overrides:

removePage in class DefaultPageMetaStore

Parameters:

pageId - page identifier

Returns:

page info removed

Throws:

PageNotFoundException

bytes

public long bytes(CacheScope cacheScope)

Parameters:

cacheScope - scope to query

Returns:

the total size of pages stored in bytes of the given scope

reset

public void reset()

Description copied from interface: PageMetaStore

Resets the meta store.

Specified by:

reset in interface PageMetaStore

Overrides:

reset in class DefaultPageMetaStore

evict

@Nullable
public PageInfo evict(CacheScope cacheScope,
                                PageStoreDir pageStoreDir)

Specified by:

evict in interface PageMetaStore

Overrides:

evict in class DefaultPageMetaStore

Parameters:

cacheScope - scope to evict

pageStoreDir - the page store dir targeted to evict

Returns:

a page to evict in this scope

getUsage

public Optional<CacheUsage> getUsage()

Description copied from interface: CacheStatus

Gets cache usage.

Specified by:

getUsage in interface CacheStatus

Overrides:

getUsage in class DefaultPageMetaStore

Returns:

cache usage, or none if reporting usage info is not supported