alluxio.client.file

Interface FileSystem

All Superinterfaces:

AutoCloseable, Closeable

All Known Implementing Classes:

BaseFileSystem

@PublicApi
public interface FileSystem
extends Closeable

Basic file system interface supporting metadata operations and data operations. Developers should not implement this class but extend the default implementation provided by BaseFileSystem instead. This ensures any new methods added to the interface will be provided by the default implementation.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	FileSystem.Cache A cache for storing FileSystem clients.
static class	FileSystem.Factory Factory for FileSystem.
static class	FileSystem.FileSystemKey A key which can be used to look up a FileSystem instance in the FileSystem.Cache.

Method Summary

Modifier and Type	Method and Description
void	createDirectory(alluxio.AlluxioURI path) Convenience method for createDirectory(AlluxioURI, CreateDirectoryPOptions) with default options.
void	createDirectory(alluxio.AlluxioURI path, alluxio.grpc.CreateDirectoryPOptions options) Creates a directory.
FileOutStream	createFile(alluxio.AlluxioURI path) Convenience method for createFile(AlluxioURI, CreateFilePOptions) with default options.
FileOutStream	createFile(alluxio.AlluxioURI path, alluxio.grpc.CreateFilePOptions options) Creates a file.
void	delete(alluxio.AlluxioURI path) Convenience method for delete(AlluxioURI, DeletePOptions) with default options.
void	delete(alluxio.AlluxioURI path, alluxio.grpc.DeletePOptions options) Deletes a file or a directory.
boolean	exists(alluxio.AlluxioURI path) Convenience method for exists(AlluxioURI, ExistsPOptions) with default options.
boolean	exists(alluxio.AlluxioURI path, alluxio.grpc.ExistsPOptions options) Checks whether a path exists in Alluxio space.
void	free(alluxio.AlluxioURI path) Convenience method for free(AlluxioURI, FreePOptions) with default options.
void	free(alluxio.AlluxioURI path, alluxio.grpc.FreePOptions options) Evicts any data under the given path from Alluxio space, but does not delete the data from the UFS.
List<alluxio.wire.BlockLocationInfo>	getBlockLocations(alluxio.AlluxioURI path) Builds a list of BlockLocationInfo for the given file.
alluxio.conf.AlluxioConfiguration	getConf()
Map<String,alluxio.wire.MountPointInfo>	getMountTable() Lists all mount points and their corresponding under storage addresses.
alluxio.client.file.URIStatus	getStatus(alluxio.AlluxioURI path) Convenience method for getStatus(AlluxioURI, GetStatusPOptions) with default options.
alluxio.client.file.URIStatus	getStatus(alluxio.AlluxioURI path, alluxio.grpc.GetStatusPOptions options) Gets the URIStatus object that represents the metadata of an Alluxio path.
List<alluxio.wire.SyncPointInfo>	getSyncPathList() Lists all the actively synced paths.
boolean	isClosed() If there are operations currently running and close is called concurrently the behavior is undefined.
List<alluxio.client.file.URIStatus>	listStatus(alluxio.AlluxioURI path) Convenience method for listStatus(AlluxioURI, ListStatusPOptions) with default options.
List<alluxio.client.file.URIStatus>	listStatus(alluxio.AlluxioURI path, alluxio.grpc.ListStatusPOptions options) If the path is a directory, returns the URIStatus of all the direct entries in it.
void	mount(alluxio.AlluxioURI alluxioPath, alluxio.AlluxioURI ufsPath) Convenience method for mount(AlluxioURI, AlluxioURI, MountPOptions) with default options.
void	mount(alluxio.AlluxioURI alluxioPath, alluxio.AlluxioURI ufsPath, alluxio.grpc.MountPOptions options) Mounts a UFS subtree to the given Alluxio path.
FileInStream	openFile(alluxio.AlluxioURI path) Convenience method for openFile(AlluxioURI, OpenFilePOptions) with default options.
FileInStream	openFile(alluxio.AlluxioURI path, alluxio.grpc.OpenFilePOptions options) Opens a file for reading.
void	persist(alluxio.AlluxioURI path) Convenience method for persist(AlluxioURI, ScheduleAsyncPersistencePOptions) which uses the default ScheduleAsyncPersistencePOptions.
void	persist(alluxio.AlluxioURI path, alluxio.grpc.ScheduleAsyncPersistencePOptions options) Schedules the given path to be asynchronously persisted to the under file system.
void	rename(alluxio.AlluxioURI src, alluxio.AlluxioURI dst) Convenience method for rename(AlluxioURI, AlluxioURI, RenamePOptions) with default options.
void	rename(alluxio.AlluxioURI src, alluxio.AlluxioURI dst, alluxio.grpc.RenamePOptions options) Renames an existing Alluxio path to another Alluxio path in Alluxio.
void	setAcl(alluxio.AlluxioURI path, alluxio.grpc.SetAclAction action, List<alluxio.security.authorization.AclEntry> entries) Convenience method for setAcl(AlluxioURI, SetAclAction, List, SetAclPOptions) with default options.
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) Convenience method for setAttribute(AlluxioURI, SetAttributePOptions) with default options.
void	setAttribute(alluxio.AlluxioURI path, alluxio.grpc.SetAttributePOptions options) Sets any number of a path's attributes, such as TTL and pin status.
void	startSync(alluxio.AlluxioURI path) Starts the active syncing process on an Alluxio path.
void	stopSync(alluxio.AlluxioURI path) Stops the active syncing process on an Alluxio path.
void	unmount(alluxio.AlluxioURI path) Convenience method for unmount(AlluxioURI, UnmountPOptions) with default options.
void	unmount(alluxio.AlluxioURI path, alluxio.grpc.UnmountPOptions options) Unmounts a UFS subtree identified by the given Alluxio path.
void	updateMount(alluxio.AlluxioURI alluxioPath, alluxio.grpc.MountPOptions options) Updates the options for an existing mount point.

