alluxio.client.file

Interface FileSystemMasterClient

All Superinterfaces:

AutoCloseable, alluxio.Client, Closeable

All Known Implementing Classes:

RetryHandlingFileSystemMasterClient

public interface FileSystemMasterClient
extends alluxio.Client

A client to use for interacting with a file system master.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	FileSystemMasterClient.Factory Factory for FileSystemMasterClient.

Method Summary

Modifier and Type	Method and Description
List<alluxio.AlluxioURI>	checkConsistency(alluxio.AlluxioURI path, alluxio.grpc.CheckConsistencyPOptions options) Checks the consistency of Alluxio metadata against the under storage for all files and directories in a given subtree.
void	completeFile(alluxio.AlluxioURI path, alluxio.grpc.CompleteFilePOptions options) Marks a file as completed.
void	createDirectory(alluxio.AlluxioURI path, alluxio.grpc.CreateDirectoryPOptions options) Creates a new directory.
alluxio.client.file.URIStatus	createFile(alluxio.AlluxioURI path, alluxio.grpc.CreateFilePOptions options) Creates a new file.
void	delete(alluxio.AlluxioURI path, alluxio.grpc.DeletePOptions options) Deletes a file or a directory.
void	free(alluxio.AlluxioURI path, alluxio.grpc.FreePOptions options) Frees a file.
String	getFilePath(long fileId)
Map<String,alluxio.wire.MountPointInfo>	getMountTable() Lists all mount points and their corresponding under storage addresses.
long	getNewBlockIdForFile(alluxio.AlluxioURI path)
alluxio.client.file.URIStatus	getStatus(alluxio.AlluxioURI path, alluxio.grpc.GetStatusPOptions options)
List<alluxio.wire.SyncPointInfo>	getSyncPathList() get the list of paths that are currently being actively synced.
List<alluxio.client.file.URIStatus>	listStatus(alluxio.AlluxioURI path, alluxio.grpc.ListStatusPOptions options)
void	mount(alluxio.AlluxioURI alluxioPath, alluxio.AlluxioURI ufsPath, alluxio.grpc.MountPOptions options) Mounts the given UFS path under the given Alluxio path.
void	rename(alluxio.AlluxioURI src, alluxio.AlluxioURI dst) Renames a file or a directory.
void	rename(alluxio.AlluxioURI src, alluxio.AlluxioURI dst, alluxio.grpc.RenamePOptions options) Renames a file or a directory.
void	scheduleAsyncPersist(alluxio.AlluxioURI path, alluxio.grpc.ScheduleAsyncPersistencePOptions options) Schedules the async persistence of the given file.
void	setAcl(alluxio.AlluxioURI path, alluxio.grpc.SetAclAction action, List<alluxio.security.authorization.AclEntry> entries, alluxio.grpc.SetAclPOptions options) Sets the ACL for a path.
void	setAttribute(alluxio.AlluxioURI path, alluxio.grpc.SetAttributePOptions options) Sets the file or directory attributes.
void	startSync(alluxio.AlluxioURI path) Start the active syncing process for a specified path.
void	stopSync(alluxio.AlluxioURI path) Stop the active syncing process for a specified path.
void	unmount(alluxio.AlluxioURI alluxioPath) Unmounts the given Alluxio path.
void	updateMount(alluxio.AlluxioURI alluxioPath, alluxio.grpc.MountPOptions options) Updates options of a mount point for the given Alluxio path.
void	updateUfsMode(alluxio.AlluxioURI ufsUri, alluxio.grpc.UpdateUfsModePOptions options) Updates the operation mode for the given ufs path.

Methods inherited from interface alluxio.Client

connect, disconnect, getAddress, isClosed, isConnected

Methods inherited from interface java.io.Closeable

close

Method Detail

checkConsistency

List<alluxio.AlluxioURI> checkConsistency(alluxio.AlluxioURI path,
                                          alluxio.grpc.CheckConsistencyPOptions options)
                                   throws alluxio.exception.status.AlluxioStatusException

Checks the consistency of Alluxio metadata against the under storage for all files and directories in a given subtree.

Parameters:

path - the root of the subtree to check

options - method options

Returns:

a list of inconsistent files and directories

