public interface FileSystemMasterClient extends Client
Modifier and Type | Interface and Description |
---|---|
static class |
FileSystemMasterClient.Factory
Factory for
FileSystemMasterClient . |
Modifier and Type | Method and Description |
---|---|
List<AlluxioURI> |
checkConsistency(AlluxioURI path,
CheckConsistencyPOptions options)
Checks the consistency of Alluxio metadata against the under storage for all files and
directories in a given subtree.
|
void |
completeFile(AlluxioURI path,
CompleteFilePOptions options)
Marks a file as completed.
|
void |
createDirectory(AlluxioURI path,
CreateDirectoryPOptions options)
Creates a new directory.
|
URIStatus |
createFile(AlluxioURI path,
CreateFilePOptions options)
Creates a new file.
|
void |
delete(AlluxioURI path,
DeletePOptions options)
Deletes a file or a directory.
|
void |
free(AlluxioURI path,
FreePOptions options)
Frees a file.
|
String |
getFilePath(long fileId) |
Map<String,MountPointInfo> |
getMountTable()
Lists all mount points and their corresponding under storage addresses.
|
long |
getNewBlockIdForFile(AlluxioURI path) |
URIStatus |
getStatus(AlluxioURI path,
GetStatusPOptions options) |
List<SyncPointInfo> |
getSyncPathList()
get the list of paths that are currently being actively synced.
|
List<URIStatus> |
listStatus(AlluxioURI path,
ListStatusPOptions options) |
void |
mount(AlluxioURI alluxioPath,
AlluxioURI ufsPath,
MountPOptions options)
Mounts the given UFS path under the given Alluxio path.
|
void |
rename(AlluxioURI src,
AlluxioURI dst)
Renames a file or a directory.
|
void |
rename(AlluxioURI src,
AlluxioURI dst,
RenamePOptions options)
Renames a file or a directory.
|
AlluxioURI |
reverseResolve(AlluxioURI ufsUri)
Reverse resolve a ufs uri.
|
void |
scheduleAsyncPersist(AlluxioURI path,
ScheduleAsyncPersistencePOptions options)
Schedules the async persistence of the given file.
|
void |
setAcl(AlluxioURI path,
SetAclAction action,
List<AclEntry> entries,
SetAclPOptions options)
Sets the ACL for a path.
|
void |
setAttribute(AlluxioURI path,
SetAttributePOptions options)
Sets the file or directory attributes.
|
void |
startSync(AlluxioURI path)
Start the active syncing process for a specified path.
|
void |
stopSync(AlluxioURI path)
Stop the active syncing process for a specified path.
|
void |
unmount(AlluxioURI alluxioPath)
Unmounts the given Alluxio path.
|
void |
updateMount(AlluxioURI alluxioPath,
MountPOptions options)
Updates options of a mount point for the given Alluxio path.
|
void |
updateUfsMode(AlluxioURI ufsUri,
UpdateUfsModePOptions options)
Updates the operation mode for the given ufs path.
|
connect, disconnect, getAddress, getConfAddress, isClosed, isConnected
List<AlluxioURI> checkConsistency(AlluxioURI path, CheckConsistencyPOptions options) throws AlluxioStatusException
path
- the root of the subtree to checkoptions
- method optionsAlluxioStatusException
void createDirectory(AlluxioURI path, CreateDirectoryPOptions options) throws AlluxioStatusException
path
- the directory pathoptions
- method optionsAlreadyExistsException
- if the directory already existsAlluxioStatusException
URIStatus createFile(AlluxioURI path, CreateFilePOptions options) throws AlluxioStatusException
path
- the file pathoptions
- method optionsAlreadyExistsException
- if the file already existsAlluxioStatusException
void completeFile(AlluxioURI path, CompleteFilePOptions options) throws AlluxioStatusException
path
- the file pathoptions
- the method optionsAlluxioStatusException
void delete(AlluxioURI path, DeletePOptions options) throws AlluxioStatusException
path
- the path to deleteoptions
- method optionsAlluxioStatusException
void free(AlluxioURI path, FreePOptions options) throws AlluxioStatusException
path
- the path to freeoptions
- method optionsNotFoundException
- if the path does not existAlluxioStatusException
String getFilePath(long fileId) throws AlluxioStatusException
fileId
- a file idAlluxioStatusException
URIStatus getStatus(AlluxioURI path, GetStatusPOptions options) throws AlluxioStatusException
path
- the file pathoptions
- the getStatus optionsNotFoundException
- if the path does not existAlluxioStatusException
long getNewBlockIdForFile(AlluxioURI path) throws AlluxioStatusException
path
- the file pathAlluxioStatusException
List<SyncPointInfo> getSyncPathList() throws AlluxioStatusException
AlluxioStatusException
List<URIStatus> listStatus(AlluxioURI path, ListStatusPOptions options) throws AlluxioStatusException
path
- the path to listoptions
- the listStatus optionsNotFoundException
- if the path does not existAlluxioStatusException
void mount(AlluxioURI alluxioPath, AlluxioURI ufsPath, MountPOptions options) throws AlluxioStatusException
alluxioPath
- the Alluxio pathufsPath
- the UFS pathoptions
- mount optionsAlluxioStatusException
void updateMount(AlluxioURI alluxioPath, MountPOptions options) throws AlluxioStatusException
alluxioPath
- the Alluxio pathoptions
- mount optionsAlluxioStatusException
Map<String,MountPointInfo> getMountTable() throws AlluxioStatusException
MountPointInfo
AlluxioStatusException
void rename(AlluxioURI src, AlluxioURI dst) throws AlluxioStatusException
src
- the path to renamedst
- new file pathNotFoundException
- if the path does not existAlluxioStatusException
void rename(AlluxioURI src, AlluxioURI dst, RenamePOptions options) throws AlluxioStatusException
src
- the path to renamedst
- new file pathoptions
- rename optionsNotFoundException
- if the path does not existAlluxioStatusException
AlluxioURI reverseResolve(AlluxioURI ufsUri) throws AlluxioStatusException
ufsUri
- the ufs uriAlluxioStatusException
void setAcl(AlluxioURI path, SetAclAction action, List<AclEntry> entries, SetAclPOptions options) throws AlluxioStatusException
path
- the file or directory pathaction
- the set action to performentries
- the ACL entries to useoptions
- the options for setting ACLNotFoundException
- if the path does not existAlluxioStatusException
void setAttribute(AlluxioURI path, SetAttributePOptions options) throws AlluxioStatusException
path
- the file or directory pathoptions
- the file or directory attribute options to be setNotFoundException
- if the path does not existAlluxioStatusException
void startSync(AlluxioURI path) throws AlluxioStatusException
path
- the file or directory to be syncedAlluxioStatusException
void stopSync(AlluxioURI path) throws AlluxioStatusException
path
- the file or directory to stop syncingAlluxioStatusException
void scheduleAsyncPersist(AlluxioURI path, ScheduleAsyncPersistencePOptions options) throws AlluxioStatusException
path
- the file pathoptions
- options to use when scheduling the persistAlluxioStatusException
void unmount(AlluxioURI alluxioPath) throws AlluxioStatusException
alluxioPath
- the Alluxio pathAlluxioStatusException
void updateUfsMode(AlluxioURI ufsUri, UpdateUfsModePOptions options) throws AlluxioStatusException
ufsUri
- the ufs pathoptions
- the options to update ufs operation modeAlluxioStatusException
Copyright © 2023. All Rights Reserved.