Methods inherited from interface java.io.Closeable

close

Method Detail

isClosed

boolean isClosed()

If there are operations currently running and close is called concurrently the behavior is undefined. After closing a FileSystem, any operations that are performed result in undefined behavior.

Returns:

whether or not this FileSystem has been closed

createDirectory

void createDirectory(alluxio.AlluxioURI path)
              throws alluxio.exception.FileAlreadyExistsException,
                     alluxio.exception.InvalidPathException,
                     IOException,
                     alluxio.exception.AlluxioException

Convenience method for createDirectory(AlluxioURI, CreateDirectoryPOptions) with default options.

Parameters:

path - the path of the directory to create in Alluxio space

Throws:

alluxio.exception.FileAlreadyExistsException - if there is already a file or directory at the given path

alluxio.exception.InvalidPathException - if the path is invalid

IOException

alluxio.exception.AlluxioException

createDirectory

void createDirectory(alluxio.AlluxioURI path,
                     alluxio.grpc.CreateDirectoryPOptions options)
              throws alluxio.exception.FileAlreadyExistsException,
                     alluxio.exception.InvalidPathException,
                     IOException,
                     alluxio.exception.AlluxioException

Creates a directory.

Parameters:

path - the path of the directory to create in Alluxio space

options - options to associate with this operation

Throws:

alluxio.exception.FileAlreadyExistsException - if there is already a file or directory at the given path

alluxio.exception.InvalidPathException - if the path is invalid

IOException

alluxio.exception.AlluxioException

createFile

FileOutStream createFile(alluxio.AlluxioURI path)
                  throws alluxio.exception.FileAlreadyExistsException,
                         alluxio.exception.InvalidPathException,
                         IOException,
                         alluxio.exception.AlluxioException

Convenience method for createFile(AlluxioURI, CreateFilePOptions) with default options.

Parameters:

path - the path of the file to create in Alluxio space

Returns:

a FileOutStream which will write data to the newly created file

Throws:

alluxio.exception.FileAlreadyExistsException - if there is already a file at the given path

alluxio.exception.InvalidPathException - if the path is invalid

IOException

alluxio.exception.AlluxioException

createFile

