Package | Description |
---|---|
alluxio.master.file | |
alluxio.master.file.meta |
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 |
---|---|
LockedInodePath |
InodeTree.lockFullInodePath(AlluxioURI uri,
LockingScheme lockScheme,
JournalContext journalContext)
Locks a path and throws an exception if the path does not exist.
|
LockedInodePath |
InodeTree.lockInodePath(LockingScheme scheme,
JournalContext journalContext)
Locks existing inodes on the path and with the pattern defined by
getPath() and getPattern() . |
LockedInodePath |
InodeTree.tryLockInodePath(LockingScheme scheme,
JournalContext journalContext)
Locks existing inodes on the path and with the pattern defined by
getPath() and getPattern() . |
Copyright © 2023. All Rights Reserved.