Modifier and Type | Method and Description |
---|---|
InetSocketAddress |
AbstractJobMasterClient.getConfAddress() |
InetSocketAddress |
AbstractMasterClient.getConfAddress() |
InetSocketAddress |
Client.getConfAddress() |
InetSocketAddress |
AbstractClient.getConfAddress()
By default, return the same underlying address as
AbstractClient.getRemoteSockAddress() . |
String |
Client.getRemoteHostName() |
String |
AbstractClient.getRemoteHostName() |
SocketAddress |
Client.getRemoteSockAddress() |
SocketAddress |
AbstractClient.getRemoteSockAddress() |
protected GrpcServerAddress |
AbstractMasterClient.queryGrpcServerAddress() |
protected abstract GrpcServerAddress |
AbstractClient.queryGrpcServerAddress()
AbstractClient works with Grpc Servers. |
Modifier and Type | Method and Description |
---|---|
InetSocketAddress |
FileSystemContext.getMasterAddress() |
void |
FileSystemContext.reinit(boolean updateClusterConf)
Closes the context, updates configuration from meta master, then re-initializes the context.
|
Modifier and Type | Method and Description |
---|---|
InetSocketAddress |
JobContext.getJobMasterAddress() |
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,
String mediumType,
long blockId,
long length) |
void |
BlockMaster.commitBlock(long workerId,
long usedBytesOnTier,
String tierAlias,
String mediumType,
long blockId,
long length)
Marks a block as committed on a specific worker.
|
default 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() |
Set<WorkerNetAddress> |
DefaultBlockMaster.getWorkerAddresses() |
Set<WorkerNetAddress> |
BlockMaster.getWorkerAddresses() |
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(Collection<Long> blockIds,
boolean delete) |
void |
BlockMaster.removeBlocks(Collection<Long> blockIds,
boolean delete)
Removes blocks from workers.
|
Modifier and Type | Method and Description |
---|---|
void |
RpcContext.close() |
void |
DefaultFileSystemMaster.completeFile(AlluxioURI path,
CompleteFileContext context) |
void |
FileSystemMaster.completeFile(AlluxioURI path,
CompleteFileContext context)
Completes a file.
|
JournalContext |
DefaultFileSystemMaster.createJournalContext() |
RpcContext |
DefaultFileSystemMaster.createRpcContext() |
RpcContext |
DefaultFileSystemMaster.createRpcContext(OperationContext operationContext) |
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 |
FileSystemMaster.getFileInfo(AlluxioURI path,
GetStatusContext context)
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.getLostWorkerList() |
List<WorkerInfo> |
FileSystemMaster.getLostWorkerList() |
long |
DefaultFileSystemMaster.getNewBlockIdForFile(AlluxioURI path) |
long |
FileSystemMaster.getNewBlockIdForFile(AlluxioURI path)
Gets a new block id for the next block of a given file to write to.
|
List<WorkerInfo> |
DefaultFileSystemMaster.getWorkerInfoList() |
List<WorkerInfo> |
FileSystemMaster.getWorkerInfoList() |
void |
FileSystemMaster.listStatus(AlluxioURI path,
ListStatusContext context,
ResultStream<FileInfo> resultStream)
Enumerates given path to given batch tracker.
|
void |
DefaultFileSystemMaster.scheduleAsyncPersistence(AlluxioURI path,
ScheduleAsyncPersistenceContext context) |
void |
FileSystemMaster.scheduleAsyncPersistence(AlluxioURI path,
ScheduleAsyncPersistenceContext context)
Schedules a file for async persistence.
|
void |
DefaultFileSystemMaster.updateUfsMode(AlluxioURI ufsPath,
UfsMode ufsMode) |
void |
FileSystemMaster.updateUfsMode(AlluxioURI ufsPath,
UfsMode ufsMode)
Update the operation mode for the given ufs path under one or more mount points.
|
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 |
MergeJournalContext.close() |
void |
StateChangeJournalContext.close() |
void |
MasterJournalContext.close() |
void |
FileSystemMergeJournalContext.close() |
void |
JournalContext.close() |
JournalContext |
Journal.createJournalContext() |
void |
MergeJournalContext.flush() |
void |
StateChangeJournalContext.flush() |
void |
NoopJournalContext.flush() |
void |
MasterJournalContext.flush() |
void |
FileSystemMergeJournalContext.flush()
Merges all journals and then flushes them.
|
void |
JournalContext.flush()
Flushes all the entries appended by the journal context so far.
|
Modifier and Type | Method and Description |
---|---|
JournalContext |
RaftJournal.createJournalContext() |
Modifier and Type | Method and Description |
---|---|
JournalContext |
UfsJournal.createJournalContext() |
Modifier and Type | Method and Description |
---|---|
void |
DefaultMetaMaster.removePathConfiguration(String path) |
void |
MetaMaster.removePathConfiguration(String path)
Removes all properties for a path.
|
void |
DefaultMetaMaster.removePathConfiguration(String path,
Set<String> keys) |
void |
MetaMaster.removePathConfiguration(String path,
Set<String> keys)
Removes properties for a path.
|
void |
DefaultMetaMaster.setPathConfiguration(String path,
Map<PropertyKey,String> properties) |
void |
MetaMaster.setPathConfiguration(String path,
Map<PropertyKey,String> properties)
Sets properties for a path.
|
Modifier and Type | Method and Description |
---|---|
List<WorkerInfo> |
DefaultWorkerProvider.getLiveWorkerInfos() |
List<WorkerInfo> |
WorkerProvider.getLiveWorkerInfos()
Get live workerInfo list.
|
Modifier and Type | Method and Description |
---|---|
InetSocketAddress |
SelectionPolicyAnyMaster.getGrpcMasterAddress(MasterInquireClient masterInquireClient) |
InetSocketAddress |
SelectionPolicySpecifiedMaster.getGrpcMasterAddress(MasterInquireClient masterInquireClient) |
InetSocketAddress |
SelectionPolicyPrimaryMaster.getGrpcMasterAddress(MasterInquireClient masterInquireClient) |
abstract InetSocketAddress |
AbstractMasterSelectionPolicy.getGrpcMasterAddress(MasterInquireClient masterInquireClient) |
InetSocketAddress |
SelectionPolicyAnyStandbyMaster.getGrpcMasterAddress(MasterInquireClient masterInquireClient) |
InetSocketAddress |
MasterSelectionPolicy.getGrpcMasterAddress(MasterInquireClient masterInquireClient)
Gets the master address the client makes gRPC request to.
|
InetSocketAddress |
AbstractMasterSelectionPolicy.getPrimaryMasterAddressCached(MasterInquireClient masterInquireClient) |
InetSocketAddress |
MasterSelectionPolicy.getPrimaryMasterAddressCached(MasterInquireClient masterInquireClient)
Get and cache the primary master address.
|
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.
|
Copyright © 2023. All Rights Reserved.