Uses of Interface
alluxio.client.file.FileSystem

Packages that use FileSystem

Package	Description
alluxio.cli
alluxio.cli.command
alluxio.cli.command.metadatacache
alluxio.cli.fs
alluxio.cli.fs.command
alluxio.client.file
alluxio.client.file.cache
alluxio.client.file.ufs
alluxio.examples
alluxio.fuse
alluxio.fuse.auth
alluxio.fuse.file
alluxio.hadoop
alluxio.job
alluxio.master
alluxio.master.backcompat
alluxio.master.backcompat.ops
alluxio.master.job
alluxio.master.job.metrics
alluxio.master.job.tracker
alluxio.multi.process
alluxio.proxy.s3
alluxio.stress.cli
alluxio.stress.cli.client
alluxio.table.common.udb

Uses of FileSystem in alluxio.cli

Constructors in alluxio.cli with parameters of type FileSystem

Constructor and Description
FuseShell(FileSystem fs, AlluxioConfiguration conf) Creates a new instance of FuseShell.

Uses of FileSystem in alluxio.cli.command

Fields in alluxio.cli.command declared as FileSystem

Modifier and Type	Field and Description
protected FileSystem	AbstractFuseShellCommand.mFileSystem

Constructors in alluxio.cli.command with parameters of type FileSystem

Constructor and Description
AbstractFuseShellCommand(FileSystem fileSystem, AlluxioConfiguration conf, String commandName)
MetadataCacheCommand(FileSystem fs, AlluxioConfiguration conf)

Uses of FileSystem in alluxio.cli.command.metadatacache

Constructors in alluxio.cli.command.metadatacache with parameters of type FileSystem

Constructor and Description
AbstractMetadataCacheSubCommand(FileSystem fileSystem, AlluxioConfiguration conf, String commandName)
DropAllCommand(FileSystem fs, AlluxioConfiguration conf, String parentCommandName)
DropCommand(FileSystem fs, AlluxioConfiguration conf, String parentCommandName)
SizeCommand(FileSystem fs, AlluxioConfiguration conf, String parentCommandName)

Uses of FileSystem in alluxio.cli.fs

Methods in alluxio.cli.fs with parameters of type FileSystem

Modifier and Type	Method and Description
static List<AlluxioURI>	FileSystemShellUtils.getAlluxioURIs(FileSystem alluxioClient, AlluxioURI inputURI) Gets all the AlluxioURIs that match inputURI.

Uses of FileSystem in alluxio.cli.fs.command

Fields in alluxio.cli.fs.command declared as FileSystem

Modifier and Type	Field and Description
protected FileSystem	AbstractFileSystemCommand.mFileSystem

Methods in alluxio.cli.fs.command with parameters of type FileSystem

Modifier and Type	Method and Description
static void	FileSystemCommandUtils.setDirectChildrenLoaded(FileSystem fs, AlluxioURI path, boolean directChildrenLoaded) Sets direct children loaded.
static void	FileSystemCommandUtils.setPinned(FileSystem fs, AlluxioURI path, boolean pinned, List<String> mediumTypes) Sets pin state for the input path.
static void	FileSystemCommandUtils.setTtl(FileSystem fs, AlluxioURI path, long ttlMs, TtlAction ttlAction) Sets a new TTL value or unsets an existing TTL value for file at path.

Uses of FileSystem in alluxio.client.file

Classes in alluxio.client.file that implement FileSystem

Modifier and Type	Class and Description
class	BaseFileSystem Default implementation of the FileSystem interface.
class	DelegatingFileSystem A wrapper of a FileSystem instance.
class	FileSystemCache.InstanceCachingFileSystem A wrapper class on a FileSystem instance.
class	MetadataCachingFileSystem FileSystem implementation with the capability of caching metadata of paths.

Fields in alluxio.client.file declared as FileSystem

Modifier and Type	Field and Description
protected FileSystem	DelegatingFileSystem.mDelegatedFileSystem

Methods in alluxio.client.file that return FileSystem

