Package | Description |
---|---|
alluxio.client.file.cache | |
alluxio.client.file.cache.store | |
alluxio.worker.http |
Modifier and Type | Method and Description |
---|---|
void |
DefaultPageMetaStore.commitFile(String fileId,
String newFileId) |
void |
PageMetaStore.commitFile(String fileId,
String newFileId)
Commits a temp file so that all its pages become permanent.
|
void |
TimeBoundPageStore.delete(PageId pageId) |
default void |
PageStore.delete(PageId pageId)
Deletes a page from the store.
|
default void |
PageStore.delete(PageId pageId,
boolean isTemporary)
Deletes a temporary page from the store.
|
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.
|
default int |
PageStore.get(PageId pageId,
ReadTargetBuffer buffer)
Gets a page from the store to the destination 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> |
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) |
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.
|
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) |
Modifier and Type | Method and Description |
---|---|
void |
HttpServerHandler.channelRead0(io.netty.channel.ChannelHandlerContext ctx,
io.netty.handler.codec.http.HttpObject msg) |
io.netty.channel.FileRegion |
PagedService.getPageFileRegion(String fileId,
long pageIndex)
Get
FileRegion object given fileId, pageIndex, and channel. |
Copyright © 2023. All Rights Reserved.