Uses of Class
alluxio.exception.status.AlluxioStatusException

Packages that use AlluxioStatusException

Package	Description
alluxio
alluxio.cli.table.command
alluxio.client.file
alluxio.client.journal
alluxio.client.metrics
alluxio.client.table
alluxio.conf
alluxio.exception.status
alluxio.grpc
alluxio.security.authentication
alluxio.util
alluxio.util.network

Uses of AlluxioStatusException in alluxio

Methods in alluxio that throw AlluxioStatusException

Modifier and Type	Method and Description
void	AbstractClient.connect() Connects with the remote.
protected long	AbstractClient.getRemoteServiceVersion()
void	ClientContext.loadConf(InetSocketAddress address, boolean loadClusterConf, boolean loadPathConf) This method will load the cluster and path level configuration defaults and update the configuration in one RPC.
void	ClientContext.loadConfIfNotLoaded(InetSocketAddress address) Loads configuration if not loaded from meta master yet.
protected <V> V	AbstractClient.retryRPC(AbstractClient.RpcCallable<V> rpc, org.slf4j.Logger logger, String rpcName, String description, Object... args) Tries to execute an RPC defined as a AbstractClient.RpcCallable.

Uses of AlluxioStatusException in alluxio.cli.table.command

Methods in alluxio.cli.table.command that throw AlluxioStatusException

Modifier and Type	Method and Description
int	ListDatabasesCommand.listDatabases() Print attached databases to stdout.
int	ListDatabasesCommand.listTable(String db, String tableName) Print table information to stdout.
int	ListDatabasesCommand.listTables(String db) Print list of tables stdout.
int	DetachDatabaseCommand.run(org.apache.commons.cli.CommandLine cli)
int	AttachDatabaseCommand.run(org.apache.commons.cli.CommandLine cl)
int	SyncDatabaseCommand.run(org.apache.commons.cli.CommandLine cli)

Uses of AlluxioStatusException in alluxio.client.file

Methods in alluxio.client.file that throw AlluxioStatusException

