alluxio.client.file.cache

Class NoExceptionCacheManager

java.lang.Object

alluxio.client.file.cache.NoExceptionCacheManager

All Implemented Interfaces:

CacheManager, CacheStatus, AutoCloseable

public class NoExceptionCacheManager
extends Object
implements CacheManager

A wrapper class of CacheManager without throwing unchecked exceptions.

Nested Class Summary

Nested classes/interfaces inherited from interface alluxio.client.file.cache.CacheManager

CacheManager.Factory, CacheManager.State

Constructor Summary

Constructors

Constructor and Description
NoExceptionCacheManager(CacheManager cacheManager)

Method Summary

Modifier and Type	Method and Description
boolean	append(PageId pageId, int appendAt, byte[] page, CacheContext cacheContext)
void	close()
void	commitFile(String fileId) Commit the File.
boolean	delete(PageId pageId) Deletes a page from the cache.
void	deleteFile(String fileId) Deletes all pages of the given file.
void	deleteTempFile(String fileId) Deletes all temporary pages of the given file.
int	get(PageId pageId, int bytesToRead, byte[] buffer, int offsetInBuffer) Reads the entire page if the queried page is found in the cache, stores the result in buffer.
int	get(PageId pageId, int pageOffset, int bytesToRead, byte[] buffer, int offsetInBuffer) Reads a part of a page if the queried page is found in the cache, stores the result in buffer.
int	get(PageId pageId, int pageOffset, int bytesToRead, byte[] buffer, int offsetInBuffer, CacheContext cacheContext) Reads a part of a page if the queried page is found in the cache, stores the result in buffer.
int	get(PageId pageId, int pageOffset, int bytesToRead, ReadTargetBuffer buffer, CacheContext cacheContext) Reads a part of a page if the queried page is found in the cache, stores the result in buffer.
int	get(PageId pageId, int pageOffset, ReadTargetBuffer buffer, CacheContext cacheContext) Reads a part of a page if the queried page is found in the cache, stores the result in buffer.
int	getAndLoad(PageId pageId, int pageOffset, int bytesToRead, ReadTargetBuffer buffer, CacheContext cacheContext, java.util.function.Supplier<byte[]> externalDataSupplier) Reads a part of a page if the queried page is found in the cache, stores the result in buffer.
List<PageId>	getCachedPageIdsByFileId(String fileId, long fileLength) Get page ids by the given file id.
Optional<DataFileChannel>	getDataFileChannel(PageId pageId, int pageOffset, int bytesToRead, CacheContext cacheContext) Get a DataFileChannel which wraps a FileRegion.
Optional<CacheUsage>	getUsage() Gets cache usage.
boolean	put(PageId pageId, byte[] page) Puts a page into the cache manager.
boolean	put(PageId pageId, ByteBuffer page, CacheContext cacheContext) Puts a page into the cache manager with scope and quota respected.
CacheManager.State	state()

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.CacheManager

invalidate, put, put

Constructor Detail

NoExceptionCacheManager

public NoExceptionCacheManager(CacheManager cacheManager)

Parameters:

cacheManager - delegated cache manager

Method Detail

commitFile

public void commitFile(String fileId)

Description copied from interface: CacheManager

Commit the File.

Specified by:

commitFile in interface CacheManager

Parameters:

fileId - the file ID

put

public boolean put(PageId pageId,
                   byte[] page)

Description copied from interface: CacheManager

Puts a page into the cache manager. This method is best effort. It is possible that this put operation returns without page written.

Specified by:

put in interface CacheManager

Parameters:

pageId - page identifier

page - page data

Returns:

true if the put was successful, false otherwise

put

public boolean put(PageId pageId,
                   ByteBuffer page,
                   CacheContext cacheContext)

Description copied from interface: CacheManager

Puts a page into the cache manager with scope and quota respected. This method is best effort. It is possible that this put operation returns without page written.

Specified by:

put in interface CacheManager

Parameters:

pageId - page identifier

page - page data

cacheContext - cache related context

Returns:

true if the put was successful, false otherwise

get

public int get(PageId pageId,
               int pageOffset,
               ReadTargetBuffer buffer,
               CacheContext cacheContext)

Description copied from interface: CacheManager

Reads a part of a page if the queried page is found in the cache, stores the result in buffer.

Specified by:

get in interface CacheManager

Parameters:

pageId - page identifier

pageOffset - offset into the page

buffer - destination buffer to write

cacheContext - cache related context

Returns:

number of bytes read, 0 if page is not found, -1 on errors

get

public int get(PageId pageId,
               int bytesToRead,
               byte[] buffer,
               int offsetInBuffer)

Description copied from interface: CacheManager

Reads the entire page if the queried page is found in the cache, stores the result in buffer.

Specified by:

get in interface CacheManager

Parameters:

pageId - page identifier

