Constructor and Description |
---|
PositionReaderTest(PositionReader reader,
int fileLen) |
Modifier and Type | Method and Description |
---|---|
default PositionReader |
FileSystem.openPositionRead(AlluxioURI path)
Convenience method for
FileSystem.openPositionRead(AlluxioURI, OpenFilePOptions)
with default options. |
PositionReader |
DoraCacheFileSystem.openPositionRead(AlluxioURI path,
OpenFilePOptions options) |
PositionReader |
FileSystem.openPositionRead(AlluxioURI path,
OpenFilePOptions options)
Opens a file for position reading.
|
PositionReader |
DelegatingFileSystem.openPositionRead(AlluxioURI path,
OpenFilePOptions options) |
PositionReader |
DoraCacheFileSystem.openPositionRead(URIStatus status,
OpenFilePOptions options) |
PositionReader |
FileSystem.openPositionRead(URIStatus status,
OpenFilePOptions options)
Opens a file for reading.
|
PositionReader |
DelegatingFileSystem.openPositionRead(URIStatus status,
OpenFilePOptions options) |
Constructor and Description |
---|
PositionReadFileInStream(PositionReader reader,
long length)
Constructor.
|
Modifier and Type | Class and Description |
---|---|
class |
LocalCachePositionReader
Implementation of
PositionReader that reads from a local cache if possible. |
Modifier and Type | Method and Description |
---|---|
PositionReader |
LocalCacheFileSystem.openPositionRead(AlluxioURI path,
OpenFilePOptions options) |
PositionReader |
LocalCacheFileSystem.openPositionRead(URIStatus status,
OpenFilePOptions options) |
Modifier and Type | Method and Description |
---|---|
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) |
Modifier and Type | Class and Description |
---|---|
class |
DoraCachePositionReader
Implementation of
PositionReader that reads data through network from source. |
Modifier and Type | Method and Description |
---|---|
DoraCachePositionReader |
DoraCacheClient.createNettyPositionReader(URIStatus status,
Protocol.OpenUfsBlockOptions ufsOptions,
Optional<CloseableSupplier<PositionReader>> externalPositionReader) |
Constructor and Description |
---|
DoraCachePositionReader(PositionReader dataReader,
long length,
Optional<CloseableSupplier<PositionReader>> fallbackReader) |
Constructor and Description |
---|
DoraCachePositionReader(PositionReader dataReader,
long length,
Optional<CloseableSupplier<PositionReader>> fallbackReader) |
Modifier and Type | Class and Description |
---|---|
class |
NettyDataReader
Positioned Netty data reader.
|
Modifier and Type | Method and Description |
---|---|
PositionReader |
UfsBaseFileSystem.openPositionRead(AlluxioURI path,
OpenFilePOptions options) |
PositionReader |
UfsBaseFileSystem.openPositionRead(URIStatus status,
OpenFilePOptions options) |
Modifier and Type | Method and Description |
---|---|
PositionReader |
ManagedBlockingUfsForwarder.openPositionRead(String path,
long fileLength) |
Modifier and Type | Class and Description |
---|---|
class |
AlluxioHdfsPositionReader
A wrapper class to translate Hadoop FileSystem FSDataInputStream to Alluxio FileSystem
PositionReader.
|
Modifier and Type | Class and Description |
---|---|
class |
ObjectPositionReader
A stream for reading data using position reader.
|
Modifier and Type | Method and Description |
---|---|
PositionReader |
UnderFileSystemWithLogging.openPositionRead(String path,
long fileLength) |
PositionReader |
UnderFileSystem.openPositionRead(String path,
long fileLength)
Opens a file for position read.
|
Modifier and Type | Method and Description |
---|---|
PositionReader |
CephFSUnderFileSystem.openPositionRead(String path,
long fileLength) |
Modifier and Type | Class and Description |
---|---|
class |
COSPositionReader
Implementation of
ObjectPositionReader that reads from COS object store. |
Modifier and Type | Method and Description |
---|---|
PositionReader |
COSUnderFileSystem.openPositionRead(String path,
long fileLength) |
Modifier and Type | Class and Description |
---|---|
class |
GCSPositionReader
Implementation of
ObjectPositionReader that reads from GCS object store. |
Modifier and Type | Method and Description |
---|---|
PositionReader |
GCSUnderFileSystem.openPositionRead(String path,
long fileLength) |
Modifier and Type | Method and Description |
---|---|
PositionReader |
GCSV2UnderFileSystem.openPositionRead(String path,
long fileLength) |
Modifier and Type | Class and Description |
---|---|
class |
HdfsPositionedUnderFileInputStream
The input stream of HDFS as under filesystem.
|
Modifier and Type | Class and Description |
---|---|
class |
LocalPositionReader
Implementation of
PositionReader that reads from local UFS. |
Modifier and Type | Class and Description |
---|---|
class |
OBSPositionReader
Implementation of
ObjectPositionReader that reads from OBS object store. |
Modifier and Type | Method and Description |
---|---|
PositionReader |
OBSUnderFileSystem.openPositionRead(String path,
long fileLength) |
Modifier and Type | Class and Description |
---|---|
class |
OSSPositionReader
Implementation of
ObjectPositionReader that reads from OSS object store. |
Modifier and Type | Method and Description |
---|---|
PositionReader |
OSSUnderFileSystem.openPositionRead(String path,
long fileLength) |
Modifier and Type | Class and Description |
---|---|
class |
S3APositionReader
Implementation of
ObjectPositionReader that reads from S3A object store. |
Modifier and Type | Class and Description |
---|---|
class |
PagedFileReader
Paged file reader.
|
Copyright © 2023. All Rights Reserved.