Package | Description |
---|---|
alluxio.master.file | |
alluxio.master.file.async | |
alluxio.master.file.meta | |
alluxio.security.authentication | |
alluxio.worker.dora | |
alluxio.worker.s3 |
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 |
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 |
DefaultPermissionChecker.checkSuperUser() |
void |
PermissionChecker.checkSuperUser()
Checks whether the user is a super user or in super group.
|
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<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) |
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> |
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.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. |
Modifier and Type | Method and Description |
---|---|
protected void |
PagedDoraWorker.checkCopyPermission(String srcPath,
String dstPath) |
protected void |
PagedDoraWorker.checkMovePermission(String srcPath,
String dstPath) |
void |
PagedDoraWorker.completeFile(String path,
CompleteFilePOptions options,
String uuid) |
void |
DoraWorker.completeFile(String path,
CompleteFilePOptions options,
String uuid)
Complete writing a file.
|
void |
PagedDoraWorker.createDirectory(String path,
CreateDirectoryPOptions options) |
void |
DoraWorker.createDirectory(String path,
CreateDirectoryPOptions options)
Create a directory.
|
OpenFileHandle |
PagedDoraWorker.createFile(String path,
CreateFilePOptions options) |
OpenFileHandle |
DoraWorker.createFile(String path,
CreateFilePOptions options)
Create File.
|
BlockReader |
PagedDoraWorker.createFileReader(String fileId,
long offset,
boolean positionShort,
Protocol.OpenUfsBlockOptions options) |
BlockReader |
DoraWorker.createFileReader(String fileId,
long offset,
boolean positionShort,
Protocol.OpenUfsBlockOptions options)
Creates the file reader to read from Alluxio dora.
|
BlockWriter |
PagedDoraWorker.createFileWriter(String fileId,
String ufsPath) |
BlockWriter |
DoraWorker.createFileWriter(String fileId,
String ufsPath)
Creates the file writer to write to Alluxio dora.
|
void |
PagedDoraWorker.delete(String path,
DeletePOptions options) |
void |
DoraWorker.delete(String path,
DeletePOptions options)
Delete a file.
|
FileInfo |
PagedDoraWorker.getFileInfo(String ufsFullPath,
GetStatusPOptions options) |
FileInfo |
DoraWorker.getFileInfo(String fileId,
GetStatusPOptions options)
Gets the file information.
|
UfsStatus[] |
PagedDoraWorker.listStatus(String path,
ListStatusPOptions options) |
UfsStatus[] |
DoraWorker.listStatus(String path,
ListStatusPOptions options)
List status from Under File System.
|
com.google.common.util.concurrent.ListenableFuture<LoadFileResponse> |
PagedDoraWorker.load(boolean loadData,
boolean skipIfExists,
List<UfsStatus> ufsStatuses,
UfsReadOptions options) |
com.google.common.util.concurrent.ListenableFuture<LoadFileResponse> |
DoraWorker.load(boolean loadData,
boolean skipIfExists,
List<UfsStatus> ufsStatuses,
UfsReadOptions options)
Loads the metadata and data of files from UFS to Alluxio.
|
protected void |
PagedDoraWorker.loadData(String ufsPath,
long mountId,
long length) |
void |
PagedDoraWorker.rename(String src,
String dst,
RenamePOptions options) |
void |
DoraWorker.rename(String src,
String dst,
RenamePOptions options)
Rename src to dst.
|
Modifier and Type | Method and Description |
---|---|
BlockReader |
S3NettyHandler.openBlock(String ufsFullPath,
long offset,
long length)
Gets a
BlockReader according the ufs full path, offset and length. |
Copyright © 2023. All Rights Reserved.