FileOutStream createFile(alluxio.AlluxioURI path,
                         alluxio.grpc.CreateFilePOptions options)
                  throws alluxio.exception.FileAlreadyExistsException,
                         alluxio.exception.InvalidPathException,
                         IOException,
                         alluxio.exception.AlluxioException

Creates a file.

Parameters:

path - the path of the file to create in Alluxio space

options - options to associate with this operation

Returns:

a FileOutStream which will write data to the newly created file

Throws:

alluxio.exception.FileAlreadyExistsException - if there is already a file at the given path

alluxio.exception.InvalidPathException - if the path is invalid

IOException

alluxio.exception.AlluxioException

delete

void delete(alluxio.AlluxioURI path)
     throws alluxio.exception.DirectoryNotEmptyException,
            alluxio.exception.FileDoesNotExistException,
            IOException,
            alluxio.exception.AlluxioException

Convenience method for delete(AlluxioURI, DeletePOptions) with default options.

Parameters:

path - the path to delete in Alluxio space

Throws:

alluxio.exception.FileDoesNotExistException - if the given path does not exist

alluxio.exception.DirectoryNotEmptyException - if recursive is false and the path is a nonempty directory

IOException

alluxio.exception.AlluxioException

delete

void delete(alluxio.AlluxioURI path,
            alluxio.grpc.DeletePOptions options)
     throws alluxio.exception.DirectoryNotEmptyException,
            alluxio.exception.FileDoesNotExistException,
            IOException,
            alluxio.exception.AlluxioException

Deletes a file or a directory.

Parameters:

path - the path to delete in Alluxio space

options - options to associate with this operation

Throws:

alluxio.exception.FileDoesNotExistException - if the given path does not exist

alluxio.exception.DirectoryNotEmptyException - if recursive is false and the path is a nonempty directory

IOException

alluxio.exception.AlluxioException

exists

boolean exists(alluxio.AlluxioURI path)
        throws alluxio.exception.InvalidPathException,
               IOException,
               alluxio.exception.AlluxioException

Convenience method for exists(AlluxioURI, ExistsPOptions) with default options.

Parameters:

path - the path in question

Returns:

true if the path exists, false otherwise

Throws:

alluxio.exception.InvalidPathException - if the path is invalid

IOException

alluxio.exception.AlluxioException

exists

boolean exists(alluxio.AlluxioURI path,
               alluxio.grpc.ExistsPOptions options)
        throws alluxio.exception.InvalidPathException,
               IOException,
               alluxio.exception.AlluxioException

Checks whether a path exists in Alluxio space.

Parameters:

path - the path in question

options - options to associate with this operation

Returns:

true if the path exists, false otherwise

Throws:

alluxio.exception.InvalidPathException - if the path is invalid

IOException

alluxio.exception.AlluxioException

free

void free(alluxio.AlluxioURI path)
   throws alluxio.exception.FileDoesNotExistException,
          IOException,
          alluxio.exception.AlluxioException

Convenience method for free(AlluxioURI, FreePOptions) with default options.

Parameters:

path - the path to free in Alluxio space

Throws:

alluxio.exception.FileDoesNotExistException - if the given path does not exist

IOException

alluxio.exception.AlluxioException

free

void free(alluxio.AlluxioURI path,
          alluxio.grpc.FreePOptions options)
   throws alluxio.exception.FileDoesNotExistException,
          IOException,
          alluxio.exception.AlluxioException

Evicts any data under the given path from Alluxio space, but does not delete the data from the UFS. The metadata will still be present in Alluxio space after this operation.

Parameters:

path - the path to free in Alluxio space

options - options to associate with this operation

Throws:

alluxio.exception.FileDoesNotExistException - if the given path does not exist

IOException

alluxio.exception.AlluxioException

getBlockLocations

List<alluxio.wire.BlockLocationInfo> getBlockLocations(alluxio.AlluxioURI path)
                                                throws alluxio.exception.FileDoesNotExistException,
                                                       IOException,
                                                       alluxio.exception.AlluxioException

