Package | Description |
---|---|
alluxio.concurrent | |
alluxio.file.options | |
alluxio.grpc | |
alluxio.master.file | |
alluxio.master.file.meta | |
alluxio.underfs | |
alluxio.underfs.s3a |
Modifier and Type | Method and Description |
---|---|
void |
ManagedBlockingUfsForwarder.performListingAsync(String path,
String continuationToken,
String startAfter,
DescendantType descendantType,
boolean checkStatus,
java.util.function.Consumer<UfsLoadResult> onComplete,
java.util.function.Consumer<Throwable> onError) |
Modifier and Type | Method and Description |
---|---|
static DescendantType |
DescendantType.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static DescendantType[] |
DescendantType.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
static DescendantType |
GrpcUtils.fromProto(LoadDescendantPType pDescendantType)
Converts a proto type to a wire type.
|
Modifier and Type | Method and Description |
---|---|
static LoadDescendantPType |
GrpcUtils.toProto(DescendantType loadDescendantType)
Converts options to proto type.
|
Modifier and Type | Method and Description |
---|---|
protected LockingScheme |
DefaultFileSystemMaster.createSyncLockingScheme(AlluxioURI path,
FileSystemMasterCommonPOptions options,
DescendantType descendantType) |
Constructor and Description |
---|
InodeSyncStream(LockingScheme rootScheme,
DefaultFileSystemMaster fsMaster,
UfsSyncPathCache syncPathCache,
RpcContext rpcContext,
DescendantType descendantType,
FileSystemMasterCommonPOptions options,
boolean forceSync,
boolean loadOnly,
boolean loadAlways)
Create a new instance of
InodeSyncStream without any audit or permission checks. |
InodeSyncStream(LockingScheme rootPath,
DefaultFileSystemMaster fsMaster,
UfsSyncPathCache syncPathCache,
RpcContext rpcContext,
DescendantType descendantType,
FileSystemMasterCommonPOptions options,
FileSystemMasterAuditContext auditContext,
java.util.function.Function<LockedInodePath,Inode> auditContextSrcInodeFunc,
boolean forceSync,
boolean loadOnly,
boolean loadAlways)
Create a new instance of
InodeSyncStream . |
Modifier and Type | Method and Description |
---|---|
alluxio.master.file.meta.SyncState |
UfsSyncPathCache.notifySyncedPath(AlluxioURI path,
DescendantType descendantType,
long startTime,
Long syncTime,
boolean isFile)
Notify sync happened.
|
SyncCheck |
UfsSyncPathCache.shouldSyncPath(AlluxioURI path,
long intervalMs,
DescendantType descendantType)
Check if sync should happen.
|
Constructor and Description |
---|
LockingScheme(AlluxioURI path,
InodeTree.LockPattern desiredPattern,
FileSystemMasterCommonPOptions options,
UfsSyncPathCache pathCache,
DescendantType descendantType)
Create a new
LockingScheme . |
Modifier and Type | Method and Description |
---|---|
void |
BaseUnderFileSystem.performListingAsync(String path,
String continuationToken,
String startAfter,
DescendantType descendantType,
boolean checkStatus,
java.util.function.Consumer<UfsLoadResult> onComplete,
java.util.function.Consumer<Throwable> onError) |
void |
UnderFileSystemWithLogging.performListingAsync(String path,
String continuationToken,
String startAfter,
DescendantType descendantType,
boolean checkStatus,
java.util.function.Consumer<UfsLoadResult> onComplete,
java.util.function.Consumer<Throwable> onError) |
void |
AsyncUfsClient.performListingAsync(String path,
String continuationToken,
String startAfter,
DescendantType descendantType,
boolean checkStatus,
java.util.function.Consumer<UfsLoadResult> onComplete,
java.util.function.Consumer<Throwable> onError)
Lists the ufs statuses for a given path.
|
Modifier and Type | Method and Description |
---|---|
void |
S3AUnderFileSystem.performListingAsync(String path,
String continuationToken,
String startAfter,
DescendantType descendantType,
boolean checkStatus,
java.util.function.Consumer<UfsLoadResult> onComplete,
java.util.function.Consumer<Throwable> onError) |
Copyright © 2023. All Rights Reserved.