Package | Description |
---|---|
alluxio.job | |
alluxio.master | |
alluxio.master.backup | |
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.grpc | |
alluxio.worker.page |
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 | Class and Description |
---|---|
class |
MasterContext<T extends UfsManager>
Stores context information for Alluxio masters.
|
Modifier and Type | Class and Description |
---|---|
class |
NoopUfsManager
Implementation of UfsManager that does nothing.
|
Constructor and Description |
---|
NoopMaster(String name,
UfsManager ufsManager)
Creates a new
NoopMaster with the given name and ufsManager. |
Modifier and Type | Field and Description |
---|---|
protected UfsManager |
AbstractBackupRole.mUfsManager
The manager of all ufs.
|
Modifier and Type | Method and Description |
---|---|
static void |
DefaultFileSystemMaster.Metrics.registerGauges(UfsManager ufsManager,
InodeTree inodeTree)
Register some file system master related gauges.
|
Constructor and Description |
---|
MountTable(UfsManager ufsManager,
MountInfo rootMountInfo,
java.time.Clock clock)
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 | Field and Description |
---|---|
UfsManager |
BlockStoreBase.mUfsManager
The shared
UfsManager used for block stores. |
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.
|
Constructor and Description |
---|
BlockStoreBase(MonoBlockStore monoBlockStore,
PagedBlockStore pagedBlockStore,
UfsManager ufs) |
Modifier and Type | Method and Description |
---|---|
BlockWorker |
BlockWorkerFactory.create(WorkerRegistry registry,
UfsManager ufsManager) |
Constructor and Description |
---|
MonoBlockStore(LocalBlockStore localBlockStore,
BlockMasterClientPool blockMasterClientPool,
UfsManager ufsManager,
AtomicReference<Long> workerId)
Constructor of MonoBlockStore.
|
UnderFileSystemBlockStore(LocalBlockStore localBlockStore,
UfsManager ufsManager)
Creates an instance of
UnderFileSystemBlockStore . |
Constructor and Description |
---|
DelegationWriteHandler(DefaultBlockWorker blockWorker,
UfsManager ufsManager,
io.grpc.stub.StreamObserver<WriteResponse> responseObserver,
AuthenticatedUserInfo userInfo,
boolean domainSocketEnabled) |
Modifier and Type | Method and Description |
---|---|
static PagedBlockStore |
PagedBlockStore.create(UfsManager ufsManager,
BlockMasterClientPool pool,
AtomicReference<Long> workerId)
Create an instance of PagedBlockStore.
|
Constructor and Description |
---|
PagedUfsBlockReader(UfsManager ufsManager,
UfsInputStreamCache ufsInStreamCache,
BlockMeta blockMeta,
long offset,
UfsBlockReadOptions ufsBlockReadOptions,
long pageSize) |
Copyright © 2023. All Rights Reserved.