alluxio.client.file.cache.store

Interface PageStoreDir

All Known Implementing Classes:

LocalPageStoreDir, MemoryPageStoreDir, PagedBlockStoreDir, RocksPageStoreDir

public interface PageStoreDir

Directory of page store.

Field Summary

Fields

Modifier and Type	Field and Description
static org.slf4j.Logger	LOG

Method Summary

Modifier and Type	Method and Description
void	abort(String fileId) Abort a temporary file.
static void	clear(Path rootPath) Clear the dir.
void	close() Close the page store dir.
default void	commit(String fileId) Commit a temporary file.
void	commit(String fileId, String newFileId) Commit a temporary file with a new file ID.
static PageStoreDir	createPageStoreDir(CacheEvictorOptions cacheEvictorOptions, PageStoreOptions pageStoreOptions) Create an instance of PageStoreDir.
static List<PageStoreDir>	createPageStoreDirs(CacheManagerOptions options) Create a list of PageStoreDir based on the configuration.
long	deletePage(PageInfo bytes)
long	getCachedBytes()
long	getCapacityBytes()
CacheEvictor	getEvictor()
static String	getFileBucket(int fileBuckets, String fileId)
PageStore	getPageStore()
Path	getRootPath()
boolean	hasFile(String fileId)
boolean	hasTempFile(String fileId)
void	putPage(PageInfo pageInfo)
boolean	putTempFile(String fileId)
void	putTempPage(PageInfo pageInfo)
long	release(long bytes) Release the pre-reserved space.
boolean	reserve(long bytes)
void	reset() Reset page store.
void	scanPages(java.util.function.Consumer<Optional<PageInfo>> pageInfoConsumer) Scan the pages under this dir.

Field Detail

LOG

static final org.slf4j.Logger LOG

Method Detail

createPageStoreDirs

static List<PageStoreDir> createPageStoreDirs(CacheManagerOptions options)
                                       throws IOException

Create a list of PageStoreDir based on the configuration.

Parameters:

options - of cache manager

Returns:

A list of LocalCacheDir

Throws:

IOException

createPageStoreDir

static PageStoreDir createPageStoreDir(CacheEvictorOptions cacheEvictorOptions,
                                       PageStoreOptions pageStoreOptions)

Create an instance of PageStoreDir.

Parameters:

cacheEvictorOptions -

pageStoreOptions -

Returns:

PageStoreDir

getFileBucket

static String getFileBucket(int fileBuckets,
                            String fileId)

Parameters:

fileBuckets - number of buckets

fileId - file id

Returns:

file bucket

clear

static void clear(Path rootPath)
           throws IOException

Clear the dir.

Parameters:

rootPath -

Throws:

IOException - when failed to clean up the specific location

getRootPath

Path getRootPath()

Returns:

root path

getPageStore

PageStore getPageStore()

Returns:

pageStore

getCapacityBytes

long getCapacityBytes()

Returns:

capacity

reset

void reset()
    throws IOException

Reset page store.

Throws:

IOException

scanPages

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

Scan the pages under this dir.

Parameters:

pageInfoConsumer -

Throws:

IOException

getCachedBytes

long getCachedBytes()

Returns:

cached bytes in this directory

putPage

void putPage(PageInfo pageInfo)

Parameters:

pageInfo -

putTempPage

void putTempPage(PageInfo pageInfo)

Parameters:

pageInfo -

putTempFile

boolean putTempFile(String fileId)

Parameters:

fileId - file id

Returns:

if the temp file is added successfully

reserve

boolean reserve(long bytes)

Parameters:

bytes -

Returns:

if the bytes requested could be reserved

deletePage

long deletePage(PageInfo bytes)

Parameters:

bytes -

Returns:

the bytes used after release

release

long release(long bytes)

Release the pre-reserved space.

Parameters:

bytes -

Returns:

the bytes used after the release

hasFile

boolean hasFile(String fileId)

Parameters:

fileId -

Returns:

true if the file is contained, false otherwise

hasTempFile

boolean hasTempFile(String fileId)

Parameters:

fileId -

Returns:

true if the temp file is contained, false otherwise

getEvictor

CacheEvictor getEvictor()

Returns:

the evictor of this dir

close

void close()

Close the page store dir.

commit

default void commit(String fileId)
             throws IOException

Commit a temporary file.

Parameters:

fileId -

Throws:

IOException

commit

void commit(String fileId,
            String newFileId)
     throws IOException

Commit a temporary file with a new file ID.

Parameters:

fileId -

newFileId -

Throws:

IOException

abort

void abort(String fileId)
    throws IOException

Abort a temporary file.

Parameters:

fileId -

Throws:

IOException