Package | Description |
---|---|
alluxio | |
alluxio.client.file | |
alluxio.client.file.dora | |
alluxio.examples | |
alluxio.master.file | |
alluxio.master.file.async | |
alluxio.master.file.meta | |
alluxio.underfs | |
alluxio.util.io |
Modifier and Type | Method and Description |
---|---|
boolean |
AlluxioURI.isAncestorOf(AlluxioURI alluxioURI)
Returns true if the current AlluxioURI is an ancestor of another AlluxioURI.
|
Modifier and Type | Method and Description |
---|---|
void |
FileSystem.checkAccess(AlluxioURI path,
CheckAccessPOptions options)
Checks access to a path.
|
void |
DelegatingFileSystem.checkAccess(AlluxioURI path,
CheckAccessPOptions options) |
AlluxioURI |
DoraCacheFileSystem.convertToAlluxioPath(AlluxioURI ufsPath)
Converts the UFS path back to Alluxio path.
|
default void |
FileSystem.createDirectory(AlluxioURI path)
Convenience method for
FileSystem.createDirectory(AlluxioURI, CreateDirectoryPOptions) with
default options. |
void |
MetadataCachingFileSystem.createDirectory(AlluxioURI path,
CreateDirectoryPOptions options) |
void |
FileSystemCache.InstanceCachingFileSystem.createDirectory(AlluxioURI path,
CreateDirectoryPOptions options) |
void |
DoraCacheFileSystem.createDirectory(AlluxioURI path,
CreateDirectoryPOptions options) |
void |
FileSystem.createDirectory(AlluxioURI path,
CreateDirectoryPOptions options)
Creates a directory.
|
void |
DelegatingFileSystem.createDirectory(AlluxioURI path,
CreateDirectoryPOptions options) |
default FileOutStream |
FileSystem.createFile(AlluxioURI path)
Convenience method for
FileSystem.createFile(AlluxioURI, CreateFilePOptions) with default
options. |
FileOutStream |
FileSystemCache.InstanceCachingFileSystem.createFile(AlluxioURI path,
CreateFilePOptions options) |
FileOutStream |
DoraCacheFileSystem.createFile(AlluxioURI alluxioPath,
CreateFilePOptions options) |
FileOutStream |
FileSystem.createFile(AlluxioURI path,
CreateFilePOptions options)
Creates a file.
|
FileOutStream |
DelegatingFileSystem.createFile(AlluxioURI path,
CreateFilePOptions options) |
default boolean |
FileSystem.exists(AlluxioURI path)
Convenience method for
FileSystem.exists(AlluxioURI, ExistsPOptions) with default options. |
boolean |
FileSystemCache.InstanceCachingFileSystem.exists(AlluxioURI path,
ExistsPOptions options) |
boolean |
DoraCacheFileSystem.exists(AlluxioURI path,
ExistsPOptions options) |
boolean |
FileSystem.exists(AlluxioURI path,
ExistsPOptions options)
Checks whether a path exists in Alluxio space.
|
boolean |
DelegatingFileSystem.exists(AlluxioURI path,
ExistsPOptions options) |
Modifier and Type | Method and Description |
---|---|
boolean |
DoraCacheClient.exists(String path,
ExistsPOptions options)
Check existence of a file or dir.
|
Modifier and Type | Method and Description |
---|---|
static void |
AlluxioFS.main(String[] args)
Entry point for the
AlluxioFS program. |
Modifier and Type | Method and Description |
---|---|
void |
DefaultFileSystemMaster.checkAccess(AlluxioURI path,
CheckAccessContext context) |
void |
FileSystemMaster.checkAccess(AlluxioURI path,
CheckAccessContext context)
Checks access to path.
|
List<AlluxioURI> |
DefaultFileSystemMaster.checkConsistency(AlluxioURI path,
CheckConsistencyContext context) |
List<AlluxioURI> |
FileSystemMaster.checkConsistency(AlluxioURI path,
CheckConsistencyContext context)
Checks the consistency of the files and directories in the subtree under the path.
|
void |
UfsSyncChecker.checkDirectory(InodeDirectory inode,
AlluxioURI alluxioUri)
Check if immediate children of directory are in sync with UFS.
|
void |
DefaultPermissionChecker.checkParentPermission(Mode.Bits bits,
LockedInodePath inodePath) |
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.checkSetAttributePermission(LockedInodePath inodePath,
boolean superuserRequired,
boolean ownerRequired,
boolean writeRequired) |
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 |
DefaultFileSystemMaster.completeFile(AlluxioURI path,
CompleteFileContext context) |
void |
FileSystemMaster.completeFile(AlluxioURI path,
CompleteFileContext context)
Completes a file.
|
long |
DefaultFileSystemMaster.createDirectory(AlluxioURI path,
CreateDirectoryContext context) |
long |
FileSystemMaster.createDirectory(AlluxioURI path,
CreateDirectoryContext context)
Creates a directory for a given path.
|
FileInfo |
DefaultFileSystemMaster.createFile(AlluxioURI path,
CreateFileContext context) |
FileInfo |
FileSystemMaster.createFile(AlluxioURI path,
CreateFileContext context)
Creates a file (not a directory) for a given path.
|
protected LockingScheme |
DefaultFileSystemMaster.createSyncLockingScheme(AlluxioURI path,
FileSystemMasterCommonPOptions options,
DescendantType descendantType) |
void |
DefaultFileSystemMaster.delete(AlluxioURI path,
DeleteContext context) |
void |
FileSystemMaster.delete(AlluxioURI path,
DeleteContext context)
Deletes a given path.
|
void |
UfsDeleter.delete(AlluxioURI alluxioUri,
Inode inode)
Deletes a path if not covered by a recursive delete.
|
void |
SafeUfsDeleter.delete(AlluxioURI alluxioUri,
Inode inode) |
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.
|
void |
DefaultFileSystemMaster.free(AlluxioURI path,
FreeContext context) |
void |
FileSystemMaster.free(AlluxioURI path,
FreeContext context)
Frees or evicts all of the blocks of the file from alluxio storage.
|
MountPointInfo |
DefaultFileSystemMaster.getDisplayMountPointInfo(AlluxioURI path) |
MountPointInfo |
FileSystemMaster.getDisplayMountPointInfo(AlluxioURI path)
Gets the mount point information of an Alluxio path for display purpose.
|
List<FileBlockInfo> |
DefaultFileSystemMaster.getFileBlockInfoList(AlluxioURI path) |
List<FileBlockInfo> |
FileSystemMaster.getFileBlockInfoList(AlluxioURI path)
Gets the
FileBlockInfo for all blocks of a file. |
FileInfo |
DefaultFileSystemMaster.getFileInfo(AlluxioURI path,
GetStatusContext context) |
FileInfo |
FileSystemMaster.getFileInfo(AlluxioURI path,
GetStatusContext context)
Returns the
FileInfo for a given path. |
long |
DefaultFileSystemMaster.getNewBlockIdForFile(AlluxioURI path) |
long |
FileSystemMaster.getNewBlockIdForFile(AlluxioURI path)
Gets a new block id for the next block of a given file to write to.
|
List<FileInfo> |
DefaultFileSystemMaster.listStatus(AlluxioURI path,
ListStatusContext context) |
List<FileInfo> |
FileSystemMaster.listStatus(AlluxioURI path,
ListStatusContext context)
Returns a list of
FileInfo for a given path. |
void |
DefaultFileSystemMaster.listStatus(AlluxioURI path,
ListStatusContext context,
ResultStream<FileInfo> resultStream) |
void |
FileSystemMaster.listStatus(AlluxioURI path,
ListStatusContext context,
ResultStream<FileInfo> resultStream)
Enumerates given path to given batch tracker.
|
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).
|
MetadataSyncLockManager.MetadataSyncPathList |
MetadataSyncLockManager.lockPath(AlluxioURI uri)
Acquire locks for a given path before metadata sync.
|
void |
DefaultFileSystemMaster.mount(AlluxioURI alluxioPath,
AlluxioURI ufsPath,
MountContext context) |
void |
FileSystemMaster.mount(AlluxioURI alluxioPath,
AlluxioURI ufsPath,
MountContext context)
Mounts a UFS path onto an Alluxio path.
|
void |
DefaultFileSystemMaster.needsSync(AlluxioURI path) |
void |
FileSystemMaster.needsSync(AlluxioURI path)
Mark a path as needed synchronization with the UFS, when this path or any
of its children are accessed, a sync with the UFS will be performed.
|
void |
DefaultFileSystemMaster.rename(AlluxioURI srcPath,
AlluxioURI dstPath,
RenameContext context) |
void |
FileSystemMaster.rename(AlluxioURI srcPath,
AlluxioURI dstPath,
RenameContext context)
Renames a file to a destination.
|
AlluxioURI |
DefaultFileSystemMaster.reverseResolve(AlluxioURI ufsUri) |
AlluxioURI |
FileSystemMaster.reverseResolve(AlluxioURI ufsUri)
Reverse path resolve a ufs uri to an Alluxio path.
|
void |
DefaultFileSystemMaster.setAcl(AlluxioURI path,
SetAclAction action,
List<AclEntry> entries,
SetAclContext context) |
void |
FileSystemMaster.setAcl(AlluxioURI path,
SetAclAction action,
List<AclEntry> entries,
SetAclContext context)
Sets the ACL for a path.
|
void |
DefaultFileSystemMaster.setAttribute(AlluxioURI path,
SetAttributeContext context) |
void |
FileSystemMaster.setAttribute(AlluxioURI path,
SetAttributeContext options)
Sets the file attribute.
|
protected void |
DefaultFileSystemMaster.setAttributeSingleFile(RpcContext rpcContext,
LockedInodePath inodePath,
boolean updateUfs,
long opTimeMs,
SetAttributeContext context) |
InodeSyncStream.SyncStatus |
InodeSyncStream.sync()
Sync the metadata according the root path the stream was created with.
|
void |
DefaultFileSystemMaster.unmount(AlluxioURI alluxioPath) |
void |
FileSystemMaster.unmount(AlluxioURI alluxioPath)
Unmounts a UFS path previously mounted onto an Alluxio path.
|
void |
DefaultFileSystemMaster.updateMount(AlluxioURI alluxioPath,
MountContext context) |
void |
FileSystemMaster.updateMount(AlluxioURI alluxioPath,
MountContext context)
Update properties of an Alluxio mount point.
|
void |
DefaultFileSystemMaster.updateUfsMode(AlluxioURI ufsPath,
UfsMode ufsMode) |
void |
FileSystemMaster.updateUfsMode(AlluxioURI ufsPath,
UfsMode ufsMode)
Update the operation mode for the given ufs path under one or more mount points.
|
FileSystemCommand |
FileSystemMaster.workerHeartbeat(long workerId,
List<Long> persistedFiles,
WorkerHeartbeatContext context)
Instructs a worker to persist the files.
|
Constructor and Description |
---|
SafeUfsDeleter(MountTable mountTable,
ReadOnlyInodeStore inodeStore,
List<Pair<AlluxioURI,LockedInodePath>> inodes,
DeletePOptions deleteOptions)
Creates a new instance of
SafeUfsDeleter . |
Modifier and Type | Method and Description |
---|---|
List<PersistFile> |
DefaultAsyncPersistHandler.pollFilesToPersist(long workerId)
Polls the files to send to the given worker for persistence.
|
List<PersistFile> |
AsyncPersistHandler.pollFilesToPersist(long workerId)
Polls the files for persistence on the given worker.
|
Modifier and Type | Method and Description |
---|---|
void |
MountTable.add(java.util.function.Supplier<JournalContext> journalContext,
AlluxioURI alluxioUri,
AlluxioURI ufsUri,
long mountId,
MountPOptions options)
Mounts the given UFS path at the given Alluxio path.
|
void |
MountTable.checkUnderWritableMountPoint(AlluxioURI alluxioUri)
Checks to see if a write operation is allowed for the specified Alluxio path, by determining
if it is under a readonly mount point.
|
boolean |
MountTable.containsMountPoint(AlluxioURI uri,
boolean containsSelf) |
List<Inode> |
InodeTree.createPath(RpcContext rpcContext,
LockedInodePath inodePath,
CreatePathContext<?,?> context)
Creates a file or directory at path.
|
void |
InodeTree.ensureFullInodePath(LockedInodePath inodePath)
Attempts to extend an existing
LockedInodePath to reach the target inode (the last
inode for the full path). |
List<MountInfo> |
MountTable.findChildrenMountPoints(AlluxioURI uri,
boolean containsSelf)
Returns the mount points under the specified path.
|
List<FileBlockInfo> |
FileSystemMasterView.getFileBlockInfoList(AlluxioURI path) |
MountInfo |
MountTable.getMountInfo(AlluxioURI uri)
Gets mount information for the path.
|
String |
MountTable.getMountPoint(AlluxioURI uri)
Returns the closest ancestor mount point the given path is nested under.
|
InodeDirectory |
LockedInodePath.getParentInodeDirectory() |
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.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() . |
InodePathPair |
InodeTree.lockInodePathPair(AlluxioURI path1,
InodeTree.LockPattern lockPattern1,
AlluxioURI path2,
InodeTree.LockPattern lockPattern2,
JournalContext journalContext)
Locks existing inodes on the two specified paths.
|
void |
UfsSyncPathCache.notifyInvalidation(AlluxioURI path)
Notify that a path has been invalidated.
|
MountTable.Resolution |
MountTable.resolve(AlluxioURI uri)
Resolves the given Alluxio path.
|
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.
|
SyncCheck |
UfsSyncPathCache.shouldSyncPath(AlluxioURI path,
long intervalMs,
DescendantType descendantType)
Check if sync should happen.
|
void |
InodeTree.syncPersistExistingDirectory(java.util.function.Supplier<JournalContext> context,
InodeDirectoryView dir,
boolean isMetadataLoad)
Synchronously persists an inode directory to the UFS.
|
void |
InodeTree.syncPersistNewDirectory(MutableInodeDirectory dir,
CreatePathContext<?,?> createContext)
Synchronously persists an inode directory to the UFS.
|
void |
LockedInodePath.traverse()
Traverses the inode path according to its lock pattern.
|
LockedInodePath |
InodeTree.tryLockInodePath(LockingScheme scheme,
JournalContext journalContext)
Locks existing inodes on the path and with the pattern defined by
LockingScheme.getPath() and LockingScheme.getPattern() . |
void |
MountTable.update(java.util.function.Supplier<JournalContext> journalContext,
AlluxioURI alluxioUri,
long newMountId,
MountPOptions newOptions)
Update the mount point with new options and mount ID.
|
void |
MountTable.validateMountPoint(AlluxioURI alluxioUri,
AlluxioURI ufsUri,
long mountId,
MountPOptions options)
Verify if the given (alluxioPath, ufsPath) can be inserted into MountTable.
|
Constructor and Description |
---|
LockedInodePath(AlluxioURI uri,
ReadOnlyInodeStore inodeStore,
InodeLockManager inodeLockManager,
InodeDirectory root,
InodeTree.LockPattern lockPattern,
boolean tryLock,
JournalContext journalContext)
Creates a new locked inode path.
|
LockingScheme(AlluxioURI path,
InodeTree.LockPattern desiredPattern,
FileSystemMasterCommonPOptions options,
UfsSyncPathCache pathCache,
DescendantType descendantType)
Create a new
LockingScheme . |
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.
|
UfsStatus |
UfsStatusCache.fetchStatusIfAbsent(AlluxioURI path,
MountTable mountTable)
Attempts to return a status from the cache.
|
void |
MasterUfsManager.setUfsMode(java.util.function.Supplier<JournalContext> journalContext,
AlluxioURI ufsPath,
UfsMode ufsMode)
Set the operation mode the given physical ufs.
|
Modifier and Type | Method and Description |
---|---|
static String |
PathUtils.cleanPath(String path)
Checks and normalizes the given path.
|
static AlluxioURI |
PathUtils.convertUfsPathToAlluxioPath(AlluxioURI ufsPath,
AlluxioURI ufsRootPath)
Converts the UFS path back to Alluxio path.
|
static String[] |
PathUtils.getCleanedPathComponents(String path)
Get the components of a path that has already been cleaned.
|
static String |
PathUtils.getFirstLevelDirectory(String path)
Gets the first level directory of the path.
|
static String |
PathUtils.getParent(String path)
Gets the parent of the file at a path.
|
static String |
PathUtils.getParentCleaned(String cleanedPath)
The same as
PathUtils.getParent(java.lang.String) except does not clean the path before getting the parent. |
static String[] |
PathUtils.getPathComponents(String path)
Gets the path components of the given path.
|
static List<String> |
PathUtils.getPossibleMountPoints(String path)
Returns the list of possible mount points of the given path.
|
static boolean |
PathUtils.hasPrefix(String path,
String prefix)
Checks whether the given path contains the given prefix.
|
static boolean |
PathUtils.isRoot(String path)
Checks if the given path is the root.
|
static String |
PathUtils.subtractPaths(String path,
String prefix)
Removes the prefix from the path, yielding a relative path from the second path to the first.
|
static void |
PathUtils.validatePath(String path)
Checks if the given path is properly formed.
|
Copyright © 2023. All Rights Reserved.