bytesToRead - number of bytes to read in this page

buffer - destination buffer to write

offsetInBuffer - offset in the destination buffer to write

Returns:

number of bytes read, 0 if page is not found, -1 on errors

get

public int get(PageId pageId,
               int pageOffset,
               int bytesToRead,
               byte[] buffer,
               int offsetInBuffer)

Description copied from interface: CacheManager

Reads a part of a page if the queried page is found in the cache, stores the result in buffer.

Specified by:

get in interface CacheManager

Parameters:

pageId - page identifier

pageOffset - offset into the page

bytesToRead - number of bytes to read in this page

buffer - destination buffer to write

offsetInBuffer - offset in the destination buffer to write

Returns:

number of bytes read, 0 if page is not found, -1 on errors

get

public int get(PageId pageId,
               int pageOffset,
               int bytesToRead,
               byte[] buffer,
               int offsetInBuffer,
               CacheContext cacheContext)

Description copied from interface: CacheManager

Reads a part of a page if the queried page is found in the cache, stores the result in buffer.

Specified by:

get in interface CacheManager

Parameters:

pageId - page identifier

pageOffset - offset into the page

bytesToRead - number of bytes to read in this page

buffer - destination buffer to write

offsetInBuffer - offset in the destination buffer to write

cacheContext - cache related context

Returns:

number of bytes read, 0 if page is not found, -1 on errors

get

public int get(PageId pageId,
               int pageOffset,
               int bytesToRead,
               ReadTargetBuffer buffer,
               CacheContext cacheContext)

Description copied from interface: CacheManager

Reads a part of a page if the queried page is found in the cache, stores the result in buffer.

Specified by:

get in interface CacheManager

Parameters:

pageId - page identifier

pageOffset - offset into the page

bytesToRead - number of bytes to read in this page

buffer - destination buffer to write

cacheContext - cache related context

Returns:

number of bytes read, 0 if page is not found, -1 on errors

getAndLoad

public int getAndLoad(PageId pageId,
                      int pageOffset,
                      int bytesToRead,
                      ReadTargetBuffer buffer,
                      CacheContext cacheContext,
                      java.util.function.Supplier<byte[]> externalDataSupplier)

Description copied from interface: CacheManager

Reads a part of a page if the queried page is found in the cache, stores the result in buffer. Loads the page otherwise.

Specified by:

getAndLoad in interface CacheManager

Parameters:

pageId - page identifier

pageOffset - offset into the page

bytesToRead - number of bytes to read in this page

buffer - destination buffer to write

cacheContext - cache related context

externalDataSupplier - the external data supplier to read a page

Returns:

number of bytes read, 0 if page is not found, -1 on errors

delete

public boolean delete(PageId pageId)

Description copied from interface: CacheManager

Deletes a page from the cache.

Specified by:

delete in interface CacheManager

Parameters:

pageId - page identifier

Returns:

true if the page is successfully deleted, false otherwise

getDataFileChannel

public Optional<DataFileChannel> getDataFileChannel(PageId pageId,
                                                    int pageOffset,
                                                    int bytesToRead,
                                                    CacheContext cacheContext)

Description copied from interface: CacheManager

Get a DataFileChannel which wraps a FileRegion.

Specified by:

getDataFileChannel in interface CacheManager

Parameters:

pageId - the page id

pageOffset - the offset inside the page

bytesToRead - the bytes to read

cacheContext - the cache context

Returns:

an object of DataFileChannel

state

public CacheManager.State state()

Specified by:

state in interface CacheManager

Returns:

state of this cache

append

public boolean append(PageId pageId,
                      int appendAt,
                      byte[] page,
                      CacheContext cacheContext)

Specified by:

append in interface CacheManager

Returns:

true if append was successful

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception

getCachedPageIdsByFileId

public List<PageId> getCachedPageIdsByFileId(String fileId,
                                             long fileLength)

Description copied from interface: CacheManager

Get page ids by the given file id.

Specified by:

getCachedPageIdsByFileId in interface CacheManager

Parameters:

fileId - file identifier

fileLength - file length (this will not be needed after we have per-file metadata)

Returns:

a list of page ids which belongs to the file

deleteFile

public void deleteFile(String fileId)

Description copied from interface: CacheManager

Deletes all pages of the given file.

Specified by:

deleteFile in interface CacheManager

Parameters:

fileId - the file id of the target file

deleteTempFile

public void deleteTempFile(String fileId)

Description copied from interface: CacheManager

Deletes all temporary pages of the given file.

Specified by:

deleteTempFile in interface CacheManager

Parameters:

fileId - the file id of the target file

getUsage

public Optional<CacheUsage> getUsage()

Description copied from interface: CacheStatus

Gets cache usage.

Specified by:

getUsage in interface CacheManager

Specified by:

getUsage in interface CacheStatus

Returns:

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