Throws:

alluxio.exception.status.AlluxioStatusException

createDirectory

void createDirectory(alluxio.AlluxioURI path,
                     alluxio.grpc.CreateDirectoryPOptions options)
              throws alluxio.exception.status.AlluxioStatusException

Creates a new directory.

Parameters:

path - the directory path

options - method options

Throws:

alluxio.exception.status.AlreadyExistsException - if the directory already exists

alluxio.exception.status.AlluxioStatusException

createFile

alluxio.client.file.URIStatus createFile(alluxio.AlluxioURI path,
                                         alluxio.grpc.CreateFilePOptions options)
                                  throws alluxio.exception.status.AlluxioStatusException

Creates a new file.

Parameters:

path - the file path

options - method options

Returns:

the uri status of the newly created file

Throws:

alluxio.exception.status.AlreadyExistsException - if the file already exists

alluxio.exception.status.AlluxioStatusException

completeFile

void completeFile(alluxio.AlluxioURI path,
                  alluxio.grpc.CompleteFilePOptions options)
           throws alluxio.exception.status.AlluxioStatusException

Marks a file as completed.

Parameters:

path - the file path

options - the method options

Throws:

alluxio.exception.status.AlluxioStatusException

delete

void delete(alluxio.AlluxioURI path,
            alluxio.grpc.DeletePOptions options)
     throws alluxio.exception.status.AlluxioStatusException

Deletes a file or a directory.

Parameters:

path - the path to delete

options - method options

Throws:

alluxio.exception.status.AlluxioStatusException

free

void free(alluxio.AlluxioURI path,
          alluxio.grpc.FreePOptions options)
   throws alluxio.exception.status.AlluxioStatusException

Frees a file.

Parameters:

path - the path to free

options - method options

Throws:

alluxio.exception.status.NotFoundException - if the path does not exist

alluxio.exception.status.AlluxioStatusException

getFilePath

String getFilePath(long fileId)
            throws alluxio.exception.status.AlluxioStatusException

Parameters:

fileId - a file id

Returns:

the file path for the given file id

Throws:

alluxio.exception.status.AlluxioStatusException

getStatus

alluxio.client.file.URIStatus getStatus(alluxio.AlluxioURI path,
                                        alluxio.grpc.GetStatusPOptions options)
                                 throws alluxio.exception.status.AlluxioStatusException

Parameters:

path - the file path

options - the getStatus options

Returns:

the file info for the given file id

Throws:

alluxio.exception.status.NotFoundException - if the path does not exist

alluxio.exception.status.AlluxioStatusException

getNewBlockIdForFile

long getNewBlockIdForFile(alluxio.AlluxioURI path)
                   throws alluxio.exception.status.AlluxioStatusException

Parameters:

path - the file path

Returns:

the next blockId for the file

Throws:

alluxio.exception.status.AlluxioStatusException

getSyncPathList

List<alluxio.wire.SyncPointInfo> getSyncPathList()
                                          throws alluxio.exception.status.AlluxioStatusException

get the list of paths that are currently being actively synced.

Returns:

the list of paths

Throws:

alluxio.exception.status.AlluxioStatusException

listStatus

List<alluxio.client.file.URIStatus> listStatus(alluxio.AlluxioURI path,
                                               alluxio.grpc.ListStatusPOptions options)
                                        throws alluxio.exception.status.AlluxioStatusException

Parameters:

path - the path to list

options - the listStatus options

Returns:

the list of file information for the given path

Throws:

alluxio.exception.status.NotFoundException - if the path does not exist

alluxio.exception.status.AlluxioStatusException

mount

void mount(alluxio.AlluxioURI alluxioPath,
           alluxio.AlluxioURI ufsPath,
           alluxio.grpc.MountPOptions options)
    throws alluxio.exception.status.AlluxioStatusException

Mounts the given UFS path under the given Alluxio path.

Parameters:

alluxioPath - the Alluxio path

ufsPath - the UFS path

options - mount options

Throws:

alluxio.exception.status.AlluxioStatusException

updateMount

void updateMount(alluxio.AlluxioURI alluxioPath,
                 alluxio.grpc.MountPOptions options)
          throws alluxio.exception.status.AlluxioStatusException

