Package | Description |
---|---|
alluxio.master.file | |
alluxio.master.file.activesync | |
alluxio.master.file.meta | |
alluxio.underfs |
Modifier and Type | Field and Description |
---|---|
static RpcContext |
RpcContext.NOOP |
Modifier and Type | Method and Description |
---|---|
RpcContext |
DefaultFileSystemMaster.createRpcContext() |
RpcContext |
DefaultFileSystemMaster.createRpcContext(OperationContext operationContext) |
protected RpcContext |
InodeSyncStream.getMetadataSyncRpcContext() |
Modifier and Type | Method and Description |
---|---|
void |
DefaultFileSystemMaster.deleteInternal(RpcContext rpcContext,
LockedInodePath inodePath,
DeleteContext deleteContext,
boolean bypassPermCheck)
Implements file deletion.
|
protected void |
DefaultFileSystemMaster.loadMetadataIfNotExist(RpcContext rpcContext,
AlluxioURI path,
LoadMetadataContext context)
Loads metadata for the path if it is (non-existing || load direct children is set).
|
protected void |
DefaultFileSystemMaster.setAttributeSingleFile(RpcContext rpcContext,
LockedInodePath inodePath,
boolean updateUfs,
long opTimeMs,
SetAttributeContext context) |
protected void |
DefaultFileSystemMaster.updateAccessTime(RpcContext rpcContext,
Inode inode,
long opTimeMs) |
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 |
---|---|
void |
ActiveSyncManager.startSyncAndJournal(RpcContext rpcContext,
AlluxioURI syncPoint)
Start active sync on a URI and journal the add entry.
|
void |
ActiveSyncManager.stopSyncAndJournal(RpcContext rpcContext,
AlluxioURI syncPoint)
Stop active sync on a URI and journal the remove entry.
|
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.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.
|
Modifier and Type | Method and Description |
---|---|
Collection<UfsStatus> |
UfsStatusCache.fetchChildrenIfAbsent(RpcContext rpcContext,
AlluxioURI path,
MountTable mountTable)
Fetches children of a given alluxio path stores them in the cache, then returns them.
|
Collection<UfsStatus> |
UfsStatusCache.fetchChildrenIfAbsent(RpcContext rpcContext,
AlluxioURI path,
MountTable mountTable,
boolean useFallback)
Fetches children of a given alluxio path, stores them in the cache, then returns them.
|
Copyright © 2023. All Rights Reserved.