Package | Description |
---|---|
alluxio.client.file.cache | |
alluxio.client.file.cache.evictor | |
alluxio.client.file.cache.store |
Modifier and Type | Method and Description |
---|---|
PageId |
PageInfo.getPageId() |
Modifier and Type | Method and Description |
---|---|
void |
DefaultMetaStore.addPage(PageId pageId,
PageInfo pageInfo) |
void |
QuotaMetaStore.addPage(PageId pageId,
PageInfo pageInfo) |
void |
MetaStore.addPage(PageId pageId,
PageInfo pageInfo)
Adds a new page to the cache.
|
void |
TimeBoundPageStore.delete(PageId pageId) |
boolean |
CacheManagerWithShadowCache.delete(PageId pageId) |
boolean |
LocalCacheManager.delete(PageId pageId) |
void |
PageStore.delete(PageId pageId)
Deletes a page from the store.
|
boolean |
CacheManager.delete(PageId pageId)
Deletes a page from the cache.
|
boolean |
NoExceptionCacheManager.delete(PageId pageId) |
void |
CacheManagerWithShadowCache.PageIdFunnel.funnel(PageId from,
com.google.common.hash.PrimitiveSink into) |
default int |
PageStore.get(PageId pageId,
byte[] buffer)
Gets a page from the store to the destination buffer.
|
default int |
CacheManager.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 |
NoExceptionCacheManager.get(PageId pageId,
int bytesToRead,
byte[] buffer,
int offsetInBuffer) |
int |
TimeBoundPageStore.get(PageId pageId,
int pageOffset,
int bytesToRead,
byte[] buffer,
int bufferOffset) |
int |
PageStore.get(PageId pageId,
int pageOffset,
int bytesToRead,
byte[] buffer,
int bufferOffset)
Gets part of a page from the store to the destination buffer.
|
default int |
CacheManager.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 |
NoExceptionCacheManager.get(PageId pageId,
int pageOffset,
int bytesToRead,
byte[] buffer,
int offsetInBuffer) |
int |
CacheManagerWithShadowCache.get(PageId pageId,
int pageOffset,
int bytesToRead,
byte[] buffer,
int offsetInBuffer,
CacheContext cacheContext) |
int |
LocalCacheManager.get(PageId pageId,
int pageOffset,
int bytesToRead,
byte[] buffer,
int offsetInBuffer,
CacheContext cacheContext) |
int |
CacheManager.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 |
NoExceptionCacheManager.get(PageId pageId,
int pageOffset,
int bytesToRead,
byte[] buffer,
int offsetInBuffer,
CacheContext cacheContext) |
PageInfo |
DefaultMetaStore.getPageInfo(PageId pageId) |
PageInfo |
QuotaMetaStore.getPageInfo(PageId pageId) |
PageInfo |
MetaStore.getPageInfo(PageId pageId) |
boolean |
DefaultMetaStore.hasPage(PageId pageId) |
boolean |
MetaStore.hasPage(PageId pageId) |
void |
TimeBoundPageStore.put(PageId pageId,
byte[] page) |
void |
PageStore.put(PageId pageId,
byte[] page)
Writes a new page from a source channel to the store.
|
default boolean |
CacheManager.put(PageId pageId,
byte[] page)
Puts a page into the cache manager.
|
boolean |
NoExceptionCacheManager.put(PageId pageId,
byte[] page) |
boolean |
CacheManagerWithShadowCache.put(PageId pageId,
byte[] page,
CacheContext cacheContext) |
boolean |
LocalCacheManager.put(PageId pageId,
byte[] page,
CacheContext cacheContext) |
boolean |
CacheManager.put(PageId pageId,
byte[] page,
CacheContext cacheContext)
Puts a page into the cache manager with scope and quota respected.
|
boolean |
NoExceptionCacheManager.put(PageId pageId,
byte[] page,
CacheContext cacheContext) |
PageInfo |
DefaultMetaStore.removePage(PageId pageId) |
PageInfo |
QuotaMetaStore.removePage(PageId pageId) |
PageInfo |
MetaStore.removePage(PageId pageId)
Removes a page.
|
Constructor and Description |
---|
PageInfo(PageId pageId,
long pageSize) |
PageInfo(PageId pageId,
long pageSize,
CacheScope cacheScope) |
Modifier and Type | Field and Description |
---|---|
protected Map<PageId,Boolean> |
LRUCacheEvictor.mLRUCache |
Modifier and Type | Method and Description |
---|---|
PageId |
NondeterministicLRUCacheEvictor.evict() |
PageId |
FIFOCacheEvictor.evict() |
PageId |
UnevictableCacheEvictor.evict() |
PageId |
LRUCacheEvictor.evict() |
PageId |
CacheEvictor.evict() |
PageId |
LFUCacheEvictor.evict() |
Modifier and Type | Method and Description |
---|---|
void |
FIFOCacheEvictor.updateOnDelete(PageId pageId) |
void |
UnevictableCacheEvictor.updateOnDelete(PageId pageId) |
void |
LRUCacheEvictor.updateOnDelete(PageId pageId) |
void |
CacheEvictor.updateOnDelete(PageId pageId)
Updates evictor after a delete operation.
|
void |
LFUCacheEvictor.updateOnDelete(PageId pageId) |
void |
FIFOCacheEvictor.updateOnGet(PageId pageId) |
void |
UnevictableCacheEvictor.updateOnGet(PageId pageId) |
void |
LRUCacheEvictor.updateOnGet(PageId pageId) |
void |
CacheEvictor.updateOnGet(PageId pageId)
Updates evictor after a get operation.
|
void |
LFUCacheEvictor.updateOnGet(PageId pageId) |
void |
FIFOCacheEvictor.updateOnPut(PageId pageId) |
void |
UnevictableCacheEvictor.updateOnPut(PageId pageId) |
void |
LRUCacheEvictor.updateOnPut(PageId pageId) |
void |
CacheEvictor.updateOnPut(PageId pageId)
Updates evictor after a put operation.
|
void |
LFUCacheEvictor.updateOnPut(PageId pageId) |
Modifier and Type | Method and Description |
---|---|
void |
LocalPageStore.delete(PageId pageId) |
void |
RocksPageStore.delete(PageId pageId) |
int |
LocalPageStore.get(PageId pageId,
int pageOffset,
int bytesToRead,
byte[] buffer,
int bufferOffset) |
int |
RocksPageStore.get(PageId pageId,
int pageOffset,
int bytesToRead,
byte[] buffer,
int bufferOffset) |
Path |
LocalPageStore.getFilePath(PageId pageId) |
void |
LocalPageStore.put(PageId pageId,
byte[] page) |
void |
RocksPageStore.put(PageId pageId,
byte[] page) |
Copyright © 2023. All Rights Reserved.