Package | Description |
---|---|
alluxio | |
alluxio.client | |
alluxio.client.file | |
alluxio.exception.status | |
alluxio.network.protocol | |
alluxio.util |
Modifier and Type | Method and Description |
---|---|
void |
AbstractClient.connect()
Connects with the remote.
|
protected <V> V |
AbstractClient.retryRPC(AbstractClient.RpcCallable<V> rpc)
Tries to execute an RPC defined as a
AbstractClient.RpcCallable . |
protected <V> V |
AbstractClient.retryRPC(AbstractClient.RpcCallable<V> rpc,
String rpcName)
Tries to execute an RPC defined as a
AbstractClient.RpcCallable . |
Modifier and Type | Method and Description |
---|---|
Map<String,MetricValue> |
MetaMasterClient.getMetrics()
Gets a map of metrics property names and their values from metrics system.
|
Map<String,MetricValue> |
RetryHandlingMetaMasterClient.getMetrics() |
Modifier and Type | Method and Description |
---|---|
List<AlluxioURI> |
RetryHandlingFileSystemMasterClient.checkConsistency(AlluxioURI path,
CheckConsistencyOptions options) |
List<AlluxioURI> |
FileSystemMasterClient.checkConsistency(AlluxioURI path,
CheckConsistencyOptions 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,
CompleteFileOptions options) |
void |
FileSystemMasterClient.completeFile(AlluxioURI path,
CompleteFileOptions options)
Marks a file as completed.
|
void |
RetryHandlingFileSystemMasterClient.createDirectory(AlluxioURI path,
CreateDirectoryOptions options) |
void |
FileSystemMasterClient.createDirectory(AlluxioURI path,
CreateDirectoryOptions options)
Creates a new directory.
|
void |
RetryHandlingFileSystemMasterClient.createFile(AlluxioURI path,
CreateFileOptions options) |
void |
FileSystemMasterClient.createFile(AlluxioURI path,
CreateFileOptions options)
Creates a new file.
|
void |
RetryHandlingFileSystemMasterClient.delete(AlluxioURI path,
DeleteOptions options) |
void |
FileSystemMasterClient.delete(AlluxioURI path,
DeleteOptions options)
Deletes a file or a directory.
|
void |
RetryHandlingFileSystemMasterClient.free(AlluxioURI path,
FreeOptions options) |
void |
FileSystemMasterClient.free(AlluxioURI path,
FreeOptions options)
Frees a file.
|
String |
RetryHandlingFileSystemMasterClient.getFilePath(GetFilePathTOptions options) |
String |
FileSystemMasterClient.getFilePath(GetFilePathTOptions options) |
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) |
URIStatus |
RetryHandlingFileSystemMasterClient.getStatus(AlluxioURI path,
GetStatusOptions options) |
URIStatus |
FileSystemMasterClient.getStatus(AlluxioURI path,
GetStatusOptions options) |
List<URIStatus> |
RetryHandlingFileSystemMasterClient.listStatus(AlluxioURI path,
ListStatusOptions options) |
List<URIStatus> |
FileSystemMasterClient.listStatus(AlluxioURI path,
ListStatusOptions options) |
void |
RetryHandlingFileSystemMasterClient.loadMetadata(AlluxioURI path,
LoadMetadataOptions options) |
void |
FileSystemMasterClient.loadMetadata(AlluxioURI path,
LoadMetadataOptions options)
Deprecated.
since version 1.1 and will be removed in version 2.0
|
void |
RetryHandlingFileSystemMasterClient.mount(AlluxioURI alluxioPath,
AlluxioURI ufsPath,
MountOptions options) |
void |
FileSystemMasterClient.mount(AlluxioURI alluxioPath,
AlluxioURI ufsPath,
MountOptions 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,
RenameOptions options) |
void |
FileSystemMasterClient.rename(AlluxioURI src,
AlluxioURI dst,
RenameOptions options)
Renames a file or a directory.
|
void |
RetryHandlingFileSystemMasterClient.scheduleAsyncPersist(AlluxioURI path) |
void |
FileSystemMasterClient.scheduleAsyncPersist(AlluxioURI path)
Schedules the async persistence of the given file.
|
void |
RetryHandlingFileSystemMasterClient.setAttribute(AlluxioURI path,
SetAttributeOptions options) |
void |
FileSystemMasterClient.setAttribute(AlluxioURI path,
SetAttributeOptions options)
Sets the file or directory attributes.
|
void |
RetryHandlingFileSystemMasterClient.unmount(AlluxioURI alluxioPath) |
void |
FileSystemMasterClient.unmount(AlluxioURI alluxioPath)
Unmounts the given Alluxio path.
|
void |
RetryHandlingFileSystemMasterClient.updateUfsMode(AlluxioURI ufsUri,
UpdateUfsModeOptions options) |
void |
FileSystemMasterClient.updateUfsMode(AlluxioURI ufsUri,
UpdateUfsModeOptions options)
Updates the operation mode for the given ufs path.
|
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 |
CanceledException
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.
|
Modifier and Type | Method and Description |
---|---|
static AlluxioStatusException |
AlluxioStatusException.from(Status status,
String m)
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.fromThrift(AlluxioTException e)
Converts an Alluxio exception from Thrift representation to native representation.
|
static AlluxioStatusException |
AlluxioStatusException.fromThrowable(Throwable t)
Converts an arbitrary throwable to an Alluxio status exception.
|
Modifier and Type | Method and Description |
---|---|
static RPCProtoMessage |
RPCProtoMessage.createResponse(AlluxioStatusException se)
Creates a response for a given
AlluxioStatusException . |
Modifier and Type | Method and Description |
---|---|
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. |
Copyright © 2023. All Rights Reserved.