Uses of Class
alluxio.exception.status.UnavailableException

Packages that use UnavailableException

Package	Description
alluxio
alluxio.client.file
alluxio.client.job
alluxio.master
alluxio.master.block
alluxio.master.file
alluxio.master.file.async
alluxio.master.file.meta
alluxio.master.journal
alluxio.master.journal.raft
alluxio.master.journal.ufs
alluxio.master.meta
alluxio.master.selectionpolicy
alluxio.master.table.transform
alluxio.underfs

Uses of UnavailableException in alluxio

Methods in alluxio that throw UnavailableException

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.

Uses of UnavailableException in alluxio.client.file

Methods in alluxio.client.file that throw UnavailableException

Modifier and Type	Method and Description
InetSocketAddress	FileSystemContext.getMasterAddress()
void	FileSystemContext.reinit(boolean updateClusterConf, boolean updatePathConf) Closes the context, updates configuration from meta master, then re-initializes the context.

Uses of UnavailableException in alluxio.client.job

Methods in alluxio.client.job that throw UnavailableException

Modifier and Type	Method and Description
InetSocketAddress	JobContext.getJobMasterAddress()

Uses of UnavailableException in alluxio.master

Methods in alluxio.master that throw UnavailableException

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()

Uses of UnavailableException in alluxio.master.block

Methods in alluxio.master.block that throw UnavailableException

Modifier and Type	Method and Description
void	BlockMaster.commitBlock(long workerId, long usedBytesOnTier, String tierAlias, String mediumType, long blockId, long length) Marks a block as committed on a specific worker.
void	DefaultBlockMaster.commitBlock(long workerId, long usedBytesOnTier, String tierAlias, String mediumType, long blockId, long length)
default void	BlockMaster.commitBlockInUFS(long blockId, long length) Marks a block as committed, but without a worker location.
BlockInfo	BlockMaster.getBlockInfo(long blockId)
BlockInfo	DefaultBlockMaster.getBlockInfo(long blockId)
List<BlockInfo>	BlockMaster.getBlockInfoList(List<Long> blockIds) Retrieves information for the given list of block ids.
List<BlockInfo>	DefaultBlockMaster.getBlockInfoList(List<Long> blockIds)
List<WorkerInfo>	BlockMaster.getLostWorkersInfoList()
List<WorkerInfo>	DefaultBlockMaster.getLostWorkersInfoList()
long	DefaultBlockMaster.getNewContainerId()
long	ContainerIdGenerable.getNewContainerId()
Set<WorkerNetAddress>	BlockMaster.getWorkerAddresses()
Set<WorkerNetAddress>	DefaultBlockMaster.getWorkerAddresses()
List<WorkerInfo>	BlockMaster.getWorkerInfoList()
List<WorkerInfo>	DefaultBlockMaster.getWorkerInfoList()
List<WorkerInfo>	BlockMaster.getWorkerReport(GetWorkerReportOptions options) Gets the worker information list for report CLI.
List<WorkerInfo>	DefaultBlockMaster.getWorkerReport(GetWorkerReportOptions options)
void	BlockMaster.removeBlocks(Collection<Long> blockIds, boolean delete) Removes blocks from workers.
void	DefaultBlockMaster.removeBlocks(Collection<Long> blockIds, boolean delete)
void	BlockMaster.validateBlocks(java.util.function.Function<Long,Boolean> validator, boolean repair) Validates the integrity of blocks with respect to the validator.
void	DefaultBlockMaster.validateBlocks(java.util.function.Function<Long,Boolean> validator, boolean repair)

Uses of UnavailableException in alluxio.master.file

Methods in alluxio.master.file that throw UnavailableException

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()
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<SyncPointInfo>	FileSystemMaster.getSyncPathList()
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.
void	DefaultFileSystemMaster.validateInodeBlocks(boolean repair)
void	FileSystemMaster.validateInodeBlocks(boolean repair) Checks the integrity of the inodes with respect to the blocks of the system.

Uses of UnavailableException in alluxio.master.file.async

Methods in alluxio.master.file.async that throw UnavailableException

Modifier and Type	Method and Description
void	AsyncPersistHandler.scheduleAsyncPersistence(AlluxioURI path) Schedules a file for async persistence.
void	DefaultAsyncPersistHandler.scheduleAsyncPersistence(AlluxioURI path)

Uses of UnavailableException in alluxio.master.file.meta

Methods in alluxio.master.file.meta that throw UnavailableException

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.

Uses of UnavailableException in alluxio.master.journal

Methods in alluxio.master.journal that throw UnavailableException

Modifier and Type	Method and Description
void	MasterJournalContext.close()
void	MergeJournalContext.close()
void	FileSystemMergeJournalContext.close()
void	JournalContext.close()
void	StateChangeJournalContext.close()
JournalContext	Journal.createJournalContext()
void	MasterJournalContext.flush()
void	MergeJournalContext.flush()
void	NoopJournalContext.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.
void	StateChangeJournalContext.flush()

Uses of UnavailableException in alluxio.master.journal.raft

Methods in alluxio.master.journal.raft that throw UnavailableException

Modifier and Type	Method and Description
JournalContext	RaftJournal.createJournalContext()

Uses of UnavailableException in alluxio.master.journal.ufs

Methods in alluxio.master.journal.ufs that throw UnavailableException

Modifier and Type	Method and Description
JournalContext	UfsJournal.createJournalContext()

Uses of UnavailableException in alluxio.master.meta

Methods in alluxio.master.meta that throw UnavailableException

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.

Uses of UnavailableException in alluxio.master.selectionpolicy

Methods in alluxio.master.selectionpolicy that throw UnavailableException

Modifier and Type	Method and Description
InetSocketAddress	SelectionPolicyAnyMaster.getGrpcMasterAddress(MasterInquireClient masterInquireClient)
InetSocketAddress	SelectionPolicyPrimaryMaster.getGrpcMasterAddress(MasterInquireClient masterInquireClient)
InetSocketAddress	SelectionPolicySpecifiedMaster.getGrpcMasterAddress(MasterInquireClient masterInquireClient)
InetSocketAddress	MasterSelectionPolicy.getGrpcMasterAddress(MasterInquireClient masterInquireClient) Gets the master address the client makes gRPC request to.
abstract InetSocketAddress	AbstractMasterSelectionPolicy.getGrpcMasterAddress(MasterInquireClient masterInquireClient)
InetSocketAddress	SelectionPolicyAnyStandbyMaster.getGrpcMasterAddress(MasterInquireClient masterInquireClient)
InetSocketAddress	MasterSelectionPolicy.getPrimaryMasterAddressCached(MasterInquireClient masterInquireClient) Get and cache the primary master address.
InetSocketAddress	AbstractMasterSelectionPolicy.getPrimaryMasterAddressCached(MasterInquireClient masterInquireClient)

Uses of UnavailableException in alluxio.master.table.transform

Constructor parameters in alluxio.master.table.transform with type arguments of type UnavailableException

Constructor and Description
TransformManager(TransformManager.ThrowingSupplier<JournalContext,UnavailableException> createJournalContext, AlluxioCatalog catalog, JobMasterClient jobMasterClient) An internal job master client will be created.

Uses of UnavailableException in alluxio.underfs

Methods in alluxio.underfs that throw UnavailableException

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.