alluxio.worker.page

Class PagedBlockStoreDir

java.lang.Object

alluxio.worker.page.PagedBlockStoreDir

All Implemented Interfaces:

PageStoreDir

public class PagedBlockStoreDir
extends Object
implements PageStoreDir

A directory storing paged blocks.

Field Summary

Fields

Modifier and Type	Field and Description
protected com.google.common.collect.HashMultimap<Long,PageInfo>	mBlockToPagesMap
protected PageStoreDir	mDelegate
protected BlockPageEvictor	mEvictor
protected int	mIndex
protected BlockStoreLocation	mLocation
protected com.google.common.collect.HashMultimap<Long,PageInfo>	mTempBlockToPagesMap

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

LOG

Constructor Summary

Constructors

Constructor and Description
PagedBlockStoreDir(PageStoreDir delegate, int index) Creates a new dir.

Method Summary

Modifier and Type	Method and Description
void	abort(String fileId) Abort a temporary file.
void	close() Close the page store dir.
void	commit(String fileId, String newFileId) Commit a temporary file with a new file ID.
long	deletePage(PageInfo pageInfo)
static List<PagedBlockStoreDir>	fromPageStoreDirs(List<PageStoreDir> dirs) Creates from a list of PageStoreDir.
long	getBlockCachedBytes(long blockId) Gets how many bytes of a block is being cached by this dir.
int	getBlockCachedPages(long blockId) Gets how many pages of a block is being cached by this dir.
Set<PageId>	getBlockPages(long blockId) Gets pages in this block.
long	getCachedBytes()
long	getCapacityBytes()
int	getDirIndex()
BlockPageEvictor	getEvictor()
BlockStoreLocation	getLocation()
int	getNumBlocks()
PageStore	getPageStore()
Path	getRootPath()
long	getTempBlockCachedBytes(long blockId) Gets how many bytes of a temp block is being cached by this dir.
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.

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, commit, createPageStoreDir, createPageStoreDirs, getFileBucket

Field Detail

mDelegate

protected final PageStoreDir mDelegate

mIndex

protected final int mIndex

mBlockToPagesMap

protected final com.google.common.collect.HashMultimap<Long,PageInfo> mBlockToPagesMap

mTempBlockToPagesMap

protected final com.google.common.collect.HashMultimap<Long,PageInfo> mTempBlockToPagesMap

mLocation

protected final BlockStoreLocation mLocation

mEvictor

protected final BlockPageEvictor mEvictor

Constructor Detail

PagedBlockStoreDir

public PagedBlockStoreDir(PageStoreDir delegate,
                          int index)

Creates a new dir.

Parameters:

delegate - the page store dir that is delegated to

index - the index of this dir in the tier

Method Detail

fromPageStoreDirs

public static List<PagedBlockStoreDir> fromPageStoreDirs(List<PageStoreDir> dirs)

Creates from a list of PageStoreDir.

Parameters:

dirs - dirs

Returns:

a list of PagedBlockStoreDir

getRootPath

public Path getRootPath()

Specified by:

getRootPath in interface PageStoreDir

Returns:

root path

getPageStore

public PageStore getPageStore()

Specified by:

getPageStore in interface PageStoreDir

Returns:

pageStore

getDirIndex

public int getDirIndex()

Returns:

index of this directory in the list of all directories

getLocation

public BlockStoreLocation getLocation()

Returns:

the block storage location of this directory

getNumBlocks

public int getNumBlocks()

Returns:

number of blocks being stored in this dir

getCapacityBytes

public long getCapacityBytes()

Specified by:

getCapacityBytes in interface PageStoreDir

Returns:

capacity

reset

public void reset()
           throws IOException

Description copied from interface: PageStoreDir

Reset page store.

Specified by:

reset in interface PageStoreDir

Throws:

IOException

scanPages

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

Description copied from interface: PageStoreDir

Scan the pages under this dir.

Specified by:

scanPages in interface PageStoreDir

Throws:

IOException

getCachedBytes

public long getCachedBytes()

Specified by:

getCachedBytes in interface PageStoreDir

Returns:

cached bytes in this directory

putPage

public void putPage(PageInfo pageInfo)

Specified by:

putPage in interface PageStoreDir

putTempPage

public void putTempPage(PageInfo pageInfo)

Specified by:

putTempPage in interface PageStoreDir

putTempFile

public boolean putTempFile(String fileId)

Specified by:

putTempFile in interface PageStoreDir

Parameters:

fileId - file id

Returns:

if the temp file is added successfully

reserve

public boolean reserve(long bytes)

Specified by:

reserve in interface PageStoreDir

Returns:

if the bytes requested could be reserved

deletePage

public long deletePage(PageInfo pageInfo)

Specified by:

deletePage in interface PageStoreDir

Returns:

the bytes used after release

release

public long release(long 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

hasTempFile

public boolean hasTempFile(String fileId)

Specified by:

hasTempFile in interface PageStoreDir

Returns:

true if the temp file is contained, false otherwise

getEvictor

public BlockPageEvictor 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

commit

public void commit(String fileId,
                   String newFileId)
            throws IOException

Description copied from interface: PageStoreDir

Commit a temporary file with a new file ID.

Specified by:

commit in interface PageStoreDir

Throws:

IOException

abort

public void abort(String fileId)
           throws IOException

Description copied from interface: PageStoreDir

Abort a temporary file.

Specified by:

abort in interface PageStoreDir

Throws:

IOException

getBlockCachedBytes

public long getBlockCachedBytes(long blockId)

Gets how many bytes of a block is being cached by this dir.

Parameters:

blockId - the block id

Returns:

total size of pages of this block being cached

getTempBlockCachedBytes

public long getTempBlockCachedBytes(long blockId)

Gets how many bytes of a temp block is being cached by this dir.

Parameters:

blockId - the block id

Returns:

total size of pages of this block being cached

getBlockCachedPages

public int getBlockCachedPages(long blockId)

Gets how many pages of a block is being cached by this dir.

Parameters:

blockId - the block id

Returns:

total number of pages of this block being cached

getBlockPages

public Set<PageId> getBlockPages(long blockId)

Gets pages in this block.

Parameters:

blockId - the block id

Returns:

pages in this block being cached