Package | Description |
---|---|
alluxio.client.file | |
alluxio.master.file | |
alluxio.master.file.async | |
alluxio.master.file.meta | |
alluxio.underfs.swift |
Modifier and Type | Method and Description |
---|---|
default void |
FileSystem.delete(AlluxioURI path)
Convenience method for
FileSystem.delete(AlluxioURI, DeletePOptions) with default options. |
void |
FileSystemCache.InstanceCachingFileSystem.delete(AlluxioURI path,
DeletePOptions options) |
void |
BaseFileSystem.delete(AlluxioURI path,
DeletePOptions options) |
void |
FileSystem.delete(AlluxioURI path,
DeletePOptions options)
Deletes a file or a directory.
|
void |
DelegatingFileSystem.delete(AlluxioURI path,
DeletePOptions options) |
default void |
FileSystem.free(AlluxioURI path)
Convenience method for
FileSystem.free(AlluxioURI, FreePOptions) with default options. |
void |
FileSystemCache.InstanceCachingFileSystem.free(AlluxioURI path,
FreePOptions options) |
void |
BaseFileSystem.free(AlluxioURI path,
FreePOptions options) |
void |
FileSystem.free(AlluxioURI path,
FreePOptions options)
Evicts any data under the given path from Alluxio space, but does not delete the data from the
UFS.
|
void |
DelegatingFileSystem.free(AlluxioURI path,
FreePOptions options) |
List<BlockLocationInfo> |
FileSystemCache.InstanceCachingFileSystem.getBlockLocations(AlluxioURI path) |
List<BlockLocationInfo> |
FileSystem.getBlockLocations(AlluxioURI path)
Builds a list of
BlockLocationInfo for the given file. |
List<BlockLocationInfo> |
DelegatingFileSystem.getBlockLocations(AlluxioURI path) |
default URIStatus |
FileSystem.getStatus(AlluxioURI path)
Convenience method for
FileSystem.getStatus(AlluxioURI, GetStatusPOptions) with default options. |
URIStatus |
FileSystemCache.InstanceCachingFileSystem.getStatus(AlluxioURI path,
GetStatusPOptions options) |
URIStatus |
BaseFileSystem.getStatus(AlluxioURI path,
GetStatusPOptions options) |
URIStatus |
MetadataCachingBaseFileSystem.getStatus(AlluxioURI path,
GetStatusPOptions options) |
URIStatus |
FileSystem.getStatus(AlluxioURI path,
GetStatusPOptions options)
Gets the
URIStatus object that represents the metadata of an Alluxio path. |
URIStatus |
DelegatingFileSystem.getStatus(AlluxioURI path,
GetStatusPOptions options) |
default List<URIStatus> |
FileSystem.listStatus(AlluxioURI path)
Convenience method for
FileSystem.listStatus(AlluxioURI, ListStatusPOptions) with default
options. |
List<URIStatus> |
FileSystemCache.InstanceCachingFileSystem.listStatus(AlluxioURI path,
ListStatusPOptions options) |
List<URIStatus> |
BaseFileSystem.listStatus(AlluxioURI path,
ListStatusPOptions options) |
List<URIStatus> |
MetadataCachingBaseFileSystem.listStatus(AlluxioURI path,
ListStatusPOptions options) |
List<URIStatus> |
FileSystem.listStatus(AlluxioURI path,
ListStatusPOptions options)
If the path is a directory, returns the
URIStatus of all the direct entries in it. |
List<URIStatus> |
DelegatingFileSystem.listStatus(AlluxioURI path,
ListStatusPOptions options) |
default FileInStream |
FileSystem.openFile(AlluxioURI path)
Convenience method for
FileSystem.openFile(AlluxioURI, OpenFilePOptions) with default options. |
FileInStream |
FileSystemCache.InstanceCachingFileSystem.openFile(AlluxioURI path,
OpenFilePOptions options) |
FileInStream |
BaseFileSystem.openFile(AlluxioURI path,
OpenFilePOptions options) |
FileInStream |
FileSystem.openFile(AlluxioURI path,
OpenFilePOptions options)
Opens a file for reading.
|
FileInStream |
DelegatingFileSystem.openFile(AlluxioURI path,
OpenFilePOptions options) |
FileInStream |
FileSystemCache.InstanceCachingFileSystem.openFile(URIStatus status,
OpenFilePOptions options) |
FileInStream |
BaseFileSystem.openFile(URIStatus status,
OpenFilePOptions options) |
FileInStream |
FileSystem.openFile(URIStatus status,
OpenFilePOptions options)
Opens a file for reading.
|
FileInStream |
DelegatingFileSystem.openFile(URIStatus status,
OpenFilePOptions options) |
default void |
FileSystem.persist(AlluxioURI path)
Convenience method for
FileSystem.persist(AlluxioURI, ScheduleAsyncPersistencePOptions) which
uses the default ScheduleAsyncPersistencePOptions . |
void |
FileSystemCache.InstanceCachingFileSystem.persist(AlluxioURI path,
ScheduleAsyncPersistencePOptions options) |
void |
BaseFileSystem.persist(AlluxioURI path,
ScheduleAsyncPersistencePOptions options) |
void |
FileSystem.persist(AlluxioURI path,
ScheduleAsyncPersistencePOptions options)
Schedules the given path to be asynchronously persisted to the under file system.
|
void |
DelegatingFileSystem.persist(AlluxioURI path,
ScheduleAsyncPersistencePOptions options) |
static void |
FileSystemUtils.persistAndWait(FileSystem fs,
AlluxioURI uri,
long persistenceWaitTime)
Convenience method for
#persistAndWait(fs, uri, persistenceWaitTime, -1) . |
static void |
FileSystemUtils.persistAndWait(FileSystem fs,
AlluxioURI uri,
long persistenceWaitTime,
int timeoutMs)
Persists the given path to the under file system and returns once the persist is complete.
|
default void |
FileSystem.rename(AlluxioURI src,
AlluxioURI dst)
Convenience method for
FileSystem.rename(AlluxioURI, AlluxioURI, RenamePOptions) with default
options. |
void |
FileSystemCache.InstanceCachingFileSystem.rename(AlluxioURI src,
AlluxioURI dst,
RenamePOptions options) |
void |
BaseFileSystem.rename(AlluxioURI src,
AlluxioURI dst,
RenamePOptions options) |
void |
FileSystem.rename(AlluxioURI src,
AlluxioURI dst,
RenamePOptions options)
Renames an existing Alluxio path to another Alluxio path in Alluxio.
|
void |
DelegatingFileSystem.rename(AlluxioURI src,
AlluxioURI dst,
RenamePOptions options) |
default void |
FileSystem.setAcl(AlluxioURI path,
SetAclAction action,
List<AclEntry> entries)
Convenience method for
FileSystem.setAcl(AlluxioURI, SetAclAction, List, SetAclPOptions) with
default options. |
void |
FileSystemCache.InstanceCachingFileSystem.setAcl(AlluxioURI path,
SetAclAction action,
List<AclEntry> entries,
SetAclPOptions options) |
void |
BaseFileSystem.setAcl(AlluxioURI path,
SetAclAction action,
List<AclEntry> entries,
SetAclPOptions options) |
void |
FileSystem.setAcl(AlluxioURI path,
SetAclAction action,
List<AclEntry> entries,
SetAclPOptions options)
Sets the ACL for a path.
|
void |
DelegatingFileSystem.setAcl(AlluxioURI path,
SetAclAction action,
List<AclEntry> entries,
SetAclPOptions options) |
default void |
FileSystem.setAttribute(AlluxioURI path)
Convenience method for
FileSystem.setAttribute(AlluxioURI, SetAttributePOptions) with default
options. |
void |
FileSystemCache.InstanceCachingFileSystem.setAttribute(AlluxioURI path,
SetAttributePOptions options) |
void |
BaseFileSystem.setAttribute(AlluxioURI path,
SetAttributePOptions options) |
void |
FileSystem.setAttribute(AlluxioURI path,
SetAttributePOptions options)
Sets any number of a path's attributes, such as TTL and pin status.
|
void |
DelegatingFileSystem.setAttribute(AlluxioURI path,
SetAttributePOptions options) |
void |
FileSystemCache.InstanceCachingFileSystem.startSync(AlluxioURI path) |
void |
BaseFileSystem.startSync(AlluxioURI path)
Starts the active syncing process on an Alluxio path.
|
void |
FileSystem.startSync(AlluxioURI path)
Starts the active syncing process on an Alluxio path.
|
void |
DelegatingFileSystem.startSync(AlluxioURI path) |
void |
FileSystemCache.InstanceCachingFileSystem.stopSync(AlluxioURI path) |
void |
BaseFileSystem.stopSync(AlluxioURI path)
Stops the active syncing process on an Alluxio path.
|
void |
FileSystem.stopSync(AlluxioURI path)
Stops the active syncing process on an Alluxio path.
|
void |
DelegatingFileSystem.stopSync(AlluxioURI path) |
Modifier and Type | Method and Description |
---|---|
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 |
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.
|
void |
DefaultFileSystemMaster.delete(AlluxioURI path,
DeleteContext context) |
void |
FileSystemMaster.delete(AlluxioURI path,
DeleteContext context)
Deletes a given path.
|
void |
DefaultFileSystemMaster.deleteInternal(RpcContext rpcContext,
LockedInodePath inodePath,
DeleteContext deleteContext)
Implements file deletion.
|
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.
|
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. |
FileInfo |
DefaultFileSystemMaster.getFileInfo(long fileId) |
FileInfo |
FileSystemMaster.getFileInfo(long fileId)
Returns the
FileInfo for a given file id. |
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.
|
AlluxioURI |
DefaultFileSystemMaster.getPath(long fileId) |
AlluxioURI |
FileSystemMaster.getPath(long fileId)
Gets the path of a file with the given id.
|
PersistenceState |
DefaultFileSystemMaster.getPersistenceState(long fileId) |
PersistenceState |
FileSystemMaster.getPersistenceState(long fileId)
Returns the persistence state for a file id.
|
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.
|
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.rename(AlluxioURI srcPath,
AlluxioURI dstPath,
RenameContext context) |
void |
FileSystemMaster.rename(AlluxioURI srcPath,
AlluxioURI dstPath,
RenameContext context)
Renames a file to a destination.
|
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) |
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.
|
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> |
AsyncPersistHandler.pollFilesToPersist(long workerId)
Polls the files for persistence on the given worker.
|
List<PersistFile> |
DefaultAsyncPersistHandler.pollFilesToPersist(long workerId)
Polls the files to send to the given worker for persistence.
|
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.ensureFullInodePath(LockedInodePath inodePath)
Attempts to extend an existing
LockedInodePath to reach the target inode (the last
inode for the full path). |
Inode |
LockedInodePath.getAncestorInode()
Returns the closest ancestor of the target inode (last inode in the full path).
|
List<FileBlockInfo> |
FileSystemMasterView.getFileBlockInfoList(AlluxioURI path) |
long |
FileSystemMasterView.getFileId(AlluxioURI path)
Returns the file id for a given path.
|
FileInfo |
FileSystemMasterView.getFileInfo(long fileId)
Returns the
FileInfo for a given path. |
PersistenceState |
FileSystemMasterView.getFilePersistenceState(long fileId)
Returns the persistence state of a given file.
|
Inode |
LockedInodePath.getInode() |
InodeFile |
LockedInodePath.getInodeFile() |
InodeDirectory |
LockedInodePath.getParentInodeDirectory() |
AlluxioURI |
InodeTree.getPath(InodeView inode)
Returns the path for a particular inode.
|
AlluxioURI |
FileSystemMasterView.getPath(long fileId)
Gets the path of a file with the given id.
|
LockedInodePath |
InodeTree.lockFullInodePath(AlluxioURI uri,
InodeTree.LockPattern lockPattern)
Locks a path and throws an exception if the path does not exist.
|
LockedInodePath |
InodeTree.lockFullInodePath(AlluxioURI uri,
LockingScheme lockScheme)
Locks a path and throws an exception if the path does not exist.
|
LockedInodePath |
InodeTree.lockFullInodePath(long id,
InodeTree.LockPattern lockPattern)
Locks a path and throws an exception if the path does not exist.
|
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.
|
void |
InodeTree.syncPersistExistingDirectory(java.util.function.Supplier<JournalContext> context,
InodeDirectoryView dir)
Synchronously persists an inode directory to the UFS.
|
void |
InodeTree.syncPersistNewDirectory(MutableInodeDirectory dir)
Synchronously persists an inode directory to the UFS.
|
Constructor and Description |
---|
SwiftUnderFileSystem(AlluxioURI uri,
UnderFileSystemConfiguration conf)
Constructs a new Swift
UnderFileSystem . |
Copyright © 2023. All Rights Reserved.