Modifier and Type | Method and Description |
---|---|
default URIStatus |
FuseCommand.run(AlluxioURI path,
String[] argv)
Runs the command.
|
URIStatus |
FuseShell.runCommand(AlluxioURI uri) |
Modifier and Type | Method and Description |
---|---|
URIStatus |
AbstractMetadataCacheSubCommand.run(AlluxioURI path,
String[] argv) |
protected URIStatus |
DropCommand.runSubCommand(AlluxioURI path,
String[] argv,
MetadataCachingFileSystem fileSystem) |
protected URIStatus |
DropAllCommand.runSubCommand(AlluxioURI path,
String[] argv,
MetadataCachingFileSystem fileSystem) |
protected abstract URIStatus |
AbstractMetadataCacheSubCommand.runSubCommand(AlluxioURI path,
String[] argv,
MetadataCachingFileSystem fs)
Run the metadatacache subcommand.
|
protected URIStatus |
SizeCommand.runSubCommand(AlluxioURI path,
String[] argv,
MetadataCachingFileSystem fileSystem) |
Modifier and Type | Method and Description |
---|---|
Pair<WorkerNetAddress,BlockInStream.BlockInStreamSource> |
BlockStoreClient.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 |
RetryHandlingFileSystemMasterClient.getStatus(AlluxioURI path,
GetStatusPOptions options) |
URIStatus |
MetadataCachingFileSystem.getStatus(AlluxioURI path,
GetStatusPOptions options) |
URIStatus |
DelegatingFileSystem.getStatus(AlluxioURI path,
GetStatusPOptions options) |
URIStatus |
FileSystemCache.InstanceCachingFileSystem.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 |
BaseFileSystem.getStatus(AlluxioURI path,
GetStatusPOptions options) |
URIStatus |
FileSystemMasterClient.getStatus(AlluxioURI path,
GetStatusPOptions options) |
Modifier and Type | Method and Description |
---|---|
List<URIStatus> |
ListStatusPartialResult.getListings() |
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> |
RetryHandlingFileSystemMasterClient.listStatus(AlluxioURI path,
ListStatusPOptions options) |
List<URIStatus> |
MetadataCachingFileSystem.listStatus(AlluxioURI path,
ListStatusPOptions options) |
List<URIStatus> |
DelegatingFileSystem.listStatus(AlluxioURI path,
ListStatusPOptions options) |
List<URIStatus> |
FileSystemCache.InstanceCachingFileSystem.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> |
BaseFileSystem.listStatus(AlluxioURI path,
ListStatusPOptions options) |
List<URIStatus> |
FileSystemMasterClient.listStatus(AlluxioURI path,
ListStatusPOptions options) |
List<URIStatus> |
MetadataCache.listStatus(String dir) |
Modifier and Type | Method and Description |
---|---|
List<BlockLocationInfo> |
DelegatingFileSystem.getBlockLocations(URIStatus status) |
List<BlockLocationInfo> |
FileSystemCache.InstanceCachingFileSystem.getBlockLocations(URIStatus status) |
List<BlockLocationInfo> |
FileSystem.getBlockLocations(URIStatus status)
Builds a list of
BlockLocationInfo for the given file. |
List<BlockLocationInfo> |
BaseFileSystem.getBlockLocations(URIStatus status) |
FileInStream |
DelegatingFileSystem.openFile(URIStatus status,
OpenFilePOptions options) |
FileInStream |
FileSystemCache.InstanceCachingFileSystem.openFile(URIStatus status,
OpenFilePOptions options) |
FileInStream |
FileSystem.openFile(URIStatus status,
OpenFilePOptions options)
Opens a file for reading.
|
FileInStream |
BaseFileSystem.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 |
RetryHandlingFileSystemMasterClient.iterateStatus(AlluxioURI path,
ListStatusPOptions options,
java.util.function.Consumer<? super URIStatus> action) |
void |
MetadataCachingFileSystem.iterateStatus(AlluxioURI path,
ListStatusPOptions options,
java.util.function.Consumer<? super URIStatus> action) |
void |
DelegatingFileSystem.iterateStatus(AlluxioURI path,
ListStatusPOptions options,
java.util.function.Consumer<? super URIStatus> action) |
void |
FileSystemCache.InstanceCachingFileSystem.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 |
BaseFileSystem.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 |
---|---|
boolean |
CacheFilter.needsCache(URIStatus uriStatus)
Whether the specific uri needs to be cached or not.
|
boolean |
DefaultCacheFilter.needsCache(URIStatus uriStatus)
The implementation of needsCache.
|
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,
AlluxioConfiguration alluxioConf,
FileSystemContext context)
Creates with the default
OpenFilePOptions . |
InStreamOptions(URIStatus status,
OpenFilePOptions options,
AlluxioConfiguration alluxioConf,
FileSystemContext context)
Creates with given
OpenFilePOptions instance. |
Modifier and Type | Method and Description |
---|---|
URIStatus |
UfsBaseFileSystem.getStatus(AlluxioURI path) |
URIStatus |
UfsBaseFileSystem.getStatus(AlluxioURI path,
GetStatusPOptions options) |
Modifier and Type | Method and Description |
---|---|
List<URIStatus> |
UfsBaseFileSystem.listStatus(AlluxioURI path,
ListStatusPOptions options) |
Modifier and Type | Method and Description |
---|---|
List<BlockLocationInfo> |
UfsBaseFileSystem.getBlockLocations(URIStatus status) |
FileInStream |
UfsBaseFileSystem.openFile(URIStatus status,
OpenFilePOptions options) |
Modifier and Type | Method and Description |
---|---|
void |
UfsBaseFileSystem.iterateStatus(AlluxioURI path,
ListStatusPOptions options,
java.util.function.Consumer<? super URIStatus> action) |
Modifier and Type | Method and Description |
---|---|
static Optional<URIStatus> |
AlluxioFuseUtils.getPathStatus(FileSystem fileSystem,
AlluxioURI uri)
Gets the path status.
|
static Optional<URIStatus> |
AlluxioFuseUtils.waitForFileCompleted(FileSystem fileSystem,
AlluxioURI uri)
Waits for the file to complete.
|
Modifier and Type | Method and Description |
---|---|
static void |
AlluxioFuseUtils.fillStat(AuthPolicy policy,
FileStat stat,
URIStatus status)
Fills the path status.
|
Modifier and Type | Method and Description |
---|---|
URIStatus |
AlluxioFileStatus.getUriStatus()
get uri status.
|
Modifier and Type | Method and Description |
---|---|
protected org.apache.hadoop.fs.Path |
FileSystem.getFsPath(String fsUriHeader,
URIStatus fileStatus) |
protected abstract org.apache.hadoop.fs.Path |
AbstractFileSystem.getFsPath(String fsUriHeader,
URIStatus fileStatus)
Used to get FS native path from Alluxio file status.
|
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.
|
Constructor and Description |
---|
AlluxioFileStatus(URIStatus status,
org.apache.hadoop.fs.Path fsPath)
Constructs a new
AlluxioFileStatus instance. |
Modifier and Type | Method and Description |
---|---|
static void |
JobUtils.loadBlock(URIStatus status,
FileSystemContext context,
long blockId,
WorkerNetAddress address,
boolean directCache)
Loads a block into the local worker.
|
Modifier and Type | Method and Description |
---|---|
protected void |
DistLoadCliRunner.setJobConfigAndFileMetrics(List<URIStatus> filePath,
int replication,
Set<String> workerSet,
Set<String> excludedWorkerSet,
Set<String> localityIds,
Set<String> excludedLocalityIds,
boolean directCache,
CmdRunAttempt attempt) |
Modifier and Type | Method and Description |
---|---|
URIStatus |
CompleteMultipartUploadHandler.CompleteMultipartUploadTask.checkIfComplete(String objectPath)
On any exception, check with Master on if the there's an object file.
|
URIStatus |
S3ObjectTask.CompleteMultipartUploadTask.checkIfComplete(String objectPath)
On any exception, check with Master on if the there's an object file.
|
Modifier and Type | Method and Description |
---|---|
static List<URIStatus> |
S3RestUtils.checkStatusesForUploadId(FileSystem metaFs,
FileSystem userFs,
AlluxioURI multipartTempDirUri,
String uploadId)
Fetches and returns the corresponding
URIStatus for both
the multipart upload temp directory and the Alluxio S3 metadata file. |
List<URIStatus> |
CompleteMultipartUploadHandler.CompleteMultipartUploadTask.validateParts(CompleteMultipartUploadRequest request,
String objectPath,
AlluxioURI multipartTemporaryDir)
Validate the parts as part of this multipart uplaod request.
|
List<URIStatus> |
S3ObjectTask.CompleteMultipartUploadTask.validateParts(CompleteMultipartUploadRequest request,
String objectPath,
AlluxioURI multipartTemporaryDir)
Validate the parts as part of this multipart uplaod request.
|
Modifier and Type | Method and Description |
---|---|
int |
S3RestUtils.URIStatusNameComparator.compare(URIStatus o1,
URIStatus o2) |
static ListPartsResult.Part |
ListPartsResult.Part.fromURIStatus(URIStatus status) |
static String |
S3RestUtils.getEntityTag(URIStatus status)
This helper method is used to get the ETag xAttr on an object.
|
CreateFilePOptions |
CompleteMultipartUploadHandler.CompleteMultipartUploadTask.prepareForCreateTempFile(URIStatus metaStatus)
Prepare CreateFilePOptions for create temp multipart upload file.
|
CreateFilePOptions |
S3ObjectTask.CompleteMultipartUploadTask.prepareForCreateTempFile(URIStatus metaStatus)
Prepare CreateFilePOptions for create temp multipart upload file.
|
Modifier and Type | Method and Description |
---|---|
static ListMultipartUploadsResult |
ListMultipartUploadsResult.buildFromStatuses(String bucket,
List<URIStatus> children) |
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.