Modifier and Type	Method and Description
static FileSystem	FileSystem.Factory.create()
static FileSystem	FileSystem.Factory.create(AlluxioConfiguration alluxioConf)
static FileSystem	FileSystem.Factory.create(ClientContext ctx)
static FileSystem	FileSystem.Factory.create(FileSystemContext context)
static FileSystem	FileSystem.Factory.create(FileSystemContext context, FileSystemOptions options)
static FileSystem	FileSystem.Factory.get()
FileSystem	FileSystemCache.get(FileSystemCache.Key key) Gets a FileSystem instance from the cache.
static FileSystem	FileSystem.Factory.get(Subject subject) Get a FileSystem from the cache with a given subject.
static FileSystem	FileSystem.Factory.get(Subject subject, AlluxioConfiguration conf) Get a FileSystem from the cache with a given subject.
FileSystem	DelegatingFileSystem.getUnderlyingFileSystem()

Methods in alluxio.client.file with parameters of type FileSystem

Modifier and Type	Method and Description
static void	FileSystemUtils.persistAndWait(FileSystem fs, AlluxioURI uri, long persistenceWaitTime) Convenience method for #persistAndWait(fs, uri, persistenceWaitTime, -1).
static void	FileSystemUtils.persistAndWait(FileSystem fs, AlluxioURI uri, long persistenceWaitTime, int timeoutMs) Persists the given path to the under file system and returns once the persist is complete.
static boolean	FileSystemUtils.waitCompleted(FileSystem fs, AlluxioURI uri) Shortcut for waitCompleted(fs, uri, -1, TimeUnit.MILLISECONDS), i.e., wait for an indefinite amount of time.
static boolean	FileSystemUtils.waitCompleted(FileSystem fs, AlluxioURI uri, long timeout, TimeUnit tunit) Waits for a file to be marked as completed.
static void	FileSystemUtils.waitForAlluxioPercentage(FileSystem fs, AlluxioURI uri, int expectedPercentage) Waits until the specified file has the desired percentage in Alluxio.

Constructors in alluxio.client.file with parameters of type FileSystem

Constructor and Description
DelegatingFileSystem(FileSystem fs) Wraps a file system instance to forward messages.
MetadataCachingFileSystem(FileSystem fileSystem, FileSystemContext context)
Value(FileSystem fileSystem, int count)

Uses of FileSystem in alluxio.client.file.cache

Classes in alluxio.client.file.cache that implement FileSystem

Modifier and Type	Class and Description
class	LocalCacheFileSystem A FileSystem implementation with a local cache.

Constructors in alluxio.client.file.cache with parameters of type FileSystem

Constructor and Description
LocalCacheFileSystem(CacheManager cacheManage, FileSystem fs, AlluxioConfiguration conf)

Uses of FileSystem in alluxio.client.file.ufs

Classes in alluxio.client.file.ufs that implement FileSystem

Modifier and Type	Class and Description
class	UfsBaseFileSystem An implementation of the FileSystem interface that directly interacts with a target UFS.

Uses of FileSystem in alluxio.examples

Constructors in alluxio.examples with parameters of type FileSystem

Constructor and Description
AlluxioReadWorker(int id, int left, int right, ByteBuffer buf, FileSystem fs)
AlluxioWriterWorker(int id, int left, int right, ByteBuffer buf, FileSystem fs)

Uses of FileSystem in alluxio.fuse

Methods in alluxio.fuse with parameters of type FileSystem

Modifier and Type	Method and Description
static FileOutStream	AlluxioFuseUtils.createFile(FileSystem fileSystem, AuthPolicy authPolicy, AlluxioURI uri, CreateFileStatus fileStatus) Creates a file in alluxio namespace.
static void	AlluxioFuseUtils.deletePath(FileSystem fileSystem, AlluxioURI uri) Deletes a file or a directory in alluxio namespace.
static Optional<URIStatus>	AlluxioFuseUtils.getPathStatus(FileSystem fileSystem, AlluxioURI uri) Gets the path status.
static FuseUmountable	AlluxioFuse.launchFuse(FileSystemContext fsContext, FileSystem fs, FuseOptions fuseOptions, boolean blocking) Launches Fuse application.
static void	AlluxioFuseUtils.setAttribute(FileSystem fileSystem, AlluxioURI uri, SetAttributePOptions options) Sets attribute for a file.
static Optional<URIStatus>	AlluxioFuseUtils.waitForFileCompleted(FileSystem fileSystem, AlluxioURI uri) Waits for the file to complete.

Constructors in alluxio.fuse with parameters of type FileSystem