Builds a list of BlockLocationInfo for the given file. Each list item contains a list of WorkerNetAddress which allows a user to determine the physical location of a block of the given file stored within Alluxio. In the case where data is stored in a UFS, but not in Alluxio this function will only include a WorkerNetAddress if the block stored in the UFS is co-located with an Alluxio worker. However if there are no co-located Alluxio workers for the block, then the behavior is controlled by the PropertyKey.USER_UFS_BLOCK_LOCATION_ALL_FALLBACK_ENABLED . If this property is set to true then every Alluxio worker will be returned. Blocks which are stored in the UFS and are *not* co-located with any Alluxio worker will return an empty list. If the file block is within Alluxio *and* the UFS then this will only return Alluxio workers which currently store the block.

Parameters:

path - the path to get block info for

Returns:

a list of blocks with the workers whose hosts have the blocks. The blocks may not necessarily be stored in Alluxio. The blocks are returned in the order of their sequences in file.

Throws:

alluxio.exception.FileDoesNotExistException - if the given path does not exist

IOException

alluxio.exception.AlluxioException

getConf

alluxio.conf.AlluxioConfiguration getConf()

Returns:

the configuration which the FileSystem is using to connect to Alluxio

getStatus

alluxio.client.file.URIStatus getStatus(alluxio.AlluxioURI path)
                                 throws alluxio.exception.FileDoesNotExistException,
                                        IOException,
                                        alluxio.exception.AlluxioException

Convenience method for getStatus(AlluxioURI, GetStatusPOptions) with default options.

Parameters:

path - the path to obtain information about

Returns:

the URIStatus of the file

Throws:

alluxio.exception.FileDoesNotExistException - if the path does not exist

IOException

alluxio.exception.AlluxioException

getStatus

alluxio.client.file.URIStatus getStatus(alluxio.AlluxioURI path,
                                        alluxio.grpc.GetStatusPOptions options)
                                 throws alluxio.exception.FileDoesNotExistException,
                                        IOException,
                                        alluxio.exception.AlluxioException

Gets the URIStatus object that represents the metadata of an Alluxio path.

Parameters:

path - the path to obtain information about

options - options to associate with this operation

Returns:

the URIStatus of the file

Throws:

alluxio.exception.FileDoesNotExistException - if the path does not exist

IOException

alluxio.exception.AlluxioException

listStatus

List<alluxio.client.file.URIStatus> listStatus(alluxio.AlluxioURI path)
                                        throws alluxio.exception.FileDoesNotExistException,
                                               IOException,
                                               alluxio.exception.AlluxioException

Convenience method for listStatus(AlluxioURI, ListStatusPOptions) with default options.

Parameters:

path - the path to list information about

Returns:

a list of URIStatuss containing information about the files and directories which are children of the given path

Throws:

alluxio.exception.FileDoesNotExistException - if the given path does not exist

IOException

alluxio.exception.AlluxioException

listStatus

List<alluxio.client.file.URIStatus> listStatus(alluxio.AlluxioURI path,
                                               alluxio.grpc.ListStatusPOptions options)
                                        throws alluxio.exception.FileDoesNotExistException,
                                               IOException,
                                               alluxio.exception.AlluxioException

If the path is a directory, returns the URIStatus of all the direct entries in it. Otherwise returns a list with a single URIStatus element for the file.

Parameters:

path - the path to list information about

options - options to associate with this operation

Returns:

a list of URIStatuss containing information about the files and directories which are children of the given path

Throws:

alluxio.exception.FileDoesNotExistException - if the given path does not exist

IOException

alluxio.exception.AlluxioException

mount

void mount(alluxio.AlluxioURI alluxioPath,
           alluxio.AlluxioURI ufsPath)
    throws IOException,
           alluxio.exception.AlluxioException

Convenience method for mount(AlluxioURI, AlluxioURI, MountPOptions) with default options.

Parameters:

alluxioPath - an Alluxio path to mount the data to

ufsPath - a UFS path to mount the data from

Throws:

IOException

alluxio.exception.AlluxioException

mount

void mount(alluxio.AlluxioURI alluxioPath,
           alluxio.AlluxioURI ufsPath,
           alluxio.grpc.MountPOptions options)
    throws IOException,
           alluxio.exception.AlluxioException

