Package | Description |
---|---|
alluxio.client.file.cache | |
alluxio.file | |
alluxio.underfs |
Modifier and Type | Method and Description |
---|---|
static LocalCachePositionReader |
LocalCachePositionReader.create(CacheManager cacheManager,
CloseableSupplier<PositionReader> fallbackReader,
FileId fileId,
long fileSize,
long pageSize,
CacheContext cacheContext) |
Modifier and Type | Method and Description |
---|---|
static FileId |
FileId.of(long fileId)
Gets a long-based file ID.
|
static FileId |
FileId.of(String fileId)
Gets a String-based file ID.
|
Modifier and Type | Method and Description |
---|---|
InputStream |
UfsInputStreamCache.acquire(UnderFileSystem ufs,
String path,
FileId fileId,
OpenOptions openOptions)
Acquires an input stream.
|
CompletableFuture<Integer> |
UfsIOManager.read(ByteBuffer buf,
long offset,
long len,
FileId fileId,
String ufsPath,
UfsReadOptions options)
Read from ufs.
|
Copyright © 2023. All Rights Reserved.