Constructor and Description
AlluxioJniFuseFileSystem(FileSystemContext fsContext, FileSystem fs, FuseOptions fuseOptions) Creates a new instance of AlluxioJniFuseFileSystem.
AlluxioJnrFuseFileSystem(FileSystem fs, AlluxioConfiguration conf, FuseOptions fuseOptions) Creates a new instance of AlluxioJnrFuseFileSystem.

Uses of FileSystem in alluxio.fuse.auth

Fields in alluxio.fuse.auth declared as FileSystem

Modifier and Type	Field and Description
protected FileSystem	LaunchUserGroupAuthPolicy.mFileSystem

Methods in alluxio.fuse.auth with parameters of type FileSystem

Modifier and Type	Method and Description
static AuthPolicy	AuthPolicyFactory.create(FileSystem fileSystem, AlluxioConfiguration conf, FuseFileSystem fuseFileSystem) Creates a new instance of AuthPolicy.
static SystemUserGroupAuthPolicy	SystemUserGroupAuthPolicy.create(FileSystem fileSystem, AlluxioConfiguration conf, Optional<FuseFileSystem> fuseFileSystem) Creates a new system auth policy.
static CustomAuthPolicy	CustomAuthPolicy.create(FileSystem fileSystem, AlluxioConfiguration conf, Optional<FuseFileSystem> fuseFileSystem) Creates a new custom auth policy.
static LaunchUserGroupAuthPolicy	LaunchUserGroupAuthPolicy.create(FileSystem fileSystem, AlluxioConfiguration conf, Optional<FuseFileSystem> fuseFileSystem) Creates a new launch user auth policy.

Constructors in alluxio.fuse.auth with parameters of type FileSystem

Constructor and Description
LaunchUserGroupAuthPolicy(FileSystem fileSystem, Optional<FuseFileSystem> fuseFileSystem)

Uses of FileSystem in alluxio.fuse.file

Methods in alluxio.fuse.file with parameters of type FileSystem

Modifier and Type	Method and Description
static FuseFileOutStream	FuseFileOutStream.create(FileSystem fileSystem, AuthPolicy authPolicy, FuseReadWriteLockManager lockManager, AlluxioURI uri, int flags, long mode) Creates a FuseFileInOrOutStream.
static FuseFileInOrOutStream	FuseFileInOrOutStream.create(FileSystem fileSystem, AuthPolicy authPolicy, FuseReadWriteLockManager lockManager, AlluxioURI uri, int flags, long mode) Creates a FuseFileInOrOutStream.
static FuseFileInStream	FuseFileInStream.create(FileSystem fileSystem, FuseReadWriteLockManager lockManager, AlluxioURI uri) Creates a FuseFileInStream.

Constructors in alluxio.fuse.file with parameters of type FileSystem

Constructor and Description
Factory(FileSystem fileSystem, AuthPolicy authPolicy) Creates an instance of FuseFileStream.Factory for creating fuse streams.

Uses of FileSystem in alluxio.hadoop

Fields in alluxio.hadoop declared as FileSystem

Modifier and Type	Field and Description
protected FileSystem	AbstractFileSystem.mFileSystem

Constructors in alluxio.hadoop with parameters of type FileSystem

Constructor and Description
AbstractFileSystem(FileSystem fileSystem) Constructs a new AbstractFileSystem instance with specified a FileSystem handler for tests.
BaseHdfsFileInputStream(FileSystem fs, AlluxioURI uri, org.apache.hadoop.fs.FileSystem.Statistics stats) Constructs a new stream for reading a file from HDFS.
FileSystem(FileSystem fileSystem) Constructs a new FileSystem instance with a specified FileSystem handler for tests.
HdfsFileInputStream(FileSystem fs, AlluxioURI uri, org.apache.hadoop.fs.FileSystem.Statistics stats) Constructs a new stream for reading a file from HDFS.

Uses of FileSystem in alluxio.job

Methods in alluxio.job that return FileSystem

Modifier and Type	Method and Description
FileSystem	JobServerContext.getFileSystem()

Constructors in alluxio.job with parameters of type FileSystem

Constructor and Description
JobServerContext(FileSystem filesystem, FileSystemContext fsContext, UfsManager ufsManager) Creates a new instance of JobServerContext.

Uses of FileSystem in alluxio.master

Methods in alluxio.master that return FileSystem