Mounts a UFS subtree to the given Alluxio path. The Alluxio path is expected not to exist as the method creates it. If the path already exists, a AlluxioException will be thrown. This method does not transfer any data or metadata from the UFS. It simply establishes the connection between the given Alluxio path and UFS path.

Parameters:

alluxioPath - an Alluxio path to mount the data to

ufsPath - a UFS path to mount the data from

options - options to associate with this operation

Throws:

IOException

alluxio.exception.AlluxioException

updateMount

void updateMount(alluxio.AlluxioURI alluxioPath,
                 alluxio.grpc.MountPOptions options)
          throws IOException,
                 alluxio.exception.AlluxioException

Updates the options for an existing mount point.

Parameters:

alluxioPath - the Alluxio path of the mount point

options - options for this mount point

Throws:

IOException

alluxio.exception.AlluxioException

getMountTable

Map<String,alluxio.wire.MountPointInfo> getMountTable()
                                               throws IOException,
                                                      alluxio.exception.AlluxioException

Lists all mount points and their corresponding under storage addresses.

Returns:

a map from String to MountPointInfo

Throws:

IOException

alluxio.exception.AlluxioException

getSyncPathList

List<alluxio.wire.SyncPointInfo> getSyncPathList()
                                          throws IOException,
                                                 alluxio.exception.AlluxioException

Lists all the actively synced paths.

Returns:

a list of actively synced paths

Throws:

IOException

alluxio.exception.AlluxioException

openFile

FileInStream openFile(alluxio.AlluxioURI path)
               throws alluxio.exception.FileDoesNotExistException,
                      IOException,
                      alluxio.exception.AlluxioException

Convenience method for openFile(AlluxioURI, OpenFilePOptions) with default options.

Parameters:

path - the file to read from

Returns:

a FileInStream for the given path

Throws:

alluxio.exception.FileDoesNotExistException - if the given file does not exist

IOException

alluxio.exception.AlluxioException

openFile

FileInStream openFile(alluxio.AlluxioURI path,
                      alluxio.grpc.OpenFilePOptions options)
               throws alluxio.exception.FileDoesNotExistException,
                      IOException,
                      alluxio.exception.AlluxioException

Opens a file for reading.

Parameters:

path - the file to read from

options - options to associate with this operation

Returns:

a FileInStream for the given path

Throws:

alluxio.exception.FileDoesNotExistException - if the given file does not exist

IOException

alluxio.exception.AlluxioException

persist

void persist(alluxio.AlluxioURI path)
      throws alluxio.exception.FileDoesNotExistException,
             IOException,
             alluxio.exception.AlluxioException

Convenience method for persist(AlluxioURI, ScheduleAsyncPersistencePOptions) which uses the default ScheduleAsyncPersistencePOptions.

Parameters:

path - the uri of the file to persist

Throws:

alluxio.exception.FileDoesNotExistException

IOException

alluxio.exception.AlluxioException

persist

void persist(alluxio.AlluxioURI path,
             alluxio.grpc.ScheduleAsyncPersistencePOptions options)
      throws alluxio.exception.FileDoesNotExistException,
             IOException,
             alluxio.exception.AlluxioException

Schedules the given path to be asynchronously persisted to the under file system. To persist synchronously please see FileSystemUtils#persistAndWait(FileSystem, AlluxioURI).

Parameters:

path - the uri of the file to persist

options - the options to use when submitting persist the path

Throws:

alluxio.exception.FileDoesNotExistException

IOException

alluxio.exception.AlluxioException

rename

void rename(alluxio.AlluxioURI src,
            alluxio.AlluxioURI dst)
     throws alluxio.exception.FileDoesNotExistException,
            IOException,
            alluxio.exception.AlluxioException

Convenience method for rename(AlluxioURI, AlluxioURI, RenamePOptions) with default options.

Parameters:

src - the path of the source, this must already exist

dst - the path of the destination, this path should not exist

Throws:

alluxio.exception.FileDoesNotExistException - if the given file does not exist

IOException

alluxio.exception.AlluxioException

rename

