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 |
---|---|
protected FileSystemMasterAuditContext |
DefaultFileSystemMaster.createAuditContext(String command,
AlluxioURI srcPath,
AlluxioURI dstPath,
Inode srcInode)
Creates a
FileSystemMasterAuditContext instance. |
void |
NoopUfsDeleter.delete(AlluxioURI alluxioUri,
Inode inode) |
void |
UfsDeleter.delete(AlluxioURI alluxioUri,
Inode inode)
Deletes a path if not covered by a recursive delete.
|
void |
SafeUfsDeleter.delete(AlluxioURI alluxioUri,
Inode inode) |
FileSystemMasterAuditContext |
FileSystemMasterAuditContext.setSrcInode(Inode srcInode)
Sets mSrcInode field.
|
protected void |
DefaultFileSystemMaster.updateAccessTime(RpcContext rpcContext,
Inode inode,
long opTimeMs) |
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 . |
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() |
Inode |
TtlBucketList.loadInode(long inodeId)
Load inode from inode store on processing the provided inode id.
|
static Inode |
Inode.wrap(InodeView delegate)
Wraps an InodeView, providing read-only access.
|
Modifier and Type | Method and Description |
---|---|
List<Inode> |
InodeTree.createPath(RpcContext rpcContext,
LockedInodePath inodePath,
CreatePathContext<?,?> context)
Creates a file or directory at path.
|
List<Inode> |
LockedInodePath.getInodeList() |
List<Inode> |
SimpleInodeLockList.getLockedInodes() |
List<Inode> |
CompositeInodeLockList.getLockedInodes() |
List<Inode> |
InodeLockList.getLockedInodes() |
Modifier and Type | Method and Description |
---|---|
void |
TtlBucket.addInode(Inode inode)
Adds an inode with default num of retry attempt to expire.
|
void |
TtlBucket.addInode(Inode inode,
int numOfRetry)
Adds an inode to the bucket with a specific left retry number.
|
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)
Insert inode to the ttlbucket with default number of retry attempts.
|
void |
TtlBucketList.insert(Inode inode,
int numOfRetry)
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,
String[] childComponentsHint)
Efficient version of
#lockChild(Inode, LockPattern) for when the child path
components are already known. |
void |
SimpleInodeLockList.lockEdge(Inode lastInode,
String childName,
LockMode mode) |
void |
CompositeInodeLockList.lockEdge(Inode inode,
String childName,
LockMode mode) |
void |
InodeLockList.lockEdge(Inode inode,
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,
String childName) |
void |
CompositeInodeLockList.pushWriteLockedEdge(Inode inode,
String childName) |
void |
InodeLockList.pushWriteLockedEdge(Inode inode,
String childName)
Leapfrogs the final edge write lock forward, reducing the lock list's write-locked scope.
|
Modifier and Type | Method and Description |
---|---|
void |
AsyncUfsAbsentPathCache.processAsync(AlluxioURI path,
List<Inode> prefixInodes) |
void |
NoopUfsAbsentPathCache.processAsync(AlluxioURI path,
List<Inode> prefixInodes) |
void |
UfsAbsentPathCache.processAsync(AlluxioURI path,
List<Inode> prefixInodes)
Processes the given path for the cache.
|
Modifier and Type | Method and Description |
---|---|
default Optional<Inode> |
ReadOnlyInodeStore.get(long id) |
Optional<Inode> |
DelegatingReadOnlyInodeStore.get(long id,
ReadOption option) |
Optional<Inode> |
ReadOnlyInodeStore.get(long id,
ReadOption option) |
default Optional<Inode> |
InodeStore.get(long id,
ReadOption option) |
default Optional<Inode> |
ReadOnlyInodeStore.getChild(InodeDirectoryView inode,
String name) |
Optional<Inode> |
DelegatingReadOnlyInodeStore.getChild(InodeDirectoryView inode,
String name,
ReadOption option) |
default Optional<Inode> |
ReadOnlyInodeStore.getChild(InodeDirectoryView inode,
String name,
ReadOption option) |
default Optional<Inode> |
ReadOnlyInodeStore.getChild(Long inodeId,
String name) |
Optional<Inode> |
DelegatingReadOnlyInodeStore.getChild(Long inodeId,
String name,
ReadOption option) |
Optional<Inode> |
ReadOnlyInodeStore.getChild(Long inodeId,
String name,
ReadOption option) |
default CloseableIterator<? extends Inode> |
ReadOnlyInodeStore.getChildren(InodeDirectoryView inode) |
CloseableIterator<? extends Inode> |
DelegatingReadOnlyInodeStore.getChildren(InodeDirectoryView inode,
ReadOption option) |
default CloseableIterator<? extends Inode> |
ReadOnlyInodeStore.getChildren(InodeDirectoryView inode,
ReadOption option) |
default CloseableIterator<? extends Inode> |
ReadOnlyInodeStore.getChildren(Long inodeId) |
CloseableIterator<? extends Inode> |
DelegatingReadOnlyInodeStore.getChildren(Long inodeId,
ReadOption option) |
default CloseableIterator<? extends Inode> |
ReadOnlyInodeStore.getChildren(Long inodeId,
ReadOption option)
Returns an iterator over the children of the specified inode.
|
default CloseableIterator<? extends Inode> |
ReadOnlyInodeStore.getChildrenFrom(long parentId,
String fromName)
Returns a closeable stream of the inodes sorted by filename of the children of the given
directory that come after and including fromName.
|
default CloseableIterator<? extends Inode> |
ReadOnlyInodeStore.getChildrenPrefix(long parentId,
String prefix)
Returns a closeable stream of the inodes sorted by filename of the children of the given
directory that come after and including fromName.
|
default CloseableIterator<? extends Inode> |
ReadOnlyInodeStore.getChildrenPrefixFrom(long parentId,
String prefix,
String fromName)
Returns a closeable stream of the inodes sorted by filename of the children of the given
directory that come after and including fromName, and matching the prefix.
|
Modifier and Type | Method and Description |
---|---|
Optional<Inode> |
CachingInodeStore.getChild(Long inodeId,
String name,
ReadOption option) |
Modifier and Type | Method and Description |
---|---|
Optional<Inode> |
HeapInodeStore.getChild(Long inodeId,
String child,
ReadOption option) |
CloseableIterator<? extends Inode> |
HeapInodeStore.getChildren(Long inodeId,
ReadOption option) |
Modifier and Type | Method and Description |
---|---|
Optional<Inode> |
RocksInodeStore.getChild(Long inodeId,
String name,
ReadOption option) |
Copyright © 2023. All Rights Reserved.