alluxio.client.file.cache.store

Class RocksPageStoreDir

java.lang.Object

alluxio.client.file.cache.store.RocksPageStoreDir

All Implemented Interfaces:

PageStoreDir

public class RocksPageStoreDir
extends Object

Represent the dir and file level metadata of a rocksdb page store.

Field Summary

Fields inherited from interface alluxio.client.file.cache.store.PageStoreDir

LOG

Constructor Summary

Constructors

Constructor and Description
RocksPageStoreDir(PageStoreOptions pageStoreOptions, PageStore pageStore, CacheEvictor cacheEvictor) Constructor of RocksPageStoreDir.

Method Summary

Modifier and Type	Method and Description
void	close() Close the page store dir.
long	deletePage(PageInfo pageInfo)
long	getCachedBytes()
long	getCapacityBytes()
CacheEvictor	getEvictor()
PageStore	getPageStore()
Path	getRootPath()
boolean	hasFile(String fileId)
boolean	putPage(PageInfo pageInfo)
boolean	putTempFile(String fileId)
long	release(int bytes) Release the pre-reserved space.
boolean	reserve(int bytes)
void	reset() Reset page store.
void	scanPages(java.util.function.Consumer<Optional<PageInfo>> pageInfoConsumer) Scan the pages under this dir.

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.store.PageStoreDir

clear, createPageStoreDir, createPageStoreDirs, getFileBucket

Constructor Detail

RocksPageStoreDir

public RocksPageStoreDir(PageStoreOptions pageStoreOptions,
                         PageStore pageStore,
                         CacheEvictor cacheEvictor)

Constructor of RocksPageStoreDir.

Parameters:

pageStoreOptions -

pageStore -

cacheEvictor -

Method Detail

getPageStore

public PageStore getPageStore()

Returns:

pageStore

reset

public void reset()
           throws IOException

Description copied from interface: PageStoreDir

Reset page store.

Throws:

IOException

scanPages

public void scanPages(java.util.function.Consumer<Optional<PageInfo>> pageInfoConsumer)

Description copied from interface: PageStoreDir

Scan the pages under this dir.

getRootPath

public Path getRootPath()

Specified by:

getRootPath in interface PageStoreDir

Returns:

root path

getCapacityBytes

public long getCapacityBytes()

Specified by:

getCapacityBytes in interface PageStoreDir

Returns:

capacity

getCachedBytes

public long getCachedBytes()

Specified by:

getCachedBytes in interface PageStoreDir

Returns:

cached bytes in this directory

putPage

public boolean putPage(PageInfo pageInfo)

Specified by:

putPage in interface PageStoreDir

Returns:

if the page added successfully

deletePage

public long deletePage(PageInfo pageInfo)

Specified by:

deletePage in interface PageStoreDir

Returns:

the bytes used after release

putTempFile

public boolean putTempFile(String fileId)

Specified by:

putTempFile in interface PageStoreDir

Returns:

if the fileId added successfully

reserve

public boolean reserve(int bytes)

Specified by:

reserve in interface PageStoreDir

Returns:

if the bytes requested could be reserved

release

public long release(int bytes)

Description copied from interface: PageStoreDir

Release the pre-reserved space.

Specified by:

release in interface PageStoreDir

Returns:

the bytes used after the release

hasFile

public boolean hasFile(String fileId)

Specified by:

hasFile in interface PageStoreDir

Returns:

true if the file is contained, false otherwise

getEvictor

public CacheEvictor getEvictor()

Specified by:

getEvictor in interface PageStoreDir

Returns:

the evictor of this dir

close

public void close()

Description copied from interface: PageStoreDir

Close the page store dir.

Specified by:

close in interface PageStoreDir