alluxio.client.file.cache

Class CacheManagerWithShadowCache

java.lang.Object

alluxio.client.file.cache.CacheManagerWithShadowCache

All Implemented Interfaces:

CacheManager, AutoCloseable

public class CacheManagerWithShadowCache
extends Object
implements CacheManager

A wrapper class of CacheManager with shadow cache.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	CacheManagerWithShadowCache.PageIdFunnel Funnel for PageId.

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

CacheManager.Factory, CacheManager.State

Constructor Summary

Constructors

Constructor and Description
CacheManagerWithShadowCache(CacheManager cacheManager, AlluxioConfiguration conf)

Method Summary

Modifier and Type	Method and Description
void	close()
boolean	delete(PageId pageId) Deletes a page from the cache.
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.
long	getShadowCacheByteHit()
long	getShadowCacheByteRead()
long	getShadowCacheBytes()
long	getShadowCachePageHit()
long	getShadowCachePageRead()
long	getShadowCachePages()
boolean	put(PageId pageId, byte[] page, CacheContext cacheContext) Puts a page into the cache manager with scope and quota respected.
CacheManager.State	state()
void	stopUpdate() Stop to switch bloom filters and update working set size.
void	switchBloomFilter() Replace the oldest bloom filter with a new one.
void	updateWorkingSetSize() Update working set size in number of pages and bytes.

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

get, get, put

Constructor Detail

CacheManagerWithShadowCache

public CacheManagerWithShadowCache(CacheManager cacheManager,
                                   AlluxioConfiguration conf)

Parameters:

cacheManager - the real cache manager

conf - the alluxio configuration

Method Detail

stopUpdate

public void stopUpdate()

Stop to switch bloom filters and update working set size.

updateWorkingSetSize

public void updateWorkingSetSize()

Update working set size in number of pages and bytes.

put

public boolean put(PageId pageId,
                   byte[] 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

switchBloomFilter

public void switchBloomFilter()

Replace the oldest bloom filter with a new one.

getShadowCachePages

public long getShadowCachePages()

Returns:

ShadowCachePages

getShadowCacheBytes

public long getShadowCacheBytes()

Returns:

ShadowCacheBytes

getShadowCachePageRead

public long getShadowCachePageRead()

Returns:

ShadowCacheBytes

getShadowCachePageHit

public long getShadowCachePageHit()

Returns:

ShadowCacheBytes

getShadowCacheByteRead

public long getShadowCacheByteRead()

Returns:

ShadowCacheBytes

getShadowCacheByteHit

public long getShadowCacheByteHit()

Returns:

ShadowCacheBytes

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

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

state

public CacheManager.State state()

Specified by:

state in interface CacheManager

Returns:

state of this cache

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception