Modifier and Type | Method and Description |
---|---|
InetSocketAddress |
Client.getAddress() |
InetSocketAddress |
AbstractClient.getAddress() |
InetSocketAddress |
AbstractMasterClient.getAddress() |
Modifier and Type | Method and Description |
---|---|
InetSocketAddress |
FileSystemContext.getMasterAddress() |
Modifier and Type | Method and Description |
---|---|
JournalContext |
AbstractMaster.createJournalContext() |
JournalContext |
Master.createJournalContext() |
List<InetSocketAddress> |
MasterInquireClient.getMasterRpcAddresses() |
List<InetSocketAddress> |
ZkMasterInquireClient.getMasterRpcAddresses() |
InetSocketAddress |
PollingMasterInquireClient.getPrimaryRpcAddress() |
InetSocketAddress |
MasterInquireClient.getPrimaryRpcAddress() |
InetSocketAddress |
ZkMasterInquireClient.getPrimaryRpcAddress() |
Modifier and Type | Method and Description |
---|---|
void |
DefaultBlockMaster.commitBlock(long workerId,
long usedBytesOnTier,
String tierAlias,
long blockId,
long length) |
void |
BlockMaster.commitBlock(long workerId,
long usedBytesOnTier,
String tierAlias,
long blockId,
long length)
Marks a block as committed on a specific worker.
|
void |
DefaultBlockMaster.commitBlockInUFS(long blockId,
long length) |
void |
BlockMaster.commitBlockInUFS(long blockId,
long length)
Marks a block as committed, but without a worker location.
|
BlockInfo |
DefaultBlockMaster.getBlockInfo(long blockId) |
BlockInfo |
BlockMaster.getBlockInfo(long blockId) |
List<BlockInfo> |
DefaultBlockMaster.getBlockInfoList(List<Long> blockIds) |
List<BlockInfo> |
BlockMaster.getBlockInfoList(List<Long> blockIds)
Retrieves information for the given list of block ids.
|
List<WorkerInfo> |
DefaultBlockMaster.getLostWorkersInfoList() |
List<WorkerInfo> |
BlockMaster.getLostWorkersInfoList() |
long |
DefaultBlockMaster.getNewContainerId() |
long |
ContainerIdGenerable.getNewContainerId() |
List<WorkerInfo> |
DefaultBlockMaster.getWorkerInfoList() |
List<WorkerInfo> |
BlockMaster.getWorkerInfoList() |
List<WorkerInfo> |
DefaultBlockMaster.getWorkerReport(GetWorkerReportOptions options) |
List<WorkerInfo> |
BlockMaster.getWorkerReport(GetWorkerReportOptions options)
Gets the worker information list for report CLI.
|
void |
DefaultBlockMaster.removeBlocks(List<Long> blockIds,
boolean delete) |
void |
BlockMaster.removeBlocks(List<Long> blockIds,
boolean delete)
Removes blocks from workers.
|
void |
DefaultBlockMaster.validateBlocks(java.util.function.Function<Long,Boolean> validator,
boolean repair) |
void |
BlockMaster.validateBlocks(java.util.function.Function<Long,Boolean> validator,
boolean repair)
Validates the integrity of blocks with respect to the validator.
|
Modifier and Type | Method and Description |
---|---|
void |
RpcContext.close() |
void |
DefaultFileSystemMaster.completeFile(AlluxioURI path,
CompleteFileOptions options) |
void |
FileSystemMaster.completeFile(AlluxioURI path,
CompleteFileOptions options)
Completes a file.
|
RpcContext |
DefaultFileSystemMaster.createRpcContext() |
List<FileBlockInfo> |
DefaultFileSystemMaster.getFileBlockInfoList(AlluxioURI path) |
List<FileBlockInfo> |
FileSystemMaster.getFileBlockInfoList(AlluxioURI path)
Gets the
FileBlockInfo for all blocks of a file. |
long |
DefaultFileSystemMaster.getFileId(AlluxioURI path) |
long |
FileSystemMaster.getFileId(AlluxioURI path)
Returns the file id for a given path.
|
FileInfo |
DefaultFileSystemMaster.getFileInfo(AlluxioURI path,
GetStatusOptions options) |
FileInfo |
FileSystemMaster.getFileInfo(AlluxioURI path,
GetStatusOptions options)
Returns the
FileInfo for a given path. |
FileInfo |
DefaultFileSystemMaster.getFileInfo(long fileId) |
FileInfo |
FileSystemMaster.getFileInfo(long fileId)
Returns the
FileInfo for a given file id. |
List<AlluxioURI> |
DefaultFileSystemMaster.getInAlluxioFiles() |
List<AlluxioURI> |
FileSystemMaster.getInAlluxioFiles() |
List<AlluxioURI> |
DefaultFileSystemMaster.getInMemoryFiles() |
List<AlluxioURI> |
FileSystemMaster.getInMemoryFiles() |
List<WorkerInfo> |
DefaultFileSystemMaster.getWorkerInfoList() |
List<WorkerInfo> |
FileSystemMaster.getWorkerInfoList() |
List<FileInfo> |
DefaultFileSystemMaster.listStatus(AlluxioURI path,
ListStatusOptions listStatusOptions) |
List<FileInfo> |
FileSystemMaster.listStatus(AlluxioURI path,
ListStatusOptions listStatusOptions)
Returns a list of
FileInfo for a given path. |
long |
DefaultFileSystemMaster.reinitializeFile(AlluxioURI path,
long blockSizeBytes,
long ttl,
TtlAction ttlAction) |
long |
FileSystemMaster.reinitializeFile(AlluxioURI path,
long blockSizeBytes,
long ttl,
TtlAction ttlAction)
Reinitializes the blocks of an existing open file.
|
void |
DefaultFileSystemMaster.reportLostFile(long fileId) |
void |
FileSystemMaster.reportLostFile(long fileId)
Reports a file as lost.
|
void |
DefaultFileSystemMaster.scheduleAsyncPersistence(AlluxioURI path) |
void |
FileSystemMaster.scheduleAsyncPersistence(AlluxioURI path)
Schedules a file for async persistence.
|
void |
DefaultFileSystemMaster.updateUfsMode(AlluxioURI ufsPath,
UnderFileSystem.UfsMode ufsMode) |
void |
FileSystemMaster.updateUfsMode(AlluxioURI ufsPath,
UnderFileSystem.UfsMode ufsMode)
Update the operation mode for the given ufs path under one or more mount points.
|
void |
DefaultFileSystemMaster.validateInodeBlocks(boolean repair) |
void |
FileSystemMaster.validateInodeBlocks(boolean repair)
Checks the integrity of the inodes with respect to the blocks of the system.
|
Modifier and Type | Method and Description |
---|---|
void |
DefaultAsyncPersistHandler.scheduleAsyncPersistence(AlluxioURI path) |
void |
AsyncPersistHandler.scheduleAsyncPersistence(AlluxioURI path)
Schedules a file for async persistence.
|
Modifier and Type | Method and Description |
---|---|
List<FileBlockInfo> |
FileSystemMasterView.getFileBlockInfoList(AlluxioURI path) |
long |
FileSystemMasterView.getFileId(AlluxioURI path)
Returns the file id for a given path.
|
FileInfo |
FileSystemMasterView.getFileInfo(long fileId)
Returns the
FileInfo for a given path. |
List<WorkerInfo> |
FileSystemMasterView.getWorkerInfoList() |
void |
InodeTree.initializeRoot(String owner,
String group,
Mode mode,
JournalContext context)
Initializes the root of the inode tree.
|
Modifier and Type | Method and Description |
---|---|
void |
MasterJournalContext.close() |
void |
StateChangeJournalContext.close() |
void |
JournalContext.close() |
JournalContext |
Journal.createJournalContext() |
Modifier and Type | Method and Description |
---|---|
JournalContext |
UfsJournal.createJournalContext() |
Modifier and Type | Method and Description |
---|---|
void |
DefaultKeyValueMaster.completePartition(AlluxioURI path,
PartitionInfo info) |
void |
KeyValueMaster.completePartition(AlluxioURI path,
PartitionInfo info)
Marks a partition complete and adds it to an incomplete key-value store.
|
void |
DefaultKeyValueMaster.completeStore(AlluxioURI path) |
void |
KeyValueMaster.completeStore(AlluxioURI path)
Marks a key-value store complete.
|
void |
DefaultKeyValueMaster.createStore(AlluxioURI path) |
void |
KeyValueMaster.createStore(AlluxioURI path)
Creates a new key-value store.
|
void |
KeyValueMaster.deleteStore(AlluxioURI uri)
Deletes a completed key-value store.
|
List<PartitionInfo> |
DefaultKeyValueMaster.getPartitionInfo(AlluxioURI path) |
List<PartitionInfo> |
KeyValueMaster.getPartitionInfo(AlluxioURI path)
Gets a list of partitions of a given key-value store.
|
void |
KeyValueMaster.mergeStore(AlluxioURI fromUri,
AlluxioURI toUri)
Merges one completed key-value store to another completed key-value store.
|
void |
KeyValueMaster.renameStore(AlluxioURI oldUri,
AlluxioURI newUri)
Renames one completed key-value store.
|
Modifier and Type | Method and Description |
---|---|
boolean |
LineageMaster.deleteLineage(long lineageId,
boolean cascade)
Deletes a lineage.
|
boolean |
DefaultLineageMaster.deleteLineage(long lineageId,
boolean cascade) |
long |
LineageMaster.reinitializeFile(String path,
long blockSizeBytes,
long ttl,
TtlAction ttlAction)
Reinitializes the file when the file is lost or not completed.
|
long |
DefaultLineageMaster.reinitializeFile(String path,
long blockSizeBytes,
long ttl,
TtlAction ttlAction) |
void |
LineageMaster.reportLostFile(String path)
Reports a file as lost.
|
void |
DefaultLineageMaster.reportLostFile(String path) |
Modifier and Type | Method and Description |
---|---|
static boolean |
LineageStateUtils.isCompleted(Lineage lineage,
FileSystemMasterView fileSystemMasterView)
Checks if all the output files of the given lineage are completed.
|
Modifier and Type | Method and Description |
---|---|
UfsManager.UfsClient |
WorkerUfsManager.get(long mountId)
Gets UFS information from the manager if this mount ID exists, or throws exception otherwise.
|
UfsManager.UfsClient |
UfsManager.get(long mountId)
Gets UFS information from the manager if this mount ID exists, or throws exception otherwise.
|
UfsManager.UfsClient |
AbstractUfsManager.get(long mountId) |
Copyright © 2023. All Rights Reserved.