Modifier and Type	Method and Description
List<AlluxioURI>	RetryHandlingFileSystemMasterClient.checkConsistency(AlluxioURI path, CheckConsistencyPOptions options)
List<AlluxioURI>	FileSystemMasterClient.checkConsistency(AlluxioURI path, CheckConsistencyPOptions options) Checks the consistency of Alluxio metadata against the under storage for all files and directories in a given subtree.
void	RetryHandlingFileSystemMasterClient.completeFile(AlluxioURI path, CompleteFilePOptions options)
void	FileSystemMasterClient.completeFile(AlluxioURI path, CompleteFilePOptions options) Marks a file as completed.
void	RetryHandlingFileSystemMasterClient.createDirectory(AlluxioURI path, CreateDirectoryPOptions options)
void	FileSystemMasterClient.createDirectory(AlluxioURI path, CreateDirectoryPOptions options) Creates a new directory.
URIStatus	RetryHandlingFileSystemMasterClient.createFile(AlluxioURI path, CreateFilePOptions options)
URIStatus	FileSystemMasterClient.createFile(AlluxioURI path, CreateFilePOptions options) Creates a new file.
void	RetryHandlingFileSystemMasterClient.delete(AlluxioURI path, DeletePOptions options)
void	FileSystemMasterClient.delete(AlluxioURI path, DeletePOptions options) Deletes a file or a directory.
void	RetryHandlingFileSystemMasterClient.free(AlluxioURI path, FreePOptions options)
void	FileSystemMasterClient.free(AlluxioURI path, FreePOptions options) Frees a file.
String	RetryHandlingFileSystemMasterClient.getFilePath(long fileId)
String	FileSystemMasterClient.getFilePath(long fileId)
Map<String,MountPointInfo>	RetryHandlingFileSystemMasterClient.getMountTable()
Map<String,MountPointInfo>	FileSystemMasterClient.getMountTable() Lists all mount points and their corresponding under storage addresses.
long	RetryHandlingFileSystemMasterClient.getNewBlockIdForFile(AlluxioURI path)
long	FileSystemMasterClient.getNewBlockIdForFile(AlluxioURI path)
List<String>	RetryHandlingFileSystemMasterClient.getStateLockHolders()
List<String>	FileSystemMasterClient.getStateLockHolders()
URIStatus	RetryHandlingFileSystemMasterClient.getStatus(AlluxioURI path, GetStatusPOptions options)
URIStatus	FileSystemMasterClient.getStatus(AlluxioURI path, GetStatusPOptions options)
List<SyncPointInfo>	RetryHandlingFileSystemMasterClient.getSyncPathList()
List<SyncPointInfo>	FileSystemMasterClient.getSyncPathList() get the list of paths that are currently being actively synced.
List<URIStatus>	RetryHandlingFileSystemMasterClient.listStatus(AlluxioURI path, ListStatusPOptions options)
List<URIStatus>	FileSystemMasterClient.listStatus(AlluxioURI path, ListStatusPOptions options)
void	RetryHandlingFileSystemMasterClient.mount(AlluxioURI alluxioPath, AlluxioURI ufsPath, MountPOptions options)
void	FileSystemMasterClient.mount(AlluxioURI alluxioPath, AlluxioURI ufsPath, MountPOptions options) Mounts the given UFS path under the given Alluxio path.
void	RetryHandlingFileSystemMasterClient.rename(AlluxioURI src, AlluxioURI dst)
void	FileSystemMasterClient.rename(AlluxioURI src, AlluxioURI dst) Renames a file or a directory.
void	RetryHandlingFileSystemMasterClient.rename(AlluxioURI src, AlluxioURI dst, RenamePOptions options)
void	FileSystemMasterClient.rename(AlluxioURI src, AlluxioURI dst, RenamePOptions options) Renames a file or a directory.
AlluxioURI	RetryHandlingFileSystemMasterClient.reverseResolve(AlluxioURI ufsUri)
AlluxioURI	FileSystemMasterClient.reverseResolve(AlluxioURI ufsUri) Reverse resolve a ufs uri.
void	RetryHandlingFileSystemMasterClient.scheduleAsyncPersist(AlluxioURI path, ScheduleAsyncPersistencePOptions options)
void	FileSystemMasterClient.scheduleAsyncPersist(AlluxioURI path, ScheduleAsyncPersistencePOptions options) Schedules the async persistence of the given file.
void	RetryHandlingFileSystemMasterClient.setAcl(AlluxioURI path, SetAclAction action, List<AclEntry> entries, SetAclPOptions options)
void	FileSystemMasterClient.setAcl(AlluxioURI path, SetAclAction action, List<AclEntry> entries, SetAclPOptions options) Sets the ACL for a path.
void	RetryHandlingFileSystemMasterClient.setAttribute(AlluxioURI path, SetAttributePOptions options)
void	FileSystemMasterClient.setAttribute(AlluxioURI path, SetAttributePOptions options) Sets the file or directory attributes.
void	RetryHandlingFileSystemMasterClient.startSync(AlluxioURI path)
void	FileSystemMasterClient.startSync(AlluxioURI path) Start the active syncing process for a specified path.
void	RetryHandlingFileSystemMasterClient.stopSync(AlluxioURI path)
void	FileSystemMasterClient.stopSync(AlluxioURI path) Stop the active syncing process for a specified path.
void	RetryHandlingFileSystemMasterClient.unmount(AlluxioURI alluxioPath)
void	FileSystemMasterClient.unmount(AlluxioURI alluxioPath) Unmounts the given Alluxio path.
void	RetryHandlingFileSystemMasterClient.updateMount(AlluxioURI alluxioPath, MountPOptions options)
void	FileSystemMasterClient.updateMount(AlluxioURI alluxioPath, MountPOptions options) Updates options of a mount point for the given Alluxio path.
void	RetryHandlingFileSystemMasterClient.updateUfsMode(AlluxioURI ufsUri, UpdateUfsModePOptions options)
void	FileSystemMasterClient.updateUfsMode(AlluxioURI ufsUri, UpdateUfsModePOptions options) Updates the operation mode for the given ufs path.

Uses of AlluxioStatusException in alluxio.client.journal

Methods in alluxio.client.journal that throw AlluxioStatusException

Modifier and Type	Method and Description
GetQuorumInfoPResponse	JournalMasterClient.getQuorumInfo() Quorum information for participating servers in journal.
GetQuorumInfoPResponse	RetryHandlingJournalMasterClient.getQuorumInfo()
void	JournalMasterClient.removeQuorumServer(NetAddress serverAddress) Removes a server from journal quorum.
void	RetryHandlingJournalMasterClient.removeQuorumServer(NetAddress serverAddress)

