Package | Description |
---|---|
alluxio.master.file | |
alluxio.master.file.async | |
alluxio.master.file.meta | |
alluxio.security.authentication |
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.
|
protected void |
DefaultPermissionChecker.checkInodeList(String user,
List<String> groups,
Mode.Bits bits,
String path,
List<InodeView> inodeList,
boolean checkIsOwner)
This method provides basic permission checking logic on a list of inodes.
|
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.checkParentPermission(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.checkPermission(Mode.Bits bits,
LockedInodePath inodePath) |
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 |
DefaultPermissionChecker.checkSetAttributePermission(LockedInodePath inodePath,
boolean superuserRequired,
boolean ownerRequired,
boolean writeRequired) |
void |
PermissionChecker.checkSuperUser()
Checks whether the user is a super user or in super group.
|
void |
DefaultPermissionChecker.checkSuperUser() |
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.
|
boolean |
DefaultFileSystemMaster.exists(AlluxioURI path,
ExistsContext context) |
boolean |
FileSystemMaster.exists(AlluxioURI path,
ExistsContext context)
Checks path exists.
|
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. |
long |
DefaultFileSystemMaster.getFileId(AlluxioURI path) |
long |
FileSystemMaster.getFileId(AlluxioURI path)
Returns the file id for a given path.
|
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.
|
List<SyncPointInfo> |
FileSystemMaster.getSyncPathList() |
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).
|
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.startSync(AlluxioURI syncPoint) |
void |
FileSystemMaster.startSync(AlluxioURI alluxioURI)
starts active sync on a specified alluxioURI.
|
void |
DefaultFileSystemMaster.stopSync(AlluxioURI syncPoint) |
void |
FileSystemMaster.stopSync(AlluxioURI alluxioURI)
stops active sync on a specific syncpoint.
|
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.
|
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 |
---|---|
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 |
---|---|
static String |
AuthenticatedClientUser.getAuthMethod(AlluxioConfiguration conf)
Gets the connection authentication method from the
ThreadLocal variable. |
static String |
AuthenticatedClientUser.getClientUser(AlluxioConfiguration conf)
Gets the user name from the
ThreadLocal variable. |
static String |
AuthenticatedClientUser.getConnectionUser(AlluxioConfiguration conf)
Gets the connection user name from the
ThreadLocal variable. |
Copyright © 2023. All Rights Reserved.