void rename(alluxio.AlluxioURI src,
            alluxio.AlluxioURI dst,
            alluxio.grpc.RenamePOptions options)
     throws alluxio.exception.FileDoesNotExistException,
            IOException,
            alluxio.exception.AlluxioException

Renames an existing Alluxio path to another Alluxio path in Alluxio. This operation will be propagated in the underlying storage if the path is persisted.

Parameters:

src - the path of the source, this must already exist

dst - the path of the destination, this path should not exist

options - options to associate with this operation

Throws:

alluxio.exception.FileDoesNotExistException - if the given file does not exist

IOException

alluxio.exception.AlluxioException

setAcl

void setAcl(alluxio.AlluxioURI path,
            alluxio.grpc.SetAclAction action,
            List<alluxio.security.authorization.AclEntry> entries)
     throws alluxio.exception.FileDoesNotExistException,
            IOException,
            alluxio.exception.AlluxioException

Convenience method for setAcl(AlluxioURI, SetAclAction, List, SetAclPOptions) with default options.

Parameters:

path - the path to set the ACL for

action - the set action to perform

entries - the ACL entries

Throws:

alluxio.exception.FileDoesNotExistException - if the given file does not exist

IOException

alluxio.exception.AlluxioException

setAcl

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

Sets the ACL for a path.

Parameters:

path - the path to set the ACL for

action - the set action to perform

entries - the ACL entries

options - options to associate with this operation

Throws:

alluxio.exception.FileDoesNotExistException - if the given file does not exist

IOException

alluxio.exception.AlluxioException

startSync

void startSync(alluxio.AlluxioURI path)
        throws alluxio.exception.FileDoesNotExistException,
               IOException,
               alluxio.exception.AlluxioException

Starts the active syncing process on an Alluxio path.

Parameters:

path - the path to sync

Throws:

alluxio.exception.FileDoesNotExistException

IOException

alluxio.exception.AlluxioException

stopSync

void stopSync(alluxio.AlluxioURI path)
       throws alluxio.exception.FileDoesNotExistException,
              IOException,
              alluxio.exception.AlluxioException

Stops the active syncing process on an Alluxio path.

Parameters:

path - the path to stop syncing

Throws:

alluxio.exception.FileDoesNotExistException

IOException

alluxio.exception.AlluxioException

setAttribute

void setAttribute(alluxio.AlluxioURI path)
           throws alluxio.exception.FileDoesNotExistException,
                  IOException,
                  alluxio.exception.AlluxioException

Convenience method for setAttribute(AlluxioURI, SetAttributePOptions) with default options.

Parameters:

path - the path to set attributes for

Throws:

alluxio.exception.FileDoesNotExistException - if the given file does not exist

IOException

alluxio.exception.AlluxioException

setAttribute

void setAttribute(alluxio.AlluxioURI path,
                  alluxio.grpc.SetAttributePOptions options)
           throws alluxio.exception.FileDoesNotExistException,
                  IOException,
                  alluxio.exception.AlluxioException

Sets any number of a path's attributes, such as TTL and pin status.

Parameters:

path - the path to set attributes for

options - options to associate with this operation

Throws:

alluxio.exception.FileDoesNotExistException - if the given file does not exist

IOException

alluxio.exception.AlluxioException

unmount

void unmount(alluxio.AlluxioURI path)
      throws IOException,
             alluxio.exception.AlluxioException

Convenience method for unmount(AlluxioURI, UnmountPOptions) with default options.

Parameters:

path - an Alluxio path, this must be a mount point

Throws:

IOException

alluxio.exception.AlluxioException

unmount

void unmount(alluxio.AlluxioURI path,
             alluxio.grpc.UnmountPOptions options)
      throws IOException,
             alluxio.exception.AlluxioException

Unmounts a UFS subtree identified by the given Alluxio path. The Alluxio path match a previously mounted path. The contents of the subtree rooted at this path are removed from Alluxio but the corresponding UFS subtree is left untouched.

Parameters:

path - an Alluxio path, this must be a mount point

options - options to associate with this operation

Throws:

IOException

alluxio.exception.AlluxioException