Uses of AlluxioStatusException in alluxio.client.metrics

Methods in alluxio.client.metrics that throw AlluxioStatusException

Modifier and Type	Method and Description
Map<String,MetricValue>	MetricsMasterClient.getMetrics() Gets all the metrics stored in the current master from metric name to metric value.
Map<String,MetricValue>	RetryHandlingMetricsMasterClient.getMetrics()

Uses of AlluxioStatusException in alluxio.client.table

Methods in alluxio.client.table that throw AlluxioStatusException

Modifier and Type	Method and Description
SyncStatus	TableMasterClient.attachDatabase(String udbType, String udbConnectionUri, String udbDbName, String dbName, Map<String,String> configuration, boolean ignoreSyncErrors) Attaches an existing database.
SyncStatus	RetryHandlingTableMasterClient.attachDatabase(String udbType, String udbConnectionUri, String udbDbName, String dbName, Map<String,String> configuration, boolean ignoreSyncErrors)
boolean	TableMasterClient.detachDatabase(String dbName) Detaches an existing database in the catalog master.
boolean	RetryHandlingTableMasterClient.detachDatabase(String dbName)
List<String>	TableMasterClient.getAllDatabases() Get a list of all database names.
List<String>	RetryHandlingTableMasterClient.getAllDatabases()
List<String>	TableMasterClient.getAllTables(String databaseName) Get a list of all table names.
List<String>	RetryHandlingTableMasterClient.getAllTables(String databaseName)
List<TransformJobInfo>	TableMasterClient.getAllTransformJobInfo()
List<TransformJobInfo>	RetryHandlingTableMasterClient.getAllTransformJobInfo()
Database	TableMasterClient.getDatabase(String databaseName) Get database metadata.
Database	RetryHandlingTableMasterClient.getDatabase(String databaseName)
Map<String,List<ColumnStatisticsInfo>>	TableMasterClient.getPartitionColumnStatistics(String databaseName, String tableName, List<String> partitionNames, List<String> columnNames) Get column statistics for selected partition and column.
Map<String,List<ColumnStatisticsInfo>>	RetryHandlingTableMasterClient.getPartitionColumnStatistics(String databaseName, String tableName, List<String> partitionNames, List<String> columnNames)
List<String>	TableMasterClient.getPartitionNames(String databaseName, String tableName) Get partition names with given database name and table name.
List<String>	RetryHandlingTableMasterClient.getPartitionNames(String databaseName, String tableName)
TableInfo	TableMasterClient.getTable(String databaseName, String tableName) Get table metadata.
TableInfo	RetryHandlingTableMasterClient.getTable(String databaseName, String tableName)
List<ColumnStatisticsInfo>	TableMasterClient.getTableColumnStatistics(String databaseName, String tableName, List<String> columnNames) Get table column statistics with given database name, table name and list of column names.
List<ColumnStatisticsInfo>	RetryHandlingTableMasterClient.getTableColumnStatistics(String databaseName, String tableName, List<String> columnNames)
TransformJobInfo	TableMasterClient.getTransformJobInfo(long jobId)
TransformJobInfo	RetryHandlingTableMasterClient.getTransformJobInfo(long jobId)
List<Partition>	TableMasterClient.readTable(String databaseName, String tableName, Constraint constraint) Returns metadata for reading a table given constraints.
List<Partition>	RetryHandlingTableMasterClient.readTable(String databaseName, String tableName, Constraint constraint)
SyncStatus	TableMasterClient.syncDatabase(String dbName) Syncs an existing database in the catalog master.
SyncStatus	RetryHandlingTableMasterClient.syncDatabase(String dbName)
long	TableMasterClient.transformTable(String dbName, String tableName, String definition) Transforms a table.
long	RetryHandlingTableMasterClient.transformTable(String dbName, String tableName, String definition)

Uses of AlluxioStatusException in alluxio.conf

Methods in alluxio.conf that throw AlluxioStatusException

Modifier and Type	Method and Description
static void	ServerConfiguration.loadWorkerClusterDefaults(InetSocketAddress address) Loads cluster default values for workers from the meta master if it's not loaded yet.

