Package | Description |
---|---|
alluxio.client.file | |
alluxio.client.file.cache |
Modifier and Type | Method and Description |
---|---|
static CacheContext |
CacheContext.defaults() |
CacheContext |
URIStatus.getCacheContext() |
CacheContext |
CacheContext.setCacheIdentifier(String identifier) |
CacheContext |
CacheContext.setCacheQuota(CacheQuota cacheQuota) |
CacheContext |
CacheContext.setCacheScope(CacheScope cacheScope) |
CacheContext |
CacheContext.setHiveCacheContext(HiveCacheContext hiveCacheContext) |
CacheContext |
CacheContext.setTemporary(boolean isTemporary) |
Constructor and Description |
---|
URIStatus(FileInfo info,
CacheContext context)
Constructs an instance of this class from a
FileInfo . |
Modifier and Type | Method and Description |
---|---|
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) |
static LocalCachePositionReader |
LocalCachePositionReader.create(AlluxioConfiguration conf,
CacheManager cacheManager,
CloseableSupplier<PositionReader> fallbackReader,
URIStatus status,
long pageSize,
CacheContext cacheContext) |
static LocalCachePositionReader |
LocalCachePositionReader.create(CacheManager cacheManager,
CloseableSupplier<PositionReader> fallbackReader,
FileId fileId,
long fileSize,
long pageSize,
CacheContext cacheContext) |
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.
|
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.
|
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.
|
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 . |
default boolean |
CacheManager.put(PageId pageId,
byte[] page,
CacheContext cacheContext)
Puts a page into the cache manager with scope and quota respected.
|
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.
|
Copyright © 2023. All Rights Reserved.