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 |
---|---|
List<PageId> |
NoExceptionCacheManager.getCachedPageIdsByFileId(String fileId,
long fileLength) |
List<PageId> |
LocalCacheManager.getCachedPageIdsByFileId(String fileId,
long fileLength) |
default List<PageId> |
CacheManager.getCachedPageIdsByFileId(String fileId,
long fileLength)
Get page ids by the given file id.
|
Modifier and Type | Method and Description |
---|---|
void |
QuotaPageMetaStore.addPage(PageId pageId,
PageInfo pageInfo) |
void |
DefaultPageMetaStore.addPage(PageId pageId,
PageInfo pageInfo) |
void |
PageMetaStore.addPage(PageId pageId,
PageInfo pageInfo)
Adds a new page to the cache.
|
void |
DefaultPageMetaStore.addTempPage(PageId pageId,
PageInfo pageInfo) |
void |
PageMetaStore.addTempPage(PageId pageId,
PageInfo pageInfo)
Adds a new temp page to the cache.
|
boolean |
CacheManagerWithShadowCache.append(PageId pageId,
int appendAt,
byte[] page,
CacheContext cacheContext) |
boolean |
NoExceptionCacheManager.append(PageId pageId,
int appendAt,
byte[] page,
CacheContext cacheContext) |
boolean |
LocalCacheManager.append(PageId pageId,
int appendAt,
byte[] page,
CacheContext cacheContext) |
boolean |
CacheManager.append(PageId pageId,
int appendAt,
byte[] page,
CacheContext cacheContext) |
boolean |
CacheManagerWithShadowCache.delete(PageId pageId) |
void |
TimeBoundPageStore.delete(PageId pageId) |
boolean |
NoExceptionCacheManager.delete(PageId pageId) |
boolean |
MultipleBloomShadowCacheManager.delete(PageId pageId) |
boolean |
ClockCuckooShadowCacheManager.delete(PageId pageId) |
boolean |
ShadowCacheManager.delete(PageId pageId)
Deletes a page from the cache.
|
boolean |
LocalCacheManager.delete(PageId pageId) |
boolean |
CacheManager.delete(PageId pageId)
Deletes a page from the cache.
|
default void |
PageStore.delete(PageId pageId)
Deletes a page from the store.
|
boolean |
LocalCacheManager.delete(PageId pageId,
boolean isTemporary)
delete the specified page.
|
default void |
PageStore.delete(PageId pageId,
boolean isTemporary)
Deletes a temporary page from the store.
|
void |
CacheManagerWithShadowCache.PageIdFunnel.funnel(PageId from,
com.google.common.hash.PrimitiveSink into) |
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 |
MultipleBloomShadowCacheManager.get(PageId pageId,
int bytesToRead,
CacheScope scope) |
int |
ClockCuckooShadowCacheManager.get(PageId pageId,
int bytesToRead,
CacheScope cacheScope) |
int |
ShadowCacheManager.get(PageId pageId,
int bytesToRead,
CacheScope scope)
Reads the entire page and refresh its access time if the queried page is found in the cache.
|
int |
NoExceptionCacheManager.get(PageId pageId,
int pageOffset,
int bytesToRead,
byte[] buffer,
int offsetInBuffer) |
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,
CacheContext cacheContext) |
default 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.
|
default int |
PageStore.get(PageId pageId,
int pageOffset,
int bytesToRead,
ReadTargetBuffer buffer)
Gets part of a page from the store to the destination buffer.
|
int |
TimeBoundPageStore.get(PageId pageId,
int pageOffset,
int bytesToRead,
ReadTargetBuffer target,
boolean isTemporary) |
int |
PageStore.get(PageId pageId,
int pageOffset,
int bytesToRead,
ReadTargetBuffer buffer,
boolean isTemporary)
Gets part of a page from the store to the destination buffer.
|
int |
CacheManagerWithShadowCache.get(PageId pageId,
int pageOffset,
int bytesToRead,
ReadTargetBuffer target,
CacheContext cacheContext) |
int |
NoExceptionCacheManager.get(PageId pageId,
int pageOffset,
int bytesToRead,
ReadTargetBuffer buffer,
CacheContext cacheContext) |
int |
LocalCacheManager.get(PageId pageId,
int pageOffset,
int bytesToRead,
ReadTargetBuffer buffer,
CacheContext cacheContext) |
int |
CacheManager.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 |
NoExceptionCacheManager.get(PageId pageId,
int pageOffset,
ReadTargetBuffer buffer,
CacheContext cacheContext) |
int |
LocalCacheManager.get(PageId pageId,
int pageOffset,
ReadTargetBuffer buffer,
CacheContext cacheContext) |
default int |
CacheManager.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.
|
default int |
PageStore.get(PageId pageId,
ReadTargetBuffer buffer)
Gets a page from the store to the destination buffer.
|
int |
CacheManagerWithShadowCache.getAndLoad(PageId pageId,
int pageOffset,
int bytesToRead,
ReadTargetBuffer buffer,
CacheContext cacheContext,
java.util.function.Supplier<byte[]> externalDataSupplier) |
int |
NoExceptionCacheManager.getAndLoad(PageId pageId,
int pageOffset,
int bytesToRead,
ReadTargetBuffer buffer,
CacheContext cacheContext,
java.util.function.Supplier<byte[]> externalDataSupplier) |
int |
LocalCacheManager.getAndLoad(PageId pageId,
int pageOffset,
int bytesToRead,
ReadTargetBuffer buffer,
CacheContext cacheContext,
java.util.function.Supplier<byte[]> externalDataSupplier) |
int |
CacheManager.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.
|
DataFileChannel |
TimeBoundPageStore.getDataFileChannel(PageId pageId,
int pageOffset,
int bytesToRead,
boolean isTemporary) |
default DataFileChannel |
PageStore.getDataFileChannel(PageId pageId,
int pageOffset,
int bytesToRead,
boolean isTemporary)
Get a
DataFileChannel which wraps a FileRegion . |
Optional<DataFileChannel> |
CacheManagerWithShadowCache.getDataFileChannel(PageId pageId,
int pageOffset,
int bytesToRead,
CacheContext cacheContext) |
Optional<DataFileChannel> |
NoExceptionCacheManager.getDataFileChannel(PageId pageId,
int pageOffset,
int bytesToRead,
CacheContext cacheContext) |
Optional<DataFileChannel> |
LocalCacheManager.getDataFileChannel(PageId pageId,
int pageOffset,
int bytesToRead,
CacheContext cacheContext) |
Optional<DataFileChannel> |
CacheManager.getDataFileChannel(PageId pageId,
int pageOffset,
int bytesToRead,
CacheContext cacheContext)
Get a
DataFileChannel which wraps a FileRegion . |
PageInfo |
QuotaPageMetaStore.getPageInfo(PageId pageId) |
PageInfo |
DefaultPageMetaStore.getPageInfo(PageId pageId) |
PageInfo |
PageMetaStore.getPageInfo(PageId pageId) |
int |
LocalCacheManager.getPageLockId(PageId pageId) |
boolean |
DefaultPageMetaStore.hasPage(PageId pageId) |
boolean |
PageMetaStore.hasPage(PageId pageId) |
boolean |
NoExceptionCacheManager.put(PageId pageId,
byte[] page) |
default boolean |
CacheManager.put(PageId pageId,
byte[] page)
Puts a page into the cache manager.
|
default void |
PageStore.put(PageId pageId,
byte[] page)
Writes a new page from a source channel to the store.
|
default void |
PageStore.put(PageId pageId,
byte[] page,
boolean isTemporary)
Writes a new page from a source channel to the store.
|
default boolean |
CacheManager.put(PageId pageId,
byte[] page,
CacheContext cacheContext)
Puts a page into the cache manager with scope and quota respected.
|
default boolean |
CacheManager.put(PageId pageId,
ByteBuffer page)
Puts a page into the cache manager.
|
void |
TimeBoundPageStore.put(PageId pageId,
ByteBuffer page,
boolean isTemporary) |
void |
PageStore.put(PageId pageId,
ByteBuffer page,
boolean isTemporary)
Writes a new page from a source channel to the store.
|
boolean |
CacheManagerWithShadowCache.put(PageId pageId,
ByteBuffer page,
CacheContext cacheContext) |
boolean |
NoExceptionCacheManager.put(PageId pageId,
ByteBuffer page,
CacheContext cacheContext) |
boolean |
LocalCacheManager.put(PageId pageId,
ByteBuffer page,
CacheContext cacheContext) |
boolean |
CacheManager.put(PageId pageId,
ByteBuffer page,
CacheContext cacheContext)
Puts a page into the cache manager with scope and quota respected.
|
boolean |
MultipleBloomShadowCacheManager.put(PageId pageId,
int size,
CacheScope scope) |
boolean |
ClockCuckooShadowCacheManager.put(PageId pageId,
int size,
CacheScope cacheScope) |
boolean |
ShadowCacheManager.put(PageId pageId,
int size,
CacheScope scope)
Puts a page with specified size and scope into the shadow cache manager.
|
default void |
PageStore.putTemporary(PageId pageId,
byte[] page)
Writes a new temporary page from a source channel to the store.
|
PageInfo |
QuotaPageMetaStore.removePage(PageId pageId) |
PageInfo |
DefaultPageMetaStore.removePage(PageId pageId) |
PageInfo |
PageMetaStore.removePage(PageId pageId)
Removes a page.
|
PageInfo |
DefaultPageMetaStore.removePage(PageId pageId,
boolean isTemporary) |
PageInfo |
PageMetaStore.removePage(PageId pageId,
boolean isTemporary)
Removes a page.
|
Constructor and Description |
---|
PageInfo(PageId pageId,
long pageSize,
CacheScope cacheScope,
PageStoreDir pageStoreDir) |
PageInfo(PageId pageId,
long pageSize,
CacheScope cacheScope,
PageStoreDir pageStoreDir,
long createdTimestamp) |
PageInfo(PageId pageId,
long pageSize,
PageStoreDir pageStoreDir) |
Modifier and Type | Field and Description |
---|---|
protected Map<PageId,Boolean> |
LRUCacheEvictor.mLRUCache |
Modifier and Type | Method and Description |
---|---|
PageId |
NondeterministicLRUCacheEvictor.evict() |
PageId |
LFUCacheEvictor.evict() |
PageId |
LRUCacheEvictor.evict() |
PageId |
UnevictableCacheEvictor.evict() |
PageId |
FIFOCacheEvictor.evict() |
PageId |
TwoChoiceRandomEvictor.evict() |
PageId |
CacheEvictor.evict() |
PageId |
NondeterministicLRUCacheEvictor.evictMatching(java.util.function.Predicate<PageId> criterion) |
PageId |
LFUCacheEvictor.evictMatching(java.util.function.Predicate<PageId> criterion) |
PageId |
LRUCacheEvictor.evictMatching(java.util.function.Predicate<PageId> criterion) |
PageId |
UnevictableCacheEvictor.evictMatching(java.util.function.Predicate<PageId> criterion) |
PageId |
FIFOCacheEvictor.evictMatching(java.util.function.Predicate<PageId> criterion) |
PageId |
TwoChoiceRandomEvictor.evictMatching(java.util.function.Predicate<PageId> criterion) |
PageId |
CacheEvictor.evictMatching(java.util.function.Predicate<PageId> criterion)
Picks the first candidate for eviction that satisfies the given criterion.
|
Modifier and Type | Method and Description |
---|---|
void |
LFUCacheEvictor.updateOnDelete(PageId pageId) |
void |
LRUCacheEvictor.updateOnDelete(PageId pageId) |
void |
UnevictableCacheEvictor.updateOnDelete(PageId pageId) |
void |
FIFOCacheEvictor.updateOnDelete(PageId pageId) |
void |
TwoChoiceRandomEvictor.updateOnDelete(PageId pageId) |
void |
CacheEvictor.updateOnDelete(PageId pageId)
Updates evictor after a delete operation.
|
void |
LFUCacheEvictor.updateOnGet(PageId pageId) |
void |
LRUCacheEvictor.updateOnGet(PageId pageId) |
void |
UnevictableCacheEvictor.updateOnGet(PageId pageId) |
void |
FIFOCacheEvictor.updateOnGet(PageId pageId) |
void |
TwoChoiceRandomEvictor.updateOnGet(PageId pageId) |
void |
CacheEvictor.updateOnGet(PageId pageId)
Updates evictor after a get operation.
|
void |
LFUCacheEvictor.updateOnPut(PageId pageId) |
void |
LRUCacheEvictor.updateOnPut(PageId pageId) |
void |
UnevictableCacheEvictor.updateOnPut(PageId pageId) |
void |
FIFOCacheEvictor.updateOnPut(PageId pageId) |
void |
TwoChoiceRandomEvictor.updateOnPut(PageId pageId) |
void |
CacheEvictor.updateOnPut(PageId pageId)
Updates evictor after a put operation.
|
Modifier and Type | Method and Description |
---|---|
PageId |
NondeterministicLRUCacheEvictor.evictMatching(java.util.function.Predicate<PageId> criterion) |
PageId |
LFUCacheEvictor.evictMatching(java.util.function.Predicate<PageId> criterion) |
PageId |
LRUCacheEvictor.evictMatching(java.util.function.Predicate<PageId> criterion) |
PageId |
UnevictableCacheEvictor.evictMatching(java.util.function.Predicate<PageId> criterion) |
PageId |
FIFOCacheEvictor.evictMatching(java.util.function.Predicate<PageId> criterion) |
PageId |
TwoChoiceRandomEvictor.evictMatching(java.util.function.Predicate<PageId> criterion) |
PageId |
CacheEvictor.evictMatching(java.util.function.Predicate<PageId> criterion)
Picks the first candidate for eviction that satisfies the given criterion.
|
Modifier and Type | Method and Description |
---|---|
PageId |
MemoryPageStore.getKeyFromPageId(PageId pageId) |
Modifier and Type | Method and Description |
---|---|
void |
MemoryPageStore.delete(PageId pageId) |
void |
LocalPageStore.delete(PageId pageId,
boolean isTemporary) |
int |
LocalPageStore.get(PageId pageId,
int pageOffset,
int bytesToRead,
ReadTargetBuffer target,
boolean isTemporary) |
int |
MemoryPageStore.get(PageId pageId,
int pageOffset,
int bytesToRead,
ReadTargetBuffer target,
boolean isTemporary) |
DataFileChannel |
LocalPageStore.getDataFileChannel(PageId pageId,
int pageOffset,
int bytesToRead,
boolean isTemporary) |
PageId |
MemoryPageStore.getKeyFromPageId(PageId pageId) |
Path |
LocalPageStore.getPagePath(PageId pageId,
boolean isTemporary) |
void |
LocalPageStore.put(PageId pageId,
ByteBuffer page,
boolean isTemporary) |
void |
MemoryPageStore.put(PageId pageId,
ByteBuffer page,
boolean isTemporary) |
Copyright © 2023. All Rights Reserved.