| Package | Description |
|---|---|
| alluxio.client.file | |
| alluxio.client.file.cache |
| 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.
|
| Modifier and Type | Field and Description |
|---|---|
protected FileSystem |
DelegatingFileSystem.mDelegatedFileSystem |
| 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(javax.security.auth.Subject subject)
Get a FileSystem from the cache with a given subject.
|
static FileSystem |
FileSystem.Factory.get(javax.security.auth.Subject subject,
AlluxioConfiguration conf)
Get a FileSystem from the cache with a given subject.
|
| 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,
java.util.concurrent.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.
|
| Constructor and Description |
|---|
DelegatingFileSystem(FileSystem fs)
Wraps a file system instance to forward messages.
|
MetadataCachingFileSystem(FileSystem fileSystem,
FileSystemContext context) |
Value(FileSystem fileSystem,
int count) |
| Modifier and Type | Class and Description |
|---|---|
class |
LocalCacheFileSystem
A FileSystem implementation with a local cache.
|
| Constructor and Description |
|---|
LocalCacheFileSystem(CacheManager cacheManage,
FileSystem fs,
AlluxioConfiguration conf) |
Copyright © 2022. All Rights Reserved.