Modifier and Type | Method and Description |
---|---|
void |
BaseFileSystem.createDirectory(AlluxioURI path) |
void |
FileSystem.createDirectory(AlluxioURI path)
Convenience method for
FileSystem.createDirectory(AlluxioURI, CreateDirectoryOptions) with
default options. |
void |
BaseFileSystem.createDirectory(AlluxioURI path,
CreateDirectoryOptions options) |
void |
FileSystem.createDirectory(AlluxioURI path,
CreateDirectoryOptions options)
Creates a directory.
|
FileOutStream |
BaseFileSystem.createFile(AlluxioURI path) |
FileOutStream |
FileSystem.createFile(AlluxioURI path)
Convenience method for
FileSystem.createFile(AlluxioURI, CreateFileOptions) with default options. |
FileOutStream |
BaseFileSystem.createFile(AlluxioURI path,
CreateFileOptions options) |
FileOutStream |
FileSystem.createFile(AlluxioURI path,
CreateFileOptions options)
Creates a file.
|
boolean |
BaseFileSystem.exists(AlluxioURI path) |
boolean |
FileSystem.exists(AlluxioURI path)
Convenience method for
FileSystem.exists(AlluxioURI, ExistsOptions) with default options. |
boolean |
BaseFileSystem.exists(AlluxioURI path,
ExistsOptions options) |
boolean |
FileSystem.exists(AlluxioURI path,
ExistsOptions options)
Checks whether a path exists in Alluxio space.
|
Modifier and Type | Method and Description |
---|---|
void |
KeyValueSystem.deleteStore(AlluxioURI uri)
Deletes a completed key-value store.
|
void |
BaseKeyValueSystem.deleteStore(AlluxioURI uri) |
Modifier and Type | Method and Description |
---|---|
List<AlluxioURI> |
DefaultFileSystemMaster.checkConsistency(AlluxioURI path,
CheckConsistencyOptions options) |
List<AlluxioURI> |
FileSystemMaster.checkConsistency(AlluxioURI path,
CheckConsistencyOptions options)
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,
CompleteFileOptions options) |
void |
FileSystemMaster.completeFile(AlluxioURI path,
CompleteFileOptions options)
Completes a file.
|
long |
DefaultFileSystemMaster.createDirectory(AlluxioURI path,
CreateDirectoryOptions options) |
long |
FileSystemMaster.createDirectory(AlluxioURI path,
CreateDirectoryOptions options)
Creates a directory for a given path.
|
long |
DefaultFileSystemMaster.createFile(AlluxioURI path,
CreateFileOptions options) |
long |
FileSystemMaster.createFile(AlluxioURI path,
CreateFileOptions options)
Creates a file (not a directory) for a given path.
|
void |
DefaultFileSystemMaster.delete(AlluxioURI path,
DeleteOptions options) |
void |
FileSystemMaster.delete(AlluxioURI path,
DeleteOptions options)
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.deleteAndJournal(RpcContext rpcContext,
LockedInodePath inodePath,
DeleteOptions deleteOptions)
Deletes a given path.
|
void |
DefaultFileSystemMaster.free(AlluxioURI path,
FreeOptions options) |
void |
FileSystemMaster.free(AlluxioURI path,
FreeOptions options)
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,
GetStatusOptions options) |
FileInfo |
FileSystemMaster.getFileInfo(AlluxioURI path,
GetStatusOptions options)
Returns the
FileInfo for a given path. |
MountPointInfo |
DefaultFileSystemMaster.getMountPointInfo(AlluxioURI path) |
MountPointInfo |
FileSystemMaster.getMountPointInfo(AlluxioURI path)
Deprecated.
will be removed after 2.0
|
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,
ListStatusOptions listStatusOptions) |
List<FileInfo> |
FileSystemMaster.listStatus(AlluxioURI path,
ListStatusOptions listStatusOptions)
Returns a list of
FileInfo for a given path. |
long |
DefaultFileSystemMaster.loadMetadata(AlluxioURI path,
LoadMetadataOptions options) |
long |
FileSystemMaster.loadMetadata(AlluxioURI path,
LoadMetadataOptions options)
Loads metadata for the object identified by the given path from UFS into Alluxio.
|
void |
DefaultFileSystemMaster.mount(AlluxioURI alluxioPath,
AlluxioURI ufsPath,
MountOptions options) |
void |
FileSystemMaster.mount(AlluxioURI alluxioPath,
AlluxioURI ufsPath,
MountOptions options)
Mounts a UFS path onto an Alluxio path.
|
long |
DefaultFileSystemMaster.reinitializeFile(AlluxioURI path,
long blockSizeBytes,
long ttl,
TtlAction ttlAction) |
long |
FileSystemMaster.reinitializeFile(AlluxioURI path,
long blockSizeBytes,
long ttl,
TtlAction ttlAction)
Reinitializes the blocks of an existing open file.
|
void |
DefaultFileSystemMaster.rename(AlluxioURI srcPath,
AlluxioURI dstPath,
RenameOptions options) |
void |
FileSystemMaster.rename(AlluxioURI srcPath,
AlluxioURI dstPath,
RenameOptions options)
Renames a file to a destination.
|
void |
DefaultFileSystemMaster.resetFile(long fileId) |
void |
FileSystemMaster.resetFile(long fileId)
Resets a file.
|
void |
DefaultFileSystemMaster.setAttribute(AlluxioURI path,
SetAttributeOptions options) |
void |
FileSystemMaster.setAttribute(AlluxioURI path,
SetAttributeOptions options)
Sets the file attribute.
|
void |
DefaultFileSystemMaster.unmount(AlluxioURI alluxioPath) |
void |
FileSystemMaster.unmount(AlluxioURI alluxioPath)
Unmounts a UFS path previously mounted onto an Alluxio path.
|
void |
DefaultFileSystemMaster.updateUfsMode(AlluxioURI ufsPath,
UnderFileSystem.UfsMode ufsMode) |
void |
FileSystemMaster.updateUfsMode(AlluxioURI ufsPath,
UnderFileSystem.UfsMode ufsMode)
Update the operation mode for the given ufs path under one or more mount points.
|
FileSystemCommand |
DefaultFileSystemMaster.workerHeartbeat(long workerId,
List<Long> persistedFiles,
WorkerHeartbeatOptions options) |
FileSystemCommand |
FileSystemMaster.workerHeartbeat(long workerId,
List<Long> persistedFiles,
WorkerHeartbeatOptions options)
Instructs a worker to persist the files.
|
Constructor and Description |
---|
SafeUfsDeleter(MountTable mountTable,
List<Pair<AlluxioURI,LockedInodePath>> inodes,
DeleteOptions 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(AlluxioURI alluxioUri,
AlluxioURI ufsUri,
long mountId,
MountOptions 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) |
InodeTree.CreatePathResult |
InodeTree.createPath(RpcContext rpcContext,
LockedInodePath inodePath,
CreatePathOptions<?> options)
Creates a file or directory at path.
|
LockedInodePath |
LockedInodePath.createTempPathForChild(String childName)
Constructs a temporary
LockedInodePath from an existing LockedInodePath , for
a direct child of the existing path. |
LockedInodePath |
LockedInodePath.createTempPathForExistingChild(Inode<?> child,
InodeTree.LockMode lockMode)
Constructs a temporary
LockedInodePath from an existing LockedInodePath , for
a direct child of the existing path. |
void |
InodeTree.ensureFullInodePath(LockedInodePath inodePath,
InodeTree.LockMode lockMode)
Attempts to extend an existing
LockedInodePath to reach the target inode (the last
inode for the full path). |
Inode<?> |
InodeDirectory.getChildReadLock(String name,
InodeLockList lockList) |
Inode<?> |
InodeDirectory.getChildWriteLock(String name,
InodeLockList lockList) |
List<FileBlockInfo> |
FileSystemMasterView.getFileBlockInfoList(AlluxioURI path) |
String |
MountTable.getMountPoint(AlluxioURI uri)
Returns the closest ancestor mount point the given path is nested under.
|
InodeDirectory |
LockedInodePath.getParentInodeDirectory() |
LockedInodePath |
InodeTree.lockChildPath(LockedInodePath inodePath,
InodeTree.LockMode lockMode,
Inode<?> childInode,
String[] pathComponents)
Lock from a specific poiint in the tree to the immediate child, and return a lockedInodePath.
|
LockedInodePath |
InodeTree.lockDescendantPath(LockedInodePath inodePath,
InodeTree.LockMode lockMode,
AlluxioURI descendantUri)
Locks from a specific point in the tree to the descendant, and return a lockedInodePath.
|
LockedInodePath |
InodeTree.lockFullInodePath(AlluxioURI path,
InodeTree.LockMode lockMode)
Locks existing inodes on the specified path, in the specified
InodeTree.LockMode . |
LockedInodePath |
InodeTree.lockInodePath(AlluxioURI path,
InodeTree.LockMode lockMode)
Locks existing inodes on the specified path, in the specified
InodeTree.LockMode . |
InodePathPair |
InodeTree.lockInodePathPair(AlluxioURI path1,
InodeTree.LockMode lockMode1,
AlluxioURI path2,
InodeTree.LockMode lockMode2)
Locks existing inodes on the two specified paths.
|
void |
InodeLockList.lockReadAndCheckNameAndParent(Inode<?> inode,
Inode parent,
String name)
Locks the given inode in read mode, and adds it to this lock list.
|
void |
Inode.lockReadAndCheckNameAndParent(Inode parent,
String name)
Obtains a read lock on the inode.
|
void |
Inode.lockReadAndCheckParent(Inode parent)
Obtains a read lock on the inode.
|
void |
InodeLockList.lockReadAndCheckParent(Inode<?> inode,
Inode parent)
Locks the given inode in read mode, and adds it to this lock list.
|
void |
InodeLockList.lockWriteAndCheckNameAndParent(Inode<?> inode,
Inode parent,
String name)
Locks the given inode in write mode, and adds it to this lock list.
|
void |
Inode.lockWriteAndCheckNameAndParent(Inode parent,
String name)
Obtains a write lock on the inode.
|
void |
Inode.lockWriteAndCheckParent(Inode parent)
Obtains a write lock on the inode.
|
void |
InodeLockList.lockWriteAndCheckParent(Inode<?> inode,
Inode parent)
Locks the given inode in write mode, and adds it to this lock list.
|
long |
InodeTree.reinitializeFile(LockedInodePath inodePath,
long blockSizeBytes,
long ttl,
TtlAction ttlAction)
Reinitializes the block size and TTL of an existing open file.
|
MountTable.Resolution |
MountTable.resolve(AlluxioURI uri)
Resolves the given Alluxio path.
|
void |
InodeTree.setPinned(LockedInodePath inodePath,
boolean pinned)
Sets the pinned state of an inode.
|
void |
InodeTree.syncPersistDirectory(RpcContext rpcContext,
InodeDirectory dir)
Synchronously persists an
InodeDirectory to the UFS. |
Constructor and Description |
---|
MutableLockedInodePath(AlluxioURI uri,
InodeLockList lockList,
InodeTree.LockMode lockMode)
Creates an instance of
MutableLockedInodePath . |
MutableLockedInodePath(AlluxioURI descendantUri,
LockedInodePath lockedInodePath,
InodeLockList descendants)
Creates an instance of
MutableLockedInodePath . |
Modifier and Type | Method and Description |
---|---|
void |
DefaultKeyValueMaster.completePartition(AlluxioURI path,
PartitionInfo info) |
void |
KeyValueMaster.completePartition(AlluxioURI path,
PartitionInfo info)
Marks a partition complete and adds it to an incomplete key-value store.
|
void |
DefaultKeyValueMaster.completeStore(AlluxioURI path) |
void |
KeyValueMaster.completeStore(AlluxioURI path)
Marks a key-value store complete.
|
void |
DefaultKeyValueMaster.createStore(AlluxioURI path) |
void |
KeyValueMaster.createStore(AlluxioURI path)
Creates a new key-value store.
|
void |
DefaultKeyValueMaster.deleteStore(AlluxioURI uri) |
void |
KeyValueMaster.deleteStore(AlluxioURI uri)
Deletes a completed key-value store.
|
List<PartitionInfo> |
DefaultKeyValueMaster.getPartitionInfo(AlluxioURI path) |
List<PartitionInfo> |
KeyValueMaster.getPartitionInfo(AlluxioURI path)
Gets a list of partitions of a given key-value store.
|
void |
DefaultKeyValueMaster.mergeStore(AlluxioURI fromUri,
AlluxioURI toUri) |
void |
KeyValueMaster.mergeStore(AlluxioURI fromUri,
AlluxioURI toUri)
Merges one completed key-value store to another completed key-value store.
|
Modifier and Type | Method and Description |
---|---|
long |
LineageMaster.createLineage(List<AlluxioURI> inputFiles,
List<AlluxioURI> outputFiles,
Job job)
Creates a lineage.
|
long |
DefaultLineageMaster.createLineage(List<AlluxioURI> inputFiles,
List<AlluxioURI> outputFiles,
Job job) |
long |
LineageMaster.reinitializeFile(String path,
long blockSizeBytes,
long ttl,
TtlAction ttlAction)
Reinitializes the file when the file is lost or not completed.
|
long |
DefaultLineageMaster.reinitializeFile(String path,
long blockSizeBytes,
long ttl,
TtlAction ttlAction) |
void |
LineageMaster.reportLostFile(String path)
Reports a file as lost.
|
void |
DefaultLineageMaster.reportLostFile(String path) |
Modifier and Type | Method and Description |
---|---|
void |
MasterUfsManager.setUfsMode(AlluxioURI ufsPath,
UnderFileSystem.UfsMode ufsMode,
RpcContext rpcContext)
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 String |
PathUtils.getParent(String path)
Gets the parent of the file at a path.
|
static String[] |
PathUtils.getPathComponents(String path)
Gets the path components 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.