Package | Description |
---|---|
alluxio.client.file.cache | |
alluxio.client.file.cache.store | |
alluxio.worker.page |
Modifier and Type | Method and Description |
---|---|
PageInfo |
QuotaPageMetaStore.evict(CacheScope cacheScope,
PageStoreDir pageStoreDir) |
PageInfo |
PageMetaStore.evict(CacheScope cacheScope,
PageStoreDir pageStoreDir) |
PageInfo |
DefaultPageMetaStore.evict(CacheScope scope,
PageStoreDir pageStoreDir) |
default PageInfo |
PageMetaStore.evict(PageStoreDir pageStoreDir) |
PageInfo |
QuotaPageMetaStore.getPageInfo(PageId pageId) |
PageInfo |
PageMetaStore.getPageInfo(PageId pageId) |
PageInfo |
DefaultPageMetaStore.getPageInfo(PageId pageId) |
PageInfo |
QuotaPageMetaStore.removePage(PageId pageId) |
PageInfo |
PageMetaStore.removePage(PageId pageId)
Removes a page.
|
PageInfo |
DefaultPageMetaStore.removePage(PageId pageId) |
Modifier and Type | Method and Description |
---|---|
void |
QuotaPageMetaStore.addPage(PageId pageId,
PageInfo pageInfo) |
void |
PageMetaStore.addPage(PageId pageId,
PageInfo pageInfo)
Adds a new page to the cache.
|
void |
DefaultPageMetaStore.addPage(PageId pageId,
PageInfo pageInfo) |
void |
PageMetaStore.addTempPage(PageId pageId,
PageInfo pageInfo)
Adds a new temp page to the cache.
|
void |
DefaultPageMetaStore.addTempPage(PageId pageId,
PageInfo pageInfo) |
Modifier and Type | Method and Description |
---|---|
void |
LocalCacheManager.invalidate(java.util.function.Predicate<PageInfo> predicate) |
default void |
CacheManager.invalidate(java.util.function.Predicate<PageInfo> predicate)
Invalidate the pages that match the given predicate.
|
Modifier and Type | Method and Description |
---|---|
long |
PageStoreDir.deletePage(PageInfo bytes) |
void |
PageStoreDir.putPage(PageInfo pageInfo) |
void |
PageStoreDir.putTempPage(PageInfo pageInfo) |
Modifier and Type | Method and Description |
---|---|
void |
MemoryPageStoreDir.scanPages(java.util.function.Consumer<Optional<PageInfo>> pageInfoConsumer) |
void |
RocksPageStoreDir.scanPages(java.util.function.Consumer<Optional<PageInfo>> pageInfoConsumer) |
void |
LocalPageStoreDir.scanPages(java.util.function.Consumer<Optional<PageInfo>> pageInfoConsumer)
Gets a stream of all pages from the page store.
|
void |
PageStoreDir.scanPages(java.util.function.Consumer<Optional<PageInfo>> pageInfoConsumer)
Scan the pages under this dir.
|
Modifier and Type | Field and Description |
---|---|
protected com.google.common.collect.HashMultimap<Long,PageInfo> |
PagedBlockStoreDir.mBlockToPagesMap |
protected com.google.common.collect.HashMultimap<Long,PageInfo> |
PagedBlockStoreDir.mTempBlockToPagesMap |
Modifier and Type | Method and Description |
---|---|
PageInfo |
PagedBlockMetaStore.evict(CacheScope cacheScope,
PageStoreDir pageStoreDir) |
PageInfo |
PagedBlockMetaStore.getPageInfo(PageId pageId) |
PageInfo |
PagedBlockMetaStore.removePage(PageId pageId) |
Modifier and Type | Method and Description |
---|---|
void |
PagedBlockMetaStore.addPage(PageId pageId,
PageInfo pageInfo) |
void |
PagedBlockMetaStore.addTempPage(PageId pageId,
PageInfo pageInfo) |
long |
PagedBlockStoreDir.deletePage(PageInfo pageInfo) |
void |
PagedBlockStoreDir.putPage(PageInfo pageInfo) |
void |
PagedBlockStoreDir.putTempPage(PageInfo pageInfo) |
Modifier and Type | Method and Description |
---|---|
void |
PagedBlockStoreDir.scanPages(java.util.function.Consumer<Optional<PageInfo>> pageInfoConsumer) |
Copyright © 2023. All Rights Reserved.