Modifier and Type	Method and Description
FileSystem	MultiMasterEmbeddedJournalLocalAlluxioCluster.getClient()
FileSystem	MultiMasterLocalAlluxioCluster.getClient()
FileSystem	LocalAlluxioCluster.getClient()
abstract FileSystem	AbstractLocalAlluxioCluster.getClient() Returns a FileSystem client.
FileSystem	ClientPool.getClient() Returns a FileSystem client.
FileSystem	LocalAlluxioMaster.getClient()
FileSystem	MultiMasterEmbeddedJournalLocalAlluxioCluster.getClient(FileSystemContext context)
FileSystem	MultiMasterLocalAlluxioCluster.getClient(FileSystemContext context)
FileSystem	LocalAlluxioCluster.getClient(FileSystemContext context)
abstract FileSystem	AbstractLocalAlluxioCluster.getClient(FileSystemContext context)
FileSystem	ClientPool.getClient(FileSystemContext context) Returns a FileSystem client using a specific context.
FileSystem	LocalAlluxioMaster.getClient(FileSystemContext context)

Uses of FileSystem in alluxio.master.backcompat

Methods in alluxio.master.backcompat with parameters of type FileSystem

Modifier and Type	Method and Description
protected abstract void	FsTestOp.apply(FileSystem fs)
protected abstract void	FsTestOp.check(FileSystem fs)
static void	Utils.createFile(FileSystem fs, AlluxioURI path) Creates a file at the given path.
static void	Utils.createFile(FileSystem fs, AlluxioURI path, CreateFilePOptions options) Creates a file at the given path.

Uses of FileSystem in alluxio.master.backcompat.ops

Methods in alluxio.master.backcompat.ops with parameters of type FileSystem

Modifier and Type	Method and Description
void	Rename.apply(FileSystem fs)
void	SetAcl.apply(FileSystem fs)
void	Mount.apply(FileSystem fs)
void	Delete.apply(FileSystem fs)
void	CreateFile.apply(FileSystem fs)
void	CreateDirectory.apply(FileSystem fs)
void	PersistDirectory.apply(FileSystem fs)
void	AsyncPersist.apply(FileSystem fs)
void	Rename.check(FileSystem fs)
void	SetAcl.check(FileSystem fs)
void	Mount.check(FileSystem fs)
void	Delete.check(FileSystem fs)
void	CreateFile.check(FileSystem fs)
void	CreateDirectory.check(FileSystem fs)
void	PersistDirectory.check(FileSystem fs)
void	AsyncPersist.check(FileSystem fs)

Uses of FileSystem in alluxio.master.job

Constructors in alluxio.master.job with parameters of type FileSystem

Constructor and Description
JobMaster(MasterContext masterContext, FileSystem filesystem, FileSystemContext fsContext, UfsManager ufsManager) Creates a new instance of JobMaster.

Uses of FileSystem in alluxio.master.job.metrics

Methods in alluxio.master.job.metrics with parameters of type FileSystem

Modifier and Type	Method and Description
static void	DistributedCmdMetrics.batchIncrementForCompleteStatusWithRetry(BatchedJobConfig config, FileSystem fileSystem, RetryPolicy retryPolicy) Increment for batch config for complete status.
static long	DistributedCmdMetrics.getFileSize(String filePath, FileSystem fileSystem, RetryPolicy retryPolicy) get file size for a given filePath, return 0 if exceeding retries.
static void	DistributedCmdMetrics.incrementForAllConfigsCompleteStatus(JobConfig config, FileSystem fileSystem, RetryPolicy retryPolicy) Increment for both batch and non-batch configs for COMPLETE status.
static void	DistributedCmdMetrics.incrementForCompleteStatusWithRetry(JobConfig config, FileSystem fileSystem, RetryPolicy retryPolicy) Increment for non-batch config for complete status.

Uses of FileSystem in alluxio.master.job.tracker

Fields in alluxio.master.job.tracker declared as FileSystem

Modifier and Type	Field and Description
protected FileSystem	AbstractCmdRunner.mFileSystem

Uses of FileSystem in alluxio.multi.process

Methods in alluxio.multi.process that return FileSystem

Modifier and Type	Method and Description
FileSystem	MultiProcessCluster.getFileSystemClient()
FileSystem	Clients.getFileSystemClient()

