Package | Description |
---|---|
alluxio.concurrent | |
alluxio.master.file.contexts | |
alluxio.underfs | |
alluxio.underfs.hdfs | |
alluxio.underfs.local | |
alluxio.underfs.wasb | |
alluxio.underfs.web |
Modifier and Type | Method and Description |
---|---|
UfsStatus |
ManagedBlockingUfsForwarder.getExistingStatus(String path) |
UfsStatus |
ManagedBlockingUfsForwarder.getStatus(String path) |
UfsStatus[] |
ManagedBlockingUfsForwarder.listStatus(String path) |
UfsStatus[] |
ManagedBlockingUfsForwarder.listStatus(String path,
ListOptions options) |
Modifier and Type | Method and Description |
---|---|
UfsStatus |
LoadMetadataContext.getUfsStatus() |
UfsStatus |
CompleteFileContext.getUfsStatus() |
UfsStatus |
CreateDirectoryContext.getUfsStatus() |
Modifier and Type | Method and Description |
---|---|
LoadMetadataContext |
LoadMetadataContext.setUfsStatus(UfsStatus ufsStatus)
Sets
UfsStatus for the directory. |
CompleteFileContext |
CompleteFileContext.setUfsStatus(UfsStatus ufsStatus)
Sets ufs status.
|
CreateDirectoryContext |
CreateDirectoryContext.setUfsStatus(UfsStatus ufsStatus)
Sets
UfsStatus for the directory. |
Modifier and Type | Class and Description |
---|---|
class |
UfsDirectoryStatus
Information about a directory in the under file system.
|
class |
UfsFileStatus
Information about a file in
UnderFileSystem . |
Modifier and Type | Method and Description |
---|---|
UfsStatus |
UfsStatusCache.addStatus(AlluxioURI path,
UfsStatus status)
Add a new status to the cache.
|
abstract UfsStatus |
UfsStatus.copy()
Create a copy of
UfsStatus . |
UfsStatus |
UfsStatusCache.fetchStatusIfAbsent(AlluxioURI path,
MountTable mountTable)
Attempts to return a status from the cache.
|
UfsStatus |
ConsistentUnderFileSystem.getExistingStatus(String path) |
UfsStatus |
ObjectUnderFileSystem.getExistingStatus(String path) |
UfsStatus |
UnderFileSystemWithLogging.getExistingStatus(String path) |
UfsStatus |
UnderFileSystem.getExistingStatus(String path)
Gets the file or directory status.
|
UfsStatus |
UfsStatusCache.getStatus(AlluxioURI path)
Get the UfsStatus from a given AlluxioURI.
|
UfsStatus |
ObjectUnderFileSystem.getStatus(String path) |
UfsStatus |
UnderFileSystemWithLogging.getStatus(String path) |
UfsStatus |
UnderFileSystem.getStatus(String path)
Gets the file or directory status.
|
protected UfsStatus[] |
ObjectUnderFileSystem.listInternal(String path,
ListOptions options)
Lists the files in the given path, the paths will be their logical names and not contain the
folder suffix.
|
UfsStatus[] |
ObjectUnderFileSystem.listStatus(String path) |
UfsStatus[] |
UnderFileSystemWithLogging.listStatus(String path) |
UfsStatus[] |
UnderFileSystem.listStatus(String path)
Returns an array of statuses of the files and directories in the directory denoted by this
abstract pathname.
|
UfsStatus[] |
ObjectUnderFileSystem.listStatus(String path,
ListOptions options) |
UfsStatus[] |
UnderFileSystemWithLogging.listStatus(String path,
ListOptions options) |
UfsStatus[] |
BaseUnderFileSystem.listStatus(String path,
ListOptions options) |
UfsStatus[] |
UnderFileSystem.listStatus(String path,
ListOptions options)
Returns an array of statuses of the files and directories in the directory denoted by this
abstract pathname, with options.
|
UfsStatus |
UfsStatusCache.remove(AlluxioURI path)
Remove a status from the cache.
|
UfsStatus |
UfsStatus.setName(String name)
Set the name of file or directory.
|
Modifier and Type | Method and Description |
---|---|
Collection<UfsStatus> |
UfsStatusCache.addChildren(AlluxioURI path,
Collection<UfsStatus> children)
Add a parent-child mapping to the status cache.
|
Collection<UfsStatus> |
UfsStatusCache.fetchChildrenIfAbsent(AlluxioURI path,
MountTable mountTable)
Fetches children of a given alluxio path stores them in the cache, then returns them.
|
Collection<UfsStatus> |
UfsStatusCache.fetchChildrenIfAbsent(AlluxioURI path,
MountTable mountTable,
boolean useFallback)
Fetches children of a given alluxio path, stores them in the cache, then returns them.
|
Collection<UfsStatus> |
UfsStatusCache.getChildren(AlluxioURI path)
Get the child
UfsStatus es from a given AlluxioURI . |
Future<Collection<UfsStatus>> |
UfsStatusCache.prefetchChildren(AlluxioURI path,
MountTable mountTable)
Submit a request to asynchronously fetch the statuses corresponding to a given directory.
|
Modifier and Type | Method and Description |
---|---|
UfsStatus |
UfsStatusCache.addStatus(AlluxioURI path,
UfsStatus status)
Add a new status to the cache.
|
static String[] |
UfsStatus.convertToNames(UfsStatus[] children)
Converts an array of UFS file status to a listing result where each element in the array is
a file or directory name.
|
static Fingerprint |
Fingerprint.create(String ufsName,
UfsStatus status)
Parses the input string and returns the fingerprint object.
|
static Fingerprint |
Fingerprint.create(String ufsName,
UfsStatus status,
AccessControlList acl)
Parses the input string and returns the fingerprint object.
|
Modifier and Type | Method and Description |
---|---|
Collection<UfsStatus> |
UfsStatusCache.addChildren(AlluxioURI path,
Collection<UfsStatus> children)
Add a parent-child mapping to the status cache.
|
Constructor and Description |
---|
UfsStatus(UfsStatus status)
Creates a new instance of
UfsStatus as a copy. |
Modifier and Type | Method and Description |
---|---|
UfsStatus |
HdfsUnderFileSystem.getStatus(String path) |
UfsStatus[] |
HdfsUnderFileSystem.listStatus(String path) |
Modifier and Type | Method and Description |
---|---|
UfsStatus |
LocalUnderFileSystem.getStatus(String path) |
UfsStatus[] |
LocalUnderFileSystem.listStatus(String path) |
Modifier and Type | Method and Description |
---|---|
UfsStatus |
WasbUnderFileSystem.getStatus(String path) |
Modifier and Type | Method and Description |
---|---|
UfsStatus |
WebUnderFileSystem.getStatus(String path) |
UfsStatus[] |
WebUnderFileSystem.listStatus(String path) |
Copyright © 2023. All Rights Reserved.