Package | Description |
---|---|
alluxio.client.block | |
alluxio.client.file | |
alluxio.client.file.cache | |
alluxio.client.file.options | |
alluxio.hadoop | |
alluxio.job.util | |
alluxio.proxy.s3 | |
alluxio.util.webui |
Modifier and Type | Method and Description |
---|---|
Pair<WorkerNetAddress,BlockInStream.BlockInStreamSource> |
AlluxioBlockStore.getDataSourceAndType(BlockInfo info,
URIStatus status,
BlockLocationPolicy policy,
Map<WorkerNetAddress,Long> failedWorkers)
Gets the data source and type of data source of a block.
|
Modifier and Type | Method and Description |
---|---|
URIStatus |
RetryHandlingFileSystemMasterClient.createFile(AlluxioURI path,
CreateFilePOptions options) |
URIStatus |
FileSystemMasterClient.createFile(AlluxioURI path,
CreateFilePOptions options)
Creates a new file.
|
URIStatus |
MetadataCache.get(AlluxioURI path) |
default URIStatus |
FileSystem.getStatus(AlluxioURI path)
Convenience method for
FileSystem.getStatus(AlluxioURI, GetStatusPOptions) with default options. |
URIStatus |
FileSystemCache.InstanceCachingFileSystem.getStatus(AlluxioURI path,
GetStatusPOptions options) |
URIStatus |
BaseFileSystem.getStatus(AlluxioURI path,
GetStatusPOptions options) |
URIStatus |
MetadataCachingBaseFileSystem.getStatus(AlluxioURI path,
GetStatusPOptions options) |
URIStatus |
RetryHandlingFileSystemMasterClient.getStatus(AlluxioURI path,
GetStatusPOptions options) |
URIStatus |
FileSystem.getStatus(AlluxioURI path,
GetStatusPOptions options)
Gets the
URIStatus object that represents the metadata of an Alluxio path. |
URIStatus |
DelegatingFileSystem.getStatus(AlluxioURI path,
GetStatusPOptions options) |
URIStatus |
FileSystemMasterClient.getStatus(AlluxioURI path,
GetStatusPOptions options) |
Modifier and Type | Method and Description |
---|---|
List<URIStatus> |
MetadataCache.listStatus(AlluxioURI dir) |
default List<URIStatus> |
FileSystem.listStatus(AlluxioURI path)
Convenience method for
FileSystem.listStatus(AlluxioURI, ListStatusPOptions) with default
options. |
List<URIStatus> |
FileSystemCache.InstanceCachingFileSystem.listStatus(AlluxioURI path,
ListStatusPOptions options) |
List<URIStatus> |
BaseFileSystem.listStatus(AlluxioURI path,
ListStatusPOptions options) |
List<URIStatus> |
MetadataCachingBaseFileSystem.listStatus(AlluxioURI path,
ListStatusPOptions options) |
List<URIStatus> |
RetryHandlingFileSystemMasterClient.listStatus(AlluxioURI path,
ListStatusPOptions options) |
List<URIStatus> |
FileSystem.listStatus(AlluxioURI path,
ListStatusPOptions options)
If the path is a directory, returns the
URIStatus of all the direct entries in it. |
List<URIStatus> |
DelegatingFileSystem.listStatus(AlluxioURI path,
ListStatusPOptions options) |
List<URIStatus> |
FileSystemMasterClient.listStatus(AlluxioURI path,
ListStatusPOptions options) |
Modifier and Type | Method and Description |
---|---|
FileInStream |
FileSystemCache.InstanceCachingFileSystem.openFile(URIStatus status,
OpenFilePOptions options) |
FileInStream |
BaseFileSystem.openFile(URIStatus status,
OpenFilePOptions options) |
FileInStream |
FileSystem.openFile(URIStatus status,
OpenFilePOptions options)
Opens a file for reading.
|
FileInStream |
DelegatingFileSystem.openFile(URIStatus status,
OpenFilePOptions options) |
void |
MetadataCache.put(AlluxioURI path,
URIStatus status) |
void |
MetadataCache.put(String path,
URIStatus status) |
Modifier and Type | Method and Description |
---|---|
default void |
FileSystem.iterateStatus(AlluxioURI path,
java.util.function.Consumer<? super URIStatus> action)
Performs a specific action on each
URIStatus in the result of FileSystem.listStatus(alluxio.AlluxioURI) . |
void |
FileSystemCache.InstanceCachingFileSystem.iterateStatus(AlluxioURI path,
ListStatusPOptions options,
java.util.function.Consumer<? super URIStatus> action) |
void |
BaseFileSystem.iterateStatus(AlluxioURI path,
ListStatusPOptions options,
java.util.function.Consumer<? super URIStatus> action) |
void |
MetadataCachingBaseFileSystem.iterateStatus(AlluxioURI path,
ListStatusPOptions options,
java.util.function.Consumer<? super URIStatus> action) |
void |
RetryHandlingFileSystemMasterClient.iterateStatus(AlluxioURI path,
ListStatusPOptions options,
java.util.function.Consumer<? super URIStatus> action) |
void |
FileSystem.iterateStatus(AlluxioURI path,
ListStatusPOptions options,
java.util.function.Consumer<? super URIStatus> action)
Performs a specific action on each
URIStatus in the result of FileSystem.listStatus(alluxio.AlluxioURI) . |
void |
DelegatingFileSystem.iterateStatus(AlluxioURI path,
ListStatusPOptions options,
java.util.function.Consumer<? super URIStatus> action) |
void |
FileSystemMasterClient.iterateStatus(AlluxioURI path,
ListStatusPOptions options,
java.util.function.Consumer<? super URIStatus> action)
Performs a specific action on each
URIStatus in the result of FileSystemMasterClient.listStatus(alluxio.AlluxioURI, alluxio.grpc.ListStatusPOptions) . |
void |
MetadataCache.put(AlluxioURI dir,
List<URIStatus> statuses)
Caches list status results of a directory.
|
Constructor and Description |
---|
AlluxioFileInStream(URIStatus status,
InStreamOptions options,
FileSystemContext context) |
Modifier and Type | Method and Description |
---|---|
FileInStream |
LocalCacheFileInStream.FileInStreamOpener.open(URIStatus uriStatus)
Opens an FSDataInputStream at the indicated Path.
|
FileInStream |
LocalCacheFileSystem.openFile(URIStatus status,
OpenFilePOptions options) |
Constructor and Description |
---|
LocalCacheFileInStream(URIStatus status,
LocalCacheFileInStream.FileInStreamOpener fileOpener,
CacheManager cacheManager,
AlluxioConfiguration conf)
Constructor when the
URIStatus is already available. |
Modifier and Type | Method and Description |
---|---|
URIStatus |
InStreamOptions.getStatus() |
Constructor and Description |
---|
InStreamOptions(URIStatus status,
AlluxioConfiguration alluxioConf)
Creates with the default
OpenFilePOptions . |
InStreamOptions(URIStatus status,
OpenFilePOptions options,
AlluxioConfiguration alluxioConf)
Creates with given
OpenFilePOptions instance. |
Modifier and Type | Method and Description |
---|---|
protected abstract org.apache.hadoop.fs.Path |
AbstractFileSystem.getFsPath(String fsUriHeader,
URIStatus fileStatus)
Used to get FS native path from Alluxio file status.
|
protected org.apache.hadoop.fs.Path |
FileSystem.getFsPath(String fsUriHeader,
URIStatus fileStatus) |
org.apache.hadoop.fs.FSDataInputStream |
HadoopFileOpener.open(URIStatus uriStatus)
Opens an FSDataInputStream at the indicated Path.
|
org.apache.hadoop.fs.FSDataInputStream |
LocalCacheFileSystem.open(URIStatus status,
int bufferSize)
Attempts to open the specified file for reading.
|
Modifier and Type | Method and Description |
---|---|
static void |
JobUtils.loadBlock(URIStatus status,
FileSystemContext context,
long blockId)
Loads a block into the local worker.
|
Modifier and Type | Method and Description |
---|---|
static ListPartsResult.Part |
ListPartsResult.Part.fromURIStatus(URIStatus status) |
Constructor and Description |
---|
ListAllMyBucketsResult(List<URIStatus> names)
Creates a
ListAllMyBucketsResult . |
ListBucketResult(String bucketName,
List<URIStatus> children,
ListBucketOptions options)
Creates an
ListBucketResult . |
Constructor and Description |
---|
UIFileInfo(URIStatus status,
AlluxioConfiguration alluxioConfiguration,
List<String> orderedTierAliases)
Creates a new instance of
UIFileInfo . |
Copyright © 2023. All Rights Reserved.