Constructors in alluxio.multi.process with parameters of type FileSystem

Constructor and Description
Clients(FileSystem fs, FileSystemMasterClient fsMaster, MetaMasterClient metaMaster, BlockMasterClient blockMaster)

Uses of FileSystem in alluxio.proxy.s3

Methods in alluxio.proxy.s3 that return FileSystem

Modifier and Type	Method and Description
static FileSystem	S3RestUtils.createFileSystemForUser(String user, FileSystem fs)
FileSystem	S3Handler.getMetaFS() Get system user FileSystem object.

Methods in alluxio.proxy.s3 with parameters of type FileSystem

Modifier and Type	Method and Description
static boolean	MultipartUploadCleaner.apply(FileSystem metaFs, FileSystem userFs, String bucket, String object, String uploadId) Schedule a task to clean multipart upload.
static void	MultipartUploadCleaner.cancelAbort(FileSystem metaFs, FileSystem userFs, String bucket, String object, String uploadId) Cancel schedule task.
static void	S3RestUtils.checkPathIsAlluxioDirectory(FileSystem fs, String bucketPath, S3AuditContext auditContext) Check if a path in alluxio is a directory.
static void	S3RestUtils.checkPathIsAlluxioDirectory(FileSystem fs, String bucketPath, S3AuditContext auditContext, com.google.common.cache.Cache<AlluxioURI,Boolean> bucketPathCache) Check if a path in alluxio is a directory.
static List<URIStatus>	S3RestUtils.checkStatusesForUploadId(FileSystem metaFs, FileSystem userFs, AlluxioURI multipartTempDirUri, String uploadId) Fetches and returns the corresponding URIStatus for both the multipart upload temp directory and the Alluxio S3 metadata file.
static FileSystem	S3RestUtils.createFileSystemForUser(String user, FileSystem fs)
static void	S3RestUtils.deleteExistObject(FileSystem fs, AlluxioURI objectURI) Delete an existing key.
static void	S3RestUtils.deleteExistObject(FileSystem fs, AlluxioURI objectURI, Boolean recursive) Delete an existing key.
static void	S3RestUtils.setEntityTag(FileSystem fs, AlluxioURI objectUri, String entityTag) This helper method is used to set the ETag xAttr on an object.
long	MultipartUploadCleaner.tryAbortMultipartUpload(FileSystem metaFs, FileSystem userFs, String bucket, String object, String uploadId) Try to abort a multipart upload if it was timeout.

Constructors in alluxio.proxy.s3 with parameters of type FileSystem

Constructor and Description
AbortTask(FileSystem metaFs, FileSystem userFs, String bucket, String object, String uploadId) Creates a new instance of MultipartUploadCleaner.AbortTask.
CompleteMultipartUploadHandler(FileSystem fs, String baseUri) Creates a new instance of CompleteMultipartUploadHandler.
CompleteMultipartUploadTask(FileSystem metaFs, FileSystem userFs, String bucket, String object, String uploadId, String body) Creates a new instance of CompleteMultipartUploadHandler.CompleteMultipartUploadTask.

Uses of FileSystem in alluxio.stress.cli

Fields in alluxio.stress.cli declared as FileSystem

Modifier and Type	Field and Description
protected FileSystem[]	StressMasterBenchBase.mCachedNativeFs In case the Alluxio Native API is used, use the following instead.

Methods in alluxio.stress.cli with parameters of type FileSystem

Modifier and Type	Method and Description
protected void	StressMasterBenchBase.applyNativeOperation(FileSystem fs, Operation operation, long counter, org.apache.hadoop.fs.Path basePath, org.apache.hadoop.fs.Path fixedBasePath, int fixedCount)

Uses of FileSystem in alluxio.stress.cli.client

Fields in alluxio.stress.cli.client declared as FileSystem

Modifier and Type	Field and Description
protected FileSystem[]	CompactionBench.mCachedFs

Uses of FileSystem in alluxio.table.common.udb

Methods in alluxio.table.common.udb that return FileSystem

Modifier and Type	Method and Description
FileSystem	UdbContext.getFileSystem()

Constructors in alluxio.table.common.udb with parameters of type FileSystem

Constructor and Description
UdbContext(UnderDatabaseRegistry udbRegistry, FileSystem fileSystem, String type, String connectionUri, String udbDbName, String dbName) Creates an instance.