@ThreadSafe public final class RetryHandlingFileSystemMasterClient extends AbstractMasterClient implements FileSystemMasterClient
AbstractClient.RpcCallable<V>
FileSystemMasterClient.Factory
mAddress, mChannel, mClosed, mConfAddress, mConnected, mContext, mServiceVersion, mVersionService
Constructor and Description |
---|
RetryHandlingFileSystemMasterClient(MasterClientContext conf)
Creates a new
RetryHandlingFileSystemMasterClient instance. |
Modifier and Type | Method and Description |
---|---|
protected void |
afterConnect()
This method is called after the connection is made to the remote.
|
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) |
protected ServiceType |
getRemoteServiceType() |
protected String |
getServiceName() |
protected long |
getServiceVersion() |
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.
|
getAddress, getConfAddress
afterDisconnect, beforeConnect, beforeDisconnect, checkVersion, close, connect, disconnect, getRemoteServiceVersion, isClosed, isConnected, retryRPC, retryRPC
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
connect, disconnect, getAddress, getConfAddress, isClosed, isConnected
public RetryHandlingFileSystemMasterClient(MasterClientContext conf)
RetryHandlingFileSystemMasterClient
instance.conf
- master client configurationprotected ServiceType getRemoteServiceType()
getRemoteServiceType
in class AbstractClient
protected String getServiceName()
getServiceName
in class AbstractClient
protected long getServiceVersion()
getServiceVersion
in class AbstractClient
protected void afterConnect()
AbstractClient
afterConnect
in class AbstractClient
public List<AlluxioURI> checkConsistency(AlluxioURI path, CheckConsistencyPOptions options) throws AlluxioStatusException
FileSystemMasterClient
checkConsistency
in interface FileSystemMasterClient
path
- the root of the subtree to checkoptions
- method optionsAlluxioStatusException
public void createDirectory(AlluxioURI path, CreateDirectoryPOptions options) throws AlluxioStatusException
FileSystemMasterClient
createDirectory
in interface FileSystemMasterClient
path
- the directory pathoptions
- method optionsAlreadyExistsException
- if the directory already existsAlluxioStatusException
public URIStatus createFile(AlluxioURI path, CreateFilePOptions options) throws AlluxioStatusException
FileSystemMasterClient
createFile
in interface FileSystemMasterClient
path
- the file pathoptions
- method optionsAlreadyExistsException
- if the file already existsAlluxioStatusException
public void completeFile(AlluxioURI path, CompleteFilePOptions options) throws AlluxioStatusException
FileSystemMasterClient
completeFile
in interface FileSystemMasterClient
path
- the file pathoptions
- the method optionsAlluxioStatusException
public void delete(AlluxioURI path, DeletePOptions options) throws AlluxioStatusException
FileSystemMasterClient
delete
in interface FileSystemMasterClient
path
- the path to deleteoptions
- method optionsAlluxioStatusException
public void free(AlluxioURI path, FreePOptions options) throws AlluxioStatusException
FileSystemMasterClient
free
in interface FileSystemMasterClient
path
- the path to freeoptions
- method optionsNotFoundException
- if the path does not existAlluxioStatusException
public String getFilePath(long fileId) throws AlluxioStatusException
getFilePath
in interface FileSystemMasterClient
fileId
- a file idAlluxioStatusException
public URIStatus getStatus(AlluxioURI path, GetStatusPOptions options) throws AlluxioStatusException
getStatus
in interface FileSystemMasterClient
path
- the file pathoptions
- the getStatus optionsNotFoundException
- if the path does not existAlluxioStatusException
public List<SyncPointInfo> getSyncPathList() throws AlluxioStatusException
FileSystemMasterClient
getSyncPathList
in interface FileSystemMasterClient
AlluxioStatusException
public long getNewBlockIdForFile(AlluxioURI path) throws AlluxioStatusException
getNewBlockIdForFile
in interface FileSystemMasterClient
path
- the file pathAlluxioStatusException
public Map<String,MountPointInfo> getMountTable() throws AlluxioStatusException
FileSystemMasterClient
getMountTable
in interface FileSystemMasterClient
MountPointInfo
AlluxioStatusException
public List<URIStatus> listStatus(AlluxioURI path, ListStatusPOptions options) throws AlluxioStatusException
listStatus
in interface FileSystemMasterClient
path
- the path to listoptions
- the listStatus optionsNotFoundException
- if the path does not existAlluxioStatusException
public void mount(AlluxioURI alluxioPath, AlluxioURI ufsPath, MountPOptions options) throws AlluxioStatusException
FileSystemMasterClient
mount
in interface FileSystemMasterClient
alluxioPath
- the Alluxio pathufsPath
- the UFS pathoptions
- mount optionsAlluxioStatusException
public void updateMount(AlluxioURI alluxioPath, MountPOptions options) throws AlluxioStatusException
FileSystemMasterClient
updateMount
in interface FileSystemMasterClient
alluxioPath
- the Alluxio pathoptions
- mount optionsAlluxioStatusException
public void rename(AlluxioURI src, AlluxioURI dst) throws AlluxioStatusException
FileSystemMasterClient
rename
in interface FileSystemMasterClient
src
- the path to renamedst
- new file pathNotFoundException
- if the path does not existAlluxioStatusException
public void rename(AlluxioURI src, AlluxioURI dst, RenamePOptions options) throws AlluxioStatusException
FileSystemMasterClient
rename
in interface FileSystemMasterClient
src
- the path to renamedst
- new file pathoptions
- rename optionsNotFoundException
- if the path does not existAlluxioStatusException
public AlluxioURI reverseResolve(AlluxioURI ufsUri) throws AlluxioStatusException
FileSystemMasterClient
reverseResolve
in interface FileSystemMasterClient
ufsUri
- the ufs uriAlluxioStatusException
public void setAcl(AlluxioURI path, SetAclAction action, List<AclEntry> entries, SetAclPOptions options) throws AlluxioStatusException
FileSystemMasterClient
setAcl
in interface FileSystemMasterClient
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
public void setAttribute(AlluxioURI path, SetAttributePOptions options) throws AlluxioStatusException
FileSystemMasterClient
setAttribute
in interface FileSystemMasterClient
path
- the file or directory pathoptions
- the file or directory attribute options to be setNotFoundException
- if the path does not existAlluxioStatusException
public void scheduleAsyncPersist(AlluxioURI path, ScheduleAsyncPersistencePOptions options) throws AlluxioStatusException
FileSystemMasterClient
scheduleAsyncPersist
in interface FileSystemMasterClient
path
- the file pathoptions
- options to use when scheduling the persistAlluxioStatusException
public void startSync(AlluxioURI path) throws AlluxioStatusException
FileSystemMasterClient
startSync
in interface FileSystemMasterClient
path
- the file or directory to be syncedAlluxioStatusException
public void stopSync(AlluxioURI path) throws AlluxioStatusException
FileSystemMasterClient
stopSync
in interface FileSystemMasterClient
path
- the file or directory to stop syncingAlluxioStatusException
public void unmount(AlluxioURI alluxioPath) throws AlluxioStatusException
FileSystemMasterClient
unmount
in interface FileSystemMasterClient
alluxioPath
- the Alluxio pathAlluxioStatusException
public void updateUfsMode(AlluxioURI ufsUri, UpdateUfsModePOptions options) throws AlluxioStatusException
FileSystemMasterClient
updateUfsMode
in interface FileSystemMasterClient
ufsUri
- the ufs pathoptions
- the options to update ufs operation modeAlluxioStatusException
Copyright © 2023. All Rights Reserved.