Package | Description |
---|---|
alluxio.master.file | |
alluxio.master.file.activesync | |
alluxio.master.file.meta | |
alluxio.underfs |
Modifier and Type | Method and Description |
---|---|
MountTable |
DefaultFileSystemMaster.getMountTable() |
Constructor and Description |
---|
SafeUfsDeleter(MountTable mountTable,
ReadOnlyInodeStore inodeStore,
List<Pair<AlluxioURI,LockedInodePath>> inodes,
DeletePOptions deleteOptions)
Creates a new instance of
SafeUfsDeleter . |
UfsSyncChecker(MountTable mountTable,
ReadOnlyInodeStore inodeStore)
Create a new instance of
UfsSyncChecker . |
Constructor and Description |
---|
ActiveSyncer(FileSystemMaster fileSystemMaster,
ActiveSyncManager syncManager,
MountTable mountTable,
long mountId)
Constructs a new
ActiveSyncer . |
ActiveSyncManager(MountTable mountTable,
FileSystemMaster fileSystemMaster)
Constructs a Active Sync Manager.
|
Modifier and Type | Method and Description |
---|---|
static UfsBlockLocationCache |
UfsBlockLocationCache.Factory.create(MountTable mountTable) |
static UfsAbsentPathCache |
UfsAbsentPathCache.Factory.create(MountTable mountTable,
java.time.Clock clock) |
Constructor and Description |
---|
AsyncUfsAbsentPathCache(MountTable mountTable,
int numThreads,
java.time.Clock clock)
Creates a new instance of
AsyncUfsAbsentPathCache . |
InodeTree(InodeStore inodeStore,
ContainerIdGenerable containerIdGenerator,
InodeDirectoryIdGenerator directoryIdGenerator,
MountTable mountTable,
InodeLockManager lockManager) |
LazyUfsBlockLocationCache(MountTable mountTable)
Creates a new instance of
UfsBlockLocationCache . |
Modifier and Type | Method and Description |
---|---|
Collection<UfsStatus> |
UfsStatusCache.fetchChildrenIfAbsent(RpcContext rpcContext,
AlluxioURI path,
MountTable mountTable)
Fetches children of a given alluxio path stores them in the cache, then returns them.
|
Collection<UfsStatus> |
UfsStatusCache.fetchChildrenIfAbsent(RpcContext rpcContext,
AlluxioURI path,
MountTable mountTable,
boolean useFallback)
Fetches children of a given alluxio path, stores them in the cache, then returns them.
|
UfsStatus |
UfsStatusCache.fetchStatusIfAbsent(AlluxioURI path,
MountTable mountTable)
Attempts to return a status from the cache.
|
Future<Collection<UfsStatus>> |
UfsStatusCache.prefetchChildren(AlluxioURI path,
MountTable mountTable)
Submit a request to asynchronously fetch the statuses corresponding to a given directory.
|
Copyright © 2023. All Rights Reserved.