| Package | Description |
|---|---|
| alluxio.master.file | |
| alluxio.master.file.activesync | |
| alluxio.master.file.meta | |
| alluxio.underfs |
| Constructor and Description |
|---|
SafeUfsDeleter(MountTable mountTable,
ReadOnlyInodeStore inodeStore,
java.util.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) |
| Constructor and Description |
|---|
AsyncUfsAbsentPathCache(MountTable mountTable,
int numThreads)
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 |
|---|---|
java.util.Collection<UfsStatus> |
UfsStatusCache.fetchChildrenIfAbsent(AlluxioURI path,
MountTable mountTable)
Fetches children of a given alluxio path stores them in the cache, then returns them.
|
java.util.Collection<UfsStatus> |
UfsStatusCache.fetchChildrenIfAbsent(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.
|
java.util.concurrent.Future<java.util.Collection<UfsStatus>> |
UfsStatusCache.prefetchChildren(AlluxioURI path,
MountTable mountTable)
Submit a request to asynchronously fetch the statuses corresponding to a given directory.
|
Copyright © 2020. All Rights Reserved.