Modifier and Type | Method and Description |
---|---|
UfsStatus |
ManagedBlockingUfsForwarder.getExistingStatus(String path) |
UfsStatus |
ManagedBlockingUfsForwarder.getStatus(String path,
GetStatusOptions options) |
UfsStatus[] |
ManagedBlockingUfsForwarder.listStatus(String path) |
UfsStatus[] |
ManagedBlockingUfsForwarder.listStatus(String path,
ListOptions options) |
Modifier and Type | Method and Description |
---|---|
Iterator<UfsStatus> |
ManagedBlockingUfsForwarder.listStatusIterable(String path,
ListOptions options,
String startAfter,
int batchSize) |
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 | Field and Description |
---|---|
protected List<UfsStatus> |
DoraLoadJob.DoraLoadTask.mFilesToLoad |
Modifier and Type | Method and Description |
---|---|
List<UfsStatus> |
DoraLoadJob.DoraLoadTask.getFilesToLoad()
Get files to load of this task.
|
Constructor and Description |
---|
DoraLoadTask(List<UfsStatus> filesToLoad)
Constructor.
|
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.
|
static UfsStatus |
UfsStatus.fromProto(UfsStatus ufsStatus) |
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.
|
default UfsStatus |
UnderFileSystem.getStatus(String path)
Gets the file or directory status.
|
UfsStatus |
ObjectUnderFileSystem.getStatus(String path,
GetStatusOptions options) |
UfsStatus |
UnderFileSystemWithLogging.getStatus(String path,
GetStatusOptions options) |
UfsStatus |
UnderFileSystem.getStatus(String path,
GetStatusOptions options)
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[] |
BaseUnderFileSystem.listStatus(String path,
ListOptions options) |
UfsStatus[] |
ObjectUnderFileSystem.listStatus(String path,
ListOptions options) |
UfsStatus[] |
UnderFileSystemWithLogging.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 |
ObjectUnderFileSystem.UfsStatusIterator.next() |
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(RpcContext rpcContext,
AlluxioURI path,
MountTable mountTable)
Fetches children of a given alluxio path stores them in the cache, then returns them.
|
Collection<UfsStatus> |
UfsStatusCache.fetchChildrenIfAbsent(RpcContext rpcContext,
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 . |
java.util.stream.Stream<UfsStatus> |
UfsLoadResult.getItems() |
Optional<UfsStatus> |
UfsStatusCache.hasStatus(AlluxioURI path)
Check if a status has been loaded in the cache for the given AlluxioURI.
|
Iterator<UfsStatus> |
BaseUnderFileSystem.listStatusIterable(String path,
ListOptions options,
String startAfter,
int batchSize) |
Iterator<UfsStatus> |
ObjectUnderFileSystem.listStatusIterable(String path,
ListOptions options,
String startAfter,
int batchSize) |
Iterator<UfsStatus> |
UnderFileSystemWithLogging.listStatusIterable(String path,
ListOptions options,
String startAfter,
int batchSize) |
Iterator<UfsStatus> |
UnderFileSystem.listStatusIterable(String path,
ListOptions options,
String startAfter,
int batchSize)
Lists the ufs statuses iteratively.
|
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,
String contentHash)
Parses the input string and returns the fingerprint object.
|
static Fingerprint |
Fingerprint.create(String ufsName,
UfsStatus status,
String contentHash,
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. |
Constructor and Description |
---|
UfsLoadResult(java.util.stream.Stream<UfsStatus> items,
int itemsCount,
String continuationToken,
AlluxioURI lastItem,
boolean isTruncated,
boolean firstIsFile,
boolean isObjectStore)
Constructs a new instance of
UfsLoadResult . |
Modifier and Type | Method and Description |
---|---|
UfsStatus |
AbfsUnderFileSystem.getStatus(String path,
GetStatusOptions options) |
Modifier and Type | Method and Description |
---|---|
UfsStatus |
AdlUnderFileSystem.getStatus(String path,
GetStatusOptions options) |
Modifier and Type | Method and Description |
---|---|
UfsStatus |
CephFSUnderFileSystem.getStatus(String path,
GetStatusOptions options) |
UfsStatus[] |
CephFSUnderFileSystem.listStatus(String path)
Each string is a name rather than a complete path.
|
Modifier and Type | Method and Description |
---|---|
UfsStatus |
HdfsUnderFileSystem.getStatus(String path,
GetStatusOptions options) |
UfsStatus[] |
HdfsUnderFileSystem.listStatus(String path) |
Modifier and Type | Method and Description |
---|---|
UfsStatus |
LocalUnderFileSystem.getStatus(String path,
GetStatusOptions options) |
UfsStatus[] |
LocalUnderFileSystem.listStatus(String path) |
Modifier and Type | Method and Description |
---|---|
UfsStatus |
OBSUnderFileSystem.getStatus(String path) |
Modifier and Type | Method and Description |
---|---|
UfsStatus |
WasbUnderFileSystem.getStatus(String path,
GetStatusOptions options) |
Modifier and Type | Method and Description |
---|---|
UfsStatus[] |
PagedDoraWorker.listStatus(String path,
ListStatusPOptions options) |
UfsStatus[] |
DoraWorker.listStatus(String path,
ListStatusPOptions options)
List status from Under File System.
|
Modifier and Type | Method and Description |
---|---|
FileInfo |
PagedDoraWorker.buildFileInfoFromUfsStatus(UfsStatus status,
String ufsFullPath)
Build FileInfo from UfsStatus and UFS full Path.
|
DoraMeta.FileStatus |
PagedDoraWorker.buildFileStatusFromUfsStatus(UfsStatus status,
String ufsFullPath)
Build FileStatus from UfsStatus and UFS full Path.
|
Modifier and Type | Method and Description |
---|---|
com.google.common.util.concurrent.ListenableFuture<LoadFileResponse> |
PagedDoraWorker.load(boolean loadData,
boolean skipIfExists,
List<UfsStatus> ufsStatuses,
UfsReadOptions options) |
com.google.common.util.concurrent.ListenableFuture<LoadFileResponse> |
DoraWorker.load(boolean loadData,
boolean skipIfExists,
List<UfsStatus> ufsStatuses,
UfsReadOptions options)
Loads the metadata and data of files from UFS to Alluxio.
|
Copyright © 2023. All Rights Reserved.