Package | Description |
---|---|
alluxio.job | |
alluxio.master.file | |
alluxio.master.file.meta | |
alluxio.master.job | |
alluxio.underfs | |
alluxio.worker |
Worker process and utils for working with the worker remotely.
|
alluxio.worker.block | |
alluxio.worker.file |
Modifier and Type | Method and Description |
---|---|
UfsManager |
JobServerContext.getUfsManager() |
Constructor and Description |
---|
JobServerContext(FileSystem filesystem,
FileSystemContext fsContext,
UfsManager ufsManager)
Creates a new instance of
JobServerContext . |
Modifier and Type | Method and Description |
---|---|
static void |
DefaultFileSystemMaster.Metrics.registerGauges(FileSystemMaster master,
UfsManager ufsManager)
Register some file system master related gauges.
|
Constructor and Description |
---|
MountTable(UfsManager ufsManager,
MountInfo rootMountInfo)
Creates a new instance of
MountTable . |
Constructor and Description |
---|
JobMaster(MasterContext masterContext,
FileSystem filesystem,
FileSystemContext fsContext,
UfsManager ufsManager)
Creates a new instance of
JobMaster . |
Modifier and Type | Class and Description |
---|---|
class |
AbstractUfsManager
Basic implementation of
UfsManager . |
class |
JobUfsManager
Implementation of UfsManager to manage the ufs used by different job service processes.
|
class |
MasterUfsManager
A class that manages the UFS for master servers.
|
class |
WorkerUfsManager
The default implementation of UfsManager to manage the ufs used by different worker services.
|
Modifier and Type | Method and Description |
---|---|
UfsManager |
AlluxioWorkerProcess.getUfsManager() |
UfsManager |
WorkerProcess.getUfsManager() |
Modifier and Type | Method and Description |
---|---|
Worker |
WorkerFactory.create(WorkerRegistry registry,
UfsManager ufsManager)
Factory method to create a new worker instance.
|
Modifier and Type | Method and Description |
---|---|
static UnderFileSystemBlockReader |
UnderFileSystemBlockReader.create(UnderFileSystemBlockMeta blockMeta,
long offset,
BlockStore localBlockStore,
UfsManager ufsManager,
UfsInputStreamManager ufsInstreamManager)
Creates an instance of
UnderFileSystemBlockReader and initializes it with a reading
offset. |
BlockWorker |
BlockWorkerFactory.create(WorkerRegistry registry,
UfsManager ufsManager) |
Constructor and Description |
---|
UnderFileSystemBlockStore(BlockStore localBlockStore,
UfsManager ufsManager)
Creates an instance of
UnderFileSystemBlockStore . |
Modifier and Type | Method and Description |
---|---|
FileSystemWorker |
FileSystemWorkerFactory.create(WorkerRegistry registry,
UfsManager ufsManager) |
Constructor and Description |
---|
FileDataManager(BlockWorker blockWorker,
com.google.common.util.concurrent.RateLimiter persistenceRateLimiter,
UfsManager ufsManager)
Creates a new instance of
FileDataManager . |
Copyright © 2023. All Rights Reserved.