Package | Description |
---|---|
alluxio.master.file | |
alluxio.master.file.meta |
Modifier and Type | Method and Description |
---|---|
void |
PermissionChecker.checkParentPermission(Mode.Bits bits,
LockedInodePath inodePath)
Checks whether a user has permission to perform a specific action on the parent of the given
path; if parent directory does not exist, treats the closest ancestor directory of the path as
its parent and checks permission on it.
|
void |
DefaultPermissionChecker.checkParentPermission(Mode.Bits bits,
LockedInodePath inodePath) |
void |
PermissionChecker.checkPermission(Mode.Bits bits,
LockedInodePath inodePath)
Checks whether a user has permission to perform a specific action on a path.
|
void |
DefaultPermissionChecker.checkPermission(Mode.Bits bits,
LockedInodePath inodePath) |
void |
PermissionChecker.checkSetAttributePermission(LockedInodePath inodePath,
boolean superuserRequired,
boolean ownerRequired,
boolean writeRequired)
Checks whether a user has permission to edit the attribute of a given path.
|
void |
DefaultPermissionChecker.checkSetAttributePermission(LockedInodePath inodePath,
boolean superuserRequired,
boolean ownerRequired,
boolean writeRequired) |
void |
DefaultFileSystemMaster.deleteInternal(RpcContext rpcContext,
LockedInodePath inodePath,
DeleteContext deleteContext,
boolean bypassPermCheck)
Implements file deletion.
|
protected void |
DefaultFileSystemMaster.ensureFullPathAndUpdateCache(LockedInodePath inodePath)
Checks to see if the entire path exists in Alluxio.
|
Mode.Bits |
PermissionChecker.getPermission(LockedInodePath inodePath)
Gets the permission to access inodePath for the current client user.
|
Mode.Bits |
DefaultPermissionChecker.getPermission(LockedInodePath inodePath) |
protected void |
DefaultFileSystemMaster.setAttributeSingleFile(RpcContext rpcContext,
LockedInodePath inodePath,
boolean updateUfs,
long opTimeMs,
SetAttributeContext context) |
Constructor and Description |
---|
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 . |
SafeUfsDeleter(MountTable mountTable,
ReadOnlyInodeStore inodeStore,
List<Pair<AlluxioURI,LockedInodePath>> inodes,
DeletePOptions deleteOptions)
Creates a new instance of
SafeUfsDeleter . |
Modifier and Type | Method and Description |
---|---|
LockedInodePath |
LockedInodePath.lockChild(Inode child,
InodeTree.LockPattern lockPattern)
Returns a new locked inode path composed of the current path plus the child inode.
|
LockedInodePath |
LockedInodePath.lockChild(Inode child,
InodeTree.LockPattern lockPattern,
String[] childComponentsHint)
Efficient version of
#lockChild(Inode, LockPattern) for when the child path
components are already known. |
LockedInodePath |
LockedInodePath.lockChildByName(String childName,
InodeTree.LockPattern lockPattern,
String[] childComponentsHint)
Efficient version of
#lockChild(Inode, LockPattern) for when the child path
components are already known. |
LockedInodePath |
LockedInodePath.lockDescendant(AlluxioURI descendantUri,
InodeTree.LockPattern lockPattern)
Locks a descendant of the current path and returns a new locked inode path.
|
LockedInodePath |
LockedInodePath.lockFinalEdgeWrite()
Returns a copy of the path with the final edge write locked.
|
LockedInodePath |
InodeTree.lockFullInodePath(AlluxioURI uri,
InodeTree.LockPattern lockPattern,
JournalContext journalContext)
Locks a path and throws an exception if the path does not exist.
|
LockedInodePath |
InodeTree.lockFullInodePath(AlluxioURI uri,
LockingScheme lockScheme,
JournalContext journalContext)
Locks a path and throws an exception if the path does not exist.
|
LockedInodePath |
InodeTree.lockFullInodePath(long id,
InodeTree.LockPattern lockPattern,
JournalContext journalContext)
Locks a path and throws an exception if the path does not exist.
|
LockedInodePath |
InodeTree.lockInodePath(AlluxioURI uri,
InodeTree.LockPattern lockPattern,
boolean tryLock,
JournalContext journalContext)
Locks existing inodes on the specified path, in the specified
InodeTree.LockPattern . |
LockedInodePath |
InodeTree.lockInodePath(AlluxioURI uri,
InodeTree.LockPattern lockPattern,
JournalContext journalContext)
Locks existing inodes on the specified path, in the specified
InodeTree.LockPattern . |
LockedInodePath |
InodeTree.lockInodePath(LockingScheme scheme,
JournalContext journalContext)
Locks existing inodes on the path and with the pattern defined by
LockingScheme.getPath() and LockingScheme.getPattern() . |
LockedInodePath |
InodeTree.tryLockInodePath(LockingScheme scheme,
JournalContext journalContext)
Locks existing inodes on the path and with the pattern defined by
LockingScheme.getPath() and LockingScheme.getPattern() . |
Modifier and Type | Method and Description |
---|---|
List<LockedInodePath> |
LockedInodePathList.getInodePathList()
get the associated inodePathList.
|
Iterator<LockedInodePath> |
LockedInodePathList.iterator() |
Modifier and Type | Method and Description |
---|---|
List<Inode> |
InodeTree.createPath(RpcContext rpcContext,
LockedInodePath inodePath,
CreatePathContext<?,?> context)
Creates a file or directory at path.
|
void |
InodeTree.deleteInode(RpcContext rpcContext,
LockedInodePath inodePath,
long opTimeMs)
Deletes a single inode from the inode tree by removing it from the parent inode.
|
void |
InodeTree.ensureFullInodePath(LockedInodePath inodePath)
Attempts to extend an existing
LockedInodePath to reach the target inode (the last
inode for the full path). |
LockedInodePathList |
InodeTree.getDescendants(LockedInodePath inodePath)
Returns
LockedInodePath s for all descendants of inodePath. |
void |
InodePathPair.setFirst(LockedInodePath first) |
void |
InodeTree.setPinned(RpcContext rpcContext,
LockedInodePath inodePath,
boolean pinned,
List<String> mediumTypes,
long opTimeMs)
Sets the pinned state of an inode.
|
void |
InodeTree.setReplication(RpcContext rpcContext,
LockedInodePath inodePath,
Integer replicationMax,
Integer replicationMin,
long opTimeMs)
Sets the min and/or max replication level of an inode.
|
void |
InodePathPair.setSecond(LockedInodePath second) |
Constructor and Description |
---|
LockedInodePathList(List<LockedInodePath> inodePathList)
Creates a new instance of
LockedInodePathList . |
Copyright © 2023. All Rights Reserved.