| Package | Description |
|---|---|
| alluxio.master.file | |
| alluxio.master.file.meta | |
| alluxio.master.metastore | |
| alluxio.master.metastore.caching | |
| alluxio.master.metastore.heap | |
| alluxio.master.metastore.rocks |
| Modifier and Type | Method and Description |
|---|---|
void |
NoopUfsDeleter.delete(AlluxioURI alluxioUri,
Inode inode) |
void |
SafeUfsDeleter.delete(AlluxioURI alluxioUri,
Inode inode) |
void |
UfsDeleter.delete(AlluxioURI alluxioUri,
Inode inode)
Deletes a path if not covered by a recursive delete.
|
FileSystemMasterAuditContext |
FileSystemMasterAuditContext.setSrcInode(Inode srcInode)
Sets mSrcInode field.
|
| Constructor and Description |
|---|
InodeSyncStream(LockingScheme rootPath,
DefaultFileSystemMaster fsMaster,
RpcContext rpcContext,
DescendantType descendantType,
FileSystemMasterCommonPOptions options,
FileSystemMasterAuditContext auditContext,
java.util.function.Function<LockedInodePath,Inode> auditContextSrcInodeFunc,
alluxio.master.file.DefaultFileSystemMaster.PermissionCheckFunction permissionCheckOperation,
boolean isGetFileInfo,
boolean forceSync,
boolean loadOnly)
Create a new instance of
InodeSyncStream. |
| Modifier and Type | Class and Description |
|---|---|
class |
InodeDirectory
Forwarding wrapper around an inode directory view.
|
class |
InodeFile
Forwarding wrapper around an inode file view.
|
| Modifier and Type | Method and Description |
|---|---|
Inode |
SimpleInodeLockList.get(int index) |
Inode |
CompositeInodeLockList.get(int index) |
Inode |
InodeLockList.get(int index) |
Inode |
LockedInodePath.getAncestorInode()
Returns the closest ancestor of the target inode (last inode in the full path).
|
Inode |
LockedInodePath.getInode() |
Inode |
LockedInodePath.getInodeOrNull() |
Inode |
LockedInodePath.getLastExistingInode() |
Inode |
LockedInodePath.getParentInodeOrNull() |
static Inode |
Inode.wrap(InodeView delegate)
Wraps an InodeView, providing read-only access.
|
| Modifier and Type | Method and Description |
|---|---|
java.util.List<Inode> |
InodeTree.createPath(RpcContext rpcContext,
LockedInodePath inodePath,
CreatePathContext<?,?> context)
Creates a file or directory at path.
|
java.util.List<Inode> |
LockedInodePath.getInodeList() |
java.util.Collection<Inode> |
TtlBucket.getInodes() |
java.util.List<Inode> |
SimpleInodeLockList.getLockedInodes() |
java.util.List<Inode> |
CompositeInodeLockList.getLockedInodes() |
java.util.List<Inode> |
InodeLockList.getLockedInodes() |
| Modifier and Type | Method and Description |
|---|---|
void |
TtlBucket.addInode(Inode inode)
Adds a inode to the bucket.
|
void |
LockedInodePath.addNextInode(Inode inode)
Adds the next inode to the path.
|
static UfsSyncUtils.SyncPlan |
UfsSyncUtils.computeSyncPlan(Inode inode,
Fingerprint ufsFingerprint,
boolean containsMountPoint)
Given an inode and ufs status, returns a sync plan describing how to
sync the inode with the ufs.
|
static boolean |
UfsSyncUtils.inodeUfsIsContentSynced(Inode inode,
Fingerprint inodeFingerprint,
Fingerprint ufsFingerprint)
Returns true if the given inode's content is synced with the ufs status.
|
static boolean |
UfsSyncUtils.inodeUfsIsMetadataSynced(Inode inode,
Fingerprint inodeFingerprint,
Fingerprint ufsFingerprint)
Returns true if the given inode's metadata matches the ufs fingerprint.
|
void |
TtlBucketList.insert(Inode inode)
Inserts an inode to the appropriate bucket where its ttl end time lies in the
bucket's interval, if no appropriate bucket exists, a new bucket will be created to contain
this inode, if ttl value is
Constants.NO_TTL, the inode won't be inserted to any
buckets and nothing will happen. |
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,
java.lang.String[] childComponentsHint)
Efficient version of
#lockChild(Inode, LockPattern) for when the child path
components are already known. |
void |
SimpleInodeLockList.lockEdge(Inode lastInode,
java.lang.String childName,
LockMode mode) |
void |
CompositeInodeLockList.lockEdge(Inode inode,
java.lang.String childName,
LockMode mode) |
void |
InodeLockList.lockEdge(Inode inode,
java.lang.String childName,
LockMode mode)
Locks an edge leading out of the last inode in the list.
|
void |
SimpleInodeLockList.lockInode(Inode inode,
LockMode mode) |
void |
CompositeInodeLockList.lockInode(Inode inode,
LockMode mode) |
void |
InodeLockList.lockInode(Inode inode,
LockMode mode)
Locks the given inode and adds it to the lock list.
|
void |
SimpleInodeLockList.pushWriteLockedEdge(Inode inode,
java.lang.String childName) |
void |
CompositeInodeLockList.pushWriteLockedEdge(Inode inode,
java.lang.String childName) |
void |
InodeLockList.pushWriteLockedEdge(Inode inode,
java.lang.String childName)
Leapfrogs the final edge write lock forward, reducing the lock list's write-locked scope.
|
| Modifier and Type | Method and Description |
|---|---|
void |
UfsAbsentPathCache.process(AlluxioURI path,
java.util.List<Inode> prefixInodes)
Processes the given path for the cache.
|
void |
AsyncUfsAbsentPathCache.process(AlluxioURI path,
java.util.List<Inode> prefixInodes) |
void |
NoopUfsAbsentPathCache.process(AlluxioURI path,
java.util.List<Inode> prefixInodes) |
| Modifier and Type | Method and Description |
|---|---|
default java.util.Optional<Inode> |
ReadOnlyInodeStore.get(long id) |
default java.util.Optional<Inode> |
InodeStore.get(long id,
ReadOption option) |
java.util.Optional<Inode> |
DelegatingReadOnlyInodeStore.get(long id,
ReadOption option) |
java.util.Optional<Inode> |
ReadOnlyInodeStore.get(long id,
ReadOption option) |
default java.util.Optional<Inode> |
ReadOnlyInodeStore.getChild(InodeDirectoryView inode,
java.lang.String name) |
java.util.Optional<Inode> |
DelegatingReadOnlyInodeStore.getChild(InodeDirectoryView inode,
java.lang.String name,
ReadOption option) |
default java.util.Optional<Inode> |
ReadOnlyInodeStore.getChild(InodeDirectoryView inode,
java.lang.String name,
ReadOption option) |
default java.util.Optional<Inode> |
ReadOnlyInodeStore.getChild(java.lang.Long inodeId,
java.lang.String name) |
java.util.Optional<Inode> |
DelegatingReadOnlyInodeStore.getChild(java.lang.Long inodeId,
java.lang.String name,
ReadOption option) |
java.util.Optional<Inode> |
ReadOnlyInodeStore.getChild(java.lang.Long inodeId,
java.lang.String name,
ReadOption option) |
default java.lang.Iterable<? extends Inode> |
ReadOnlyInodeStore.getChildren(InodeDirectoryView inode) |
java.lang.Iterable<? extends Inode> |
DelegatingReadOnlyInodeStore.getChildren(InodeDirectoryView inode,
ReadOption option) |
default java.lang.Iterable<? extends Inode> |
ReadOnlyInodeStore.getChildren(InodeDirectoryView inode,
ReadOption option) |
default java.lang.Iterable<? extends Inode> |
ReadOnlyInodeStore.getChildren(java.lang.Long inodeId) |
java.lang.Iterable<? extends Inode> |
DelegatingReadOnlyInodeStore.getChildren(java.lang.Long inodeId,
ReadOption option) |
default java.lang.Iterable<? extends Inode> |
ReadOnlyInodeStore.getChildren(java.lang.Long inodeId,
ReadOption option)
Returns an iterator over the children of the specified inode.
|
| Modifier and Type | Method and Description |
|---|---|
java.util.Optional<Inode> |
CachingInodeStore.getChild(java.lang.Long inodeId,
java.lang.String name,
ReadOption option) |
| Modifier and Type | Method and Description |
|---|---|
java.util.Optional<Inode> |
HeapInodeStore.getChild(java.lang.Long inodeId,
java.lang.String child,
ReadOption option) |
java.lang.Iterable<? extends Inode> |
HeapInodeStore.getChildren(java.lang.Long inodeId,
ReadOption option) |
| Modifier and Type | Method and Description |
|---|---|
java.util.Optional<Inode> |
RocksInodeStore.getChild(java.lang.Long inodeId,
java.lang.String name,
ReadOption option) |
Copyright © 2020. All Rights Reserved.