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