Modifier and Type | Method and Description |
---|---|
static List<AlluxioURI> |
FileSystemShellUtils.getAlluxioURIs(FileSystem alluxioClient,
AlluxioURI inputURI)
Gets all the
AlluxioURI s that match inputURI. |
Modifier and Type | Field and Description |
---|---|
protected FileSystem |
AbstractFileSystemCommand.mFileSystem |
Modifier and Type | Method and Description |
---|---|
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.
|
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 |
MetadataCachingBaseFileSystem
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(AlluxioConfiguration alluxioConf) |
static FileSystem |
FileSystem.Factory.create(ClientContext ctx) |
static FileSystem |
FileSystem.Factory.create(FileSystemContext context) |
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) |
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.
|
Constructor and Description |
---|
DelegatingFileSystem(FileSystem fs)
Wraps a file system instance to forward messages.
|
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) |
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) |
Constructor and Description |
---|
AlluxioFuseFileSystem(FileSystem fs,
AlluxioFuseOptions opts,
AlluxioConfiguration conf)
Creates a new instance of
AlluxioFuseFileSystem . |
AlluxioJniFuseFileSystem(FileSystem fs,
AlluxioFuseOptions opts,
AlluxioConfiguration conf)
Creates a new instance of
AlluxioJniFuseFileSystem . |
Modifier and Type | Field and Description |
---|---|
protected FileSystem |
AbstractFileSystem.mFileSystem |
Constructor and Description |
---|
AbstractFileSystem(FileSystem fileSystem)
Constructs a new
AbstractFileSystem instance with specified a FileSystem
handler for tests. |
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.
|
Modifier and Type | Method and Description |
---|---|
FileSystem |
JobServerContext.getFileSystem() |
Constructor and Description |
---|
JobServerContext(FileSystem filesystem,
FileSystemContext fsContext,
UfsManager ufsManager)
Creates a new instance of
JobServerContext . |
Modifier and Type | Method and Description |
---|---|
static void |
JobUtils.loadBlock(FileSystem fs,
FileSystemContext context,
String path,
long blockId)
Loads a block into the local worker.
|
Modifier and Type | Method and Description |
---|---|
FileSystem |
MultiMasterLocalAlluxioCluster.getClient() |
FileSystem |
LocalAlluxioCluster.getClient() |
FileSystem |
ClientPool.getClient()
Returns a
FileSystem client. |
FileSystem |
LocalAlluxioMaster.getClient() |
abstract FileSystem |
AbstractLocalAlluxioCluster.getClient()
Returns a
FileSystem client. |
FileSystem |
MultiMasterLocalAlluxioCluster.getClient(FileSystemContext context) |
FileSystem |
LocalAlluxioCluster.getClient(FileSystemContext context) |
FileSystem |
ClientPool.getClient(FileSystemContext context)
Returns a
FileSystem client using a specific context. |
FileSystem |
LocalAlluxioMaster.getClient(FileSystemContext context) |
abstract FileSystem |
AbstractLocalAlluxioCluster.getClient(FileSystemContext context) |
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.
|
Modifier and Type | Method and Description |
---|---|
void |
CreateFile.apply(FileSystem fs) |
void |
Rename.apply(FileSystem fs) |
void |
Mount.apply(FileSystem fs) |
void |
AsyncPersist.apply(FileSystem fs) |
void |
Delete.apply(FileSystem fs) |
void |
CreateDirectory.apply(FileSystem fs) |
void |
SetAcl.apply(FileSystem fs) |
void |
PersistDirectory.apply(FileSystem fs) |
void |
CreateFile.check(FileSystem fs) |
void |
Rename.check(FileSystem fs) |
void |
Mount.check(FileSystem fs) |
void |
AsyncPersist.check(FileSystem fs) |
void |
Delete.check(FileSystem fs) |
void |
CreateDirectory.check(FileSystem fs) |
void |
SetAcl.check(FileSystem fs) |
void |
PersistDirectory.check(FileSystem fs) |
Constructor and Description |
---|
JobMaster(MasterContext masterContext,
FileSystem filesystem,
FileSystemContext fsContext,
UfsManager ufsManager)
Creates a new instance of
JobMaster . |
Modifier and Type | Method and Description |
---|---|
FileSystem |
MultiProcessCluster.getFileSystemClient() |
FileSystem |
Clients.getFileSystemClient() |
Constructor and Description |
---|
Clients(FileSystem fs,
FileSystemMasterClient fsMaster,
MetaMasterClient metaMaster,
BlockMasterClient blockMaster) |
Modifier and Type | Method and Description |
---|---|
FileSystem |
UdbContext.getFileSystem() |
Constructor and Description |
---|
UdbContext(UnderDatabaseRegistry udbRegistry,
FileSystem fileSystem,
String type,
String connectionUri,
String udbDbName,
String dbName)
Creates an instance.
|
Copyright © 2023. All Rights Reserved.