Updates options of a mount point for the given Alluxio path.

Parameters:

alluxioPath - the Alluxio path

options - mount options

Throws:

alluxio.exception.status.AlluxioStatusException

getMountTable

Map<String,alluxio.wire.MountPointInfo> getMountTable()
                                               throws alluxio.exception.status.AlluxioStatusException

Lists all mount points and their corresponding under storage addresses.

Returns:

a map from String to MountPointInfo

Throws:

alluxio.exception.status.AlluxioStatusException

rename

void rename(alluxio.AlluxioURI src,
            alluxio.AlluxioURI dst)
     throws alluxio.exception.status.AlluxioStatusException

Renames a file or a directory.

Parameters:

src - the path to rename

dst - new file path

Throws:

alluxio.exception.status.NotFoundException - if the path does not exist

alluxio.exception.status.AlluxioStatusException

rename

void rename(alluxio.AlluxioURI src,
            alluxio.AlluxioURI dst,
            alluxio.grpc.RenamePOptions options)
     throws alluxio.exception.status.AlluxioStatusException

Renames a file or a directory.

Parameters:

src - the path to rename

dst - new file path

options - rename options

Throws:

alluxio.exception.status.NotFoundException - if the path does not exist

alluxio.exception.status.AlluxioStatusException

setAcl

void setAcl(alluxio.AlluxioURI path,
            alluxio.grpc.SetAclAction action,
            List<alluxio.security.authorization.AclEntry> entries,
            alluxio.grpc.SetAclPOptions options)
     throws alluxio.exception.status.AlluxioStatusException

Sets the ACL for a path.

Parameters:

path - the file or directory path

action - the set action to perform

entries - the ACL entries to use

options - the options for setting ACL

Throws:

alluxio.exception.status.NotFoundException - if the path does not exist

alluxio.exception.status.AlluxioStatusException

setAttribute

void setAttribute(alluxio.AlluxioURI path,
                  alluxio.grpc.SetAttributePOptions options)
           throws alluxio.exception.status.AlluxioStatusException

Sets the file or directory attributes.

Parameters:

path - the file or directory path

options - the file or directory attribute options to be set

Throws:

alluxio.exception.status.NotFoundException - if the path does not exist

alluxio.exception.status.AlluxioStatusException

startSync

void startSync(alluxio.AlluxioURI path)
        throws alluxio.exception.status.AlluxioStatusException

Start the active syncing process for a specified path.

Parameters:

path - the file or directory to be synced

Throws:

alluxio.exception.status.AlluxioStatusException

stopSync

void stopSync(alluxio.AlluxioURI path)
       throws alluxio.exception.status.AlluxioStatusException

Stop the active syncing process for a specified path.

Parameters:

path - the file or directory to stop syncing

Throws:

alluxio.exception.status.AlluxioStatusException

scheduleAsyncPersist

void scheduleAsyncPersist(alluxio.AlluxioURI path,
                          alluxio.grpc.ScheduleAsyncPersistencePOptions options)
                   throws alluxio.exception.status.AlluxioStatusException

Schedules the async persistence of the given file.

Parameters:

path - the file path

options - options to use when scheduling the persist

Throws:

alluxio.exception.status.AlluxioStatusException

unmount

void unmount(alluxio.AlluxioURI alluxioPath)
      throws alluxio.exception.status.AlluxioStatusException

Unmounts the given Alluxio path.

Parameters:

alluxioPath - the Alluxio path

Throws:

alluxio.exception.status.AlluxioStatusException

updateUfsMode

void updateUfsMode(alluxio.AlluxioURI ufsUri,
                   alluxio.grpc.UpdateUfsModePOptions options)
            throws alluxio.exception.status.AlluxioStatusException

Updates the operation mode for the given ufs path. The path is required to be the scheme and authority only. For example, to update the mode for under storage at hdfs://ns/folder1 specify the argument as hdfs://ns/. Note: the mode for any other mounted under storage which shares the prefix (such as hdfs://ns/folder2) is also updated.

Parameters:

ufsUri - the ufs path

options - the options to update ufs operation mode

Throws:

alluxio.exception.status.AlluxioStatusException