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.
|
protected void |
DefaultPermissionChecker.checkInodeList(String user,
List<String> groups,
Mode.Bits bits,
String path,
List<Inode<?>> inodeList,
boolean checkIsOwner)
This method provides basic permission checking logic on a list of inodes.
|
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.checkPermission(Mode.Bits bits,
LockedInodePath inodePath) |
void |
PermissionChecker.checkPermission(Mode.Bits bits,
LockedInodePath inodePath)
Checks whether a user has permission to perform a specific action on a path.
|
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 |
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.
|
List<FileBlockInfo> |
DefaultFileSystemMaster.getFileBlockInfoList(AlluxioURI path) |
List<FileBlockInfo> |
FileSystemMaster.getFileBlockInfoList(AlluxioURI path)
Gets the
FileBlockInfo for all blocks of a file. |
long |
DefaultFileSystemMaster.getFileId(AlluxioURI path) |
long |
FileSystemMaster.getFileId(AlluxioURI path)
Returns the file id for a given path.
|
FileInfo |
DefaultFileSystemMaster.getFileInfo(AlluxioURI path,
GetStatusOptions options) |
FileInfo |
FileSystemMaster.getFileInfo(AlluxioURI path,
GetStatusOptions options)
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.
|
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.
|
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.
|
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 |
InodeTree.addInodeDirectoryFromJournal(File.InodeDirectoryEntry entry)
Adds the directory represented by the entry parameter into the inode tree.
|
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.
|
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. |
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.
|
List<PartitionInfo> |
DefaultKeyValueMaster.getPartitionInfo(AlluxioURI path) |
List<PartitionInfo> |
KeyValueMaster.getPartitionInfo(AlluxioURI path)
Gets a list of partitions of a given 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 |
---|---|
static boolean |
LineageStateUtils.isCompleted(Lineage lineage,
FileSystemMasterView fileSystemMasterView)
Checks if all the output files of the given lineage are completed.
|
Modifier and Type | Method and Description |
---|---|
static String |
AuthenticatedClientUser.getClientUser()
Gets the user name from the
ThreadLocal variable. |
Copyright © 2023. All Rights Reserved.