Package | Description |
---|---|
alluxio.master.file.meta | |
alluxio.underfs | |
alluxio.worker |
Worker process and utils for working with the worker remotely.
|
alluxio.worker.block |
Modifier and Type | Method and Description |
---|---|
UfsManager.UfsClient |
MountTable.Resolution.getUfsClient() |
UfsManager.UfsClient |
MountTable.getUfsClient(long mountId)
Get the associated ufs client with the mount id.
|
Modifier and Type | Method and Description |
---|---|
UfsManager.UfsClient |
JobUfsManager.get(long mountId) |
UfsManager.UfsClient |
WorkerUfsManager.get(long mountId)
Gets UFS information from the manager if this mount ID exists, or throws exception otherwise.
|
UfsManager.UfsClient |
AbstractUfsManager.get(long mountId) |
UfsManager.UfsClient |
UfsManager.get(long mountId)
Gets UFS information from the manager if this mount ID exists, or throws exception otherwise.
|
UfsManager.UfsClient |
AbstractUfsManager.getJournal(URI location) |
UfsManager.UfsClient |
UfsManager.getJournal(URI location) |
UfsManager.UfsClient |
AbstractUfsManager.getRoot() |
UfsManager.UfsClient |
UfsManager.getRoot() |
Modifier and Type | Method and Description |
---|---|
static String |
BlockUtils.getUfsBlockPath(UfsManager.UfsClient ufsInfo,
long blockId)
For a given block ID, derives the corresponding UFS file of this block if it falls back to
be stored in UFS.
|
Modifier and Type | Method and Description |
---|---|
static UnderFileSystemBlockReader |
UnderFileSystemBlockReader.create(UnderFileSystemBlockMeta blockMeta,
long offset,
boolean positionShort,
LocalBlockStore localBlockStore,
UfsManager.UfsClient ufsClient,
UfsInputStreamCache ufsInStreamCache,
com.codahale.metrics.Counter ufsBytesRead,
com.codahale.metrics.Meter ufsBytesReadThroughput)
Creates an instance of
UnderFileSystemBlockReader and initializes it with a reading
offset. |
Constructor and Description |
---|
UfsIOManager(UfsManager.UfsClient ufsClient) |
Copyright © 2023. All Rights Reserved.