Package | Description |
---|---|
alluxio | |
alluxio.client.file | |
alluxio.client.file.cache | |
alluxio.client.file.ufs | |
alluxio.hadoop | |
alluxio.proxy.s3 |
Modifier and Type | Method and Description |
---|---|
FileInStream |
StreamCache.getInStream(Integer key) |
Modifier and Type | Method and Description |
---|---|
Integer |
StreamCache.put(FileInStream is) |
Modifier and Type | Class and Description |
---|---|
class |
PositionReadFileInStream
Implementation of
FileInStream that reads from a dora cache if possible. |
Modifier and Type | Method and Description |
---|---|
default FileInStream |
FileSystem.openFile(AlluxioURI path)
Convenience method for
FileSystem.openFile(AlluxioURI, OpenFilePOptions) with default options. |
FileInStream |
MetadataCachingFileSystem.openFile(AlluxioURI path,
OpenFilePOptions options) |
FileInStream |
FileSystemCache.InstanceCachingFileSystem.openFile(AlluxioURI path,
OpenFilePOptions options) |
FileInStream |
DoraCacheFileSystem.openFile(AlluxioURI path,
OpenFilePOptions options) |
FileInStream |
FileSystem.openFile(AlluxioURI path,
OpenFilePOptions options)
Opens a file for reading.
|
FileInStream |
DelegatingFileSystem.openFile(AlluxioURI path,
OpenFilePOptions options) |
FileInStream |
FileSystemCache.InstanceCachingFileSystem.openFile(URIStatus status,
OpenFilePOptions options) |
FileInStream |
DoraCacheFileSystem.openFile(URIStatus status,
OpenFilePOptions options) |
FileInStream |
FileSystem.openFile(URIStatus status,
OpenFilePOptions options)
Opens a file for reading.
|
FileInStream |
DelegatingFileSystem.openFile(URIStatus status,
OpenFilePOptions options) |
Modifier and Type | Class and Description |
---|---|
class |
LocalCacheFileInStream
Implementation of
FileInStream that reads from a local cache if possible. |
Modifier and Type | Method and Description |
---|---|
FileInStream |
LocalCacheFileInStream.FileInStreamOpener.open(URIStatus uriStatus)
Opens an FSDataInputStream at the indicated Path.
|
FileInStream |
LocalCacheFileSystem.openFile(AlluxioURI path,
OpenFilePOptions options) |
FileInStream |
LocalCacheFileSystem.openFile(URIStatus status,
OpenFilePOptions options) |
Constructor and Description |
---|
LocalCacheFileInStream(URIStatus status,
LocalCacheFileInStream.FileInStreamOpener fileOpener,
CacheManager cacheManager,
AlluxioConfiguration conf,
Optional<FileInStream> externalFileInStream)
Constructor when the
URIStatus is already available. |
Modifier and Type | Class and Description |
---|---|
class |
UfsFileInStream
Supports reading from a ufs file directly.
|
Modifier and Type | Method and Description |
---|---|
FileInStream |
UfsBaseFileSystem.openFile(AlluxioURI path,
OpenFilePOptions options) |
FileInStream |
UfsBaseFileSystem.openFile(URIStatus status,
OpenFilePOptions options) |
Modifier and Type | Class and Description |
---|---|
class |
AlluxioHdfsInputStream
A wrapper class to translate Hadoop FileSystem FSDataInputStream to Alluxio FileSystem
FileInStream.
|
Modifier and Type | Field and Description |
---|---|
protected FileInStream |
BaseHdfsFileInputStream.mInputStream |
Constructor and Description |
---|
BaseHdfsFileInputStream(FileInStream inputStream,
org.apache.hadoop.fs.FileSystem.Statistics stats)
Constructs a new stream for reading a file from HDFS.
|
HdfsFileInputStream(FileInStream inputStream,
org.apache.hadoop.fs.FileSystem.Statistics stats)
Constructs a new stream for reading a file from HDFS.
|
Modifier and Type | Method and Description |
---|---|
static RangeFileInStream |
RangeFileInStream.Factory.create(FileInStream underlyingStream,
long underlyingLength,
S3RangeSpec range) |
Copyright © 2023. All Rights Reserved.