Uses of AlluxioStatusException in alluxio.exception.status

Subclasses of AlluxioStatusException in alluxio.exception.status

Modifier and Type	Class and Description
class	AbortedException Exception indicating that the operation was aborted, typically due to a concurrency issue like sequencer check failures, transaction aborts, etc.
class	AlreadyExistsException Exception indicating that an attempt to create an entity failed because one already exists.
class	CancelledException Exception indicating that an operation was cancelled (typically by the caller).
class	DataLossException Exception indicating unrecoverable data loss or corruption.
class	DeadlineExceededException Exception indicating that an operation was cancelled (typically by the caller).
class	FailedPreconditionException Exception indicating that operation was rejected because the system is not in a state required for the operation's execution.
class	InternalException Exception representing an internal error.
class	InvalidArgumentException Exception indicating that a client specified an invalid argument.
class	NotFoundException Exception indicating that some requested entity (e.g., file or directory) was not found.
class	OutOfRangeException Exception indicating that and operation was attempted past the valid range.
class	PermissionDeniedException Exception indicating that the caller does not have permission to execute the specified operation.
class	ResourceExhaustedException Exception indicating that some resource has been exhausted, perhaps a per-user quota, or perhaps the entire file system is out of space.
class	UnauthenticatedException Exception indicating that the request does not have valid authentication credentials for the operation.
class	UnavailableException Exception indicating that the service is currently unavailable.
class	UnimplementedException Exception indicating that an operation is not implemented or not supported/enabled in this service.
class	UnknownException Exception representing an unknown error.

Methods in alluxio.exception.status that return AlluxioStatusException

Modifier and Type	Method and Description
static AlluxioStatusException	AlluxioStatusException.from(io.grpc.Status status) Converts an Alluxio exception from status and message representation to native representation.
static AlluxioStatusException	AlluxioStatusException.fromAlluxioException(AlluxioException ae) Converts checked Alluxio exceptions to Alluxio status exceptions.
static AlluxioStatusException	AlluxioStatusException.fromCheckedException(Throwable throwable) Converts checked throwables to Alluxio status exceptions.
static AlluxioStatusException	AlluxioStatusException.fromIOException(IOException ioe) Converts an IOException to a corresponding status exception.
static AlluxioStatusException	AlluxioStatusException.fromStatusRuntimeException(io.grpc.StatusRuntimeException e) Converts a gRPC StatusRuntimeException to an Alluxio status exception.
static AlluxioStatusException	AlluxioStatusException.fromThrowable(Throwable t) Converts an arbitrary throwable to an Alluxio status exception.

Uses of AlluxioStatusException in alluxio.grpc

Methods in alluxio.grpc that throw AlluxioStatusException

Modifier and Type	Method and Description
GrpcChannel	GrpcChannelBuilder.build() Creates an authenticated channel of type GrpcChannel.

Uses of AlluxioStatusException in alluxio.security.authentication

Methods in alluxio.security.authentication that throw AlluxioStatusException

Modifier and Type	Method and Description
void	ChannelAuthenticator.authenticate() It builds an authenticated channel.
void	AuthenticatedChannelClientDriver.startAuthenticatedChannel(long timeoutMs) Starts authentication with the server and wait until completion.

Uses of AlluxioStatusException in alluxio.util

Methods in alluxio.util that throw AlluxioStatusException

Modifier and Type	Method and Description
static GetConfigurationPResponse	ConfigurationUtils.loadConfiguration(InetSocketAddress address, AlluxioConfiguration conf, boolean ignoreClusterConf, boolean ignorePathConf) Loads configuration from meta master in one RPC.
static void	CommonUtils.unwrapResponse(Protocol.Response response) Unwraps a Protocol.Response.
static void	CommonUtils.unwrapResponseFrom(Protocol.Response response, io.netty.channel.Channel channel) Unwraps a Protocol.Response associated with a channel.

Uses of AlluxioStatusException in alluxio.util.network

Methods in alluxio.util.network that throw AlluxioStatusException

Modifier and Type	Method and Description
static void	NetworkAddressUtils.pingService(InetSocketAddress address, ServiceType serviceType, AlluxioConfiguration conf, UserState userState) Test if the input address is serving an Alluxio service.