Modifier and Type | Method and Description |
---|---|
void |
AbstractClient.connect()
Connects with the remote.
|
protected GrpcChannel |
AbstractClient.createChannel() |
protected long |
AbstractClient.getRemoteServiceVersion() |
void |
ClientContext.loadConf(InetSocketAddress address)
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 . |
protected <V> V |
AbstractClient.retryRPC(RetryPolicy retryPolicy,
AbstractClient.RpcCallable<V> rpc,
org.slf4j.Logger logger,
String rpcName,
String description,
Object... args) |
Modifier and Type | Method and Description |
---|---|
void |
RetryHandlingFileSystemMasterClient.checkAccess(AlluxioURI path,
CheckAccessPOptions options) |
void |
FileSystemMasterClient.checkAccess(AlluxioURI path,
CheckAccessPOptions options)
Check access to a path.
|
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.
|
boolean |
RetryHandlingFileSystemMasterClient.exists(AlluxioURI path,
ExistsPOptions options) |
boolean |
FileSystemMasterClient.exists(AlluxioURI path,
ExistsPOptions options)
Checks whether a file or directory exists.
|
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) |
long |
RetryHandlingFileSystemMasterClient.getMountId(AlluxioURI ufsUri) |
long |
FileSystemMasterClient.getMountId(AlluxioURI ufsUri)
Reverse resolve a ufs uri and get mount id.
|
default Map<String,MountPointInfo> |
FileSystemMasterClient.getMountTable()
Lists all mount points and their corresponding under storage addresses.
|
Map<String,MountPointInfo> |
RetryHandlingFileSystemMasterClient.getMountTable(boolean checkUfs) |
Map<String,MountPointInfo> |
FileSystemMasterClient.getMountTable(boolean checkUfs)
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) |
void |
RetryHandlingFileSystemMasterClient.iterateStatus(AlluxioURI path,
ListStatusPOptions options,
java.util.function.Consumer<? super URIStatus> action) |
void |
FileSystemMasterClient.iterateStatus(AlluxioURI path,
ListStatusPOptions options,
java.util.function.Consumer<? super URIStatus> action)
Performs a specific action on each
URIStatus in the result of FileSystemMasterClient.listStatus(alluxio.AlluxioURI, alluxio.grpc.ListStatusPOptions) . |
List<URIStatus> |
RetryHandlingFileSystemMasterClient.listStatus(AlluxioURI path,
ListStatusPOptions options) |
List<URIStatus> |
FileSystemMasterClient.listStatus(AlluxioURI path,
ListStatusPOptions options) |
ListStatusPartialResult |
RetryHandlingFileSystemMasterClient.listStatusPartial(AlluxioURI path,
ListStatusPartialPOptions options) |
ListStatusPartialResult |
FileSystemMasterClient.listStatusPartial(AlluxioURI path,
ListStatusPartialPOptions 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.needsSync(AlluxioURI path) |
void |
FileSystemMasterClient.needsSync(AlluxioURI path)
Mark a path as needed synchronization with the UFS, when this path or any
of its children are accessed, a sync with the UFS will be performed.
|
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.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.
|
Modifier and Type | Field and Description |
---|---|
com.github.oxo42.stateless4j.triggers.TriggerWithParameters1<AlluxioStatusException,NettyDataReaderStateMachine.TriggerEvent> |
NettyDataReaderStateMachine.TriggerEventsWithParam.mServerErrorEvent |
Modifier and Type | Method and Description |
---|---|
ServerErrorResponseEvent |
ResponseEventFactory.createServerErrorResponseEvent(AlluxioStatusException alluxioStatusException)
Create a ServerErrorResponseEvent.
|
Constructor and Description |
---|
ServerErrorResponseEvent(AlluxioStatusException alluxioStatusException)
Server error response event.
|
Modifier and Type | Method and Description |
---|---|
GetQuorumInfoPResponse |
RetryHandlingJournalMasterClient.getQuorumInfo() |
GetQuorumInfoPResponse |
JournalMasterClient.getQuorumInfo()
Quorum information for participating servers in journal.
|
GetTransferLeaderMessagePResponse |
RetryHandlingJournalMasterClient.getTransferLeaderMessage(String transferId) |
GetTransferLeaderMessagePResponse |
JournalMasterClient.getTransferLeaderMessage(String transferId)
Gets exception messages thrown when transferring the leader.
|
void |
RetryHandlingJournalMasterClient.removeQuorumServer(NetAddress serverAddress) |
void |
JournalMasterClient.removeQuorumServer(NetAddress serverAddress)
Removes a server from journal quorum.
|
void |
RetryHandlingJournalMasterClient.resetPriorities() |
void |
JournalMasterClient.resetPriorities()
Resets RaftPeer priorities.
|
String |
RetryHandlingJournalMasterClient.transferLeadership(NetAddress newLeaderNetAddress) |
String |
JournalMasterClient.transferLeadership(NetAddress newLeaderNetAddress)
Initiates changing the leading master of the quorum.
|
Modifier and Type | Method and Description |
---|---|
Map<String,MetricValue> |
RetryHandlingMetricsMasterClient.getMetrics() |
Map<String,MetricValue> |
MetricsMasterClient.getMetrics()
Gets all the metrics stored in the current master from metric name to metric value.
|
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) |
Modifier and Type | Method and Description |
---|---|
static void |
Configuration.loadClusterDefaults(InetSocketAddress address,
Scope scope)
Loads cluster default values for workers from the meta master if it's not loaded yet.
|
static GetConfigurationPResponse |
Configuration.loadConfiguration(InetSocketAddress address,
AlluxioConfiguration conf,
boolean ignoreClusterConf,
boolean ignorePathConf)
Loads configuration from meta master in one RPC.
|
Modifier and Type | Method and Description |
---|---|
static AlluxioRuntimeException |
AlluxioRuntimeException.from(AlluxioStatusException t)
Converts an arbitrary AlluxioStatusException to an Alluxio runtime exception.
|
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 |
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.
|
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.
|
Modifier and Type | Method and Description |
---|---|
protected void |
GrpcChannel.authenticate(AuthType authType,
Subject subject,
AlluxioConfiguration config) |
void |
GrpcChannel.authenticate(AuthType authType,
Subject subject,
AlluxioConfiguration config,
SaslClientHandler clientHandler) |
GrpcChannel |
GrpcChannelBuilder.build()
Creates an authenticated channel of type
GrpcChannel . |
protected SaslClientHandler |
GrpcChannel.createSaslClientHandler(AuthType authType,
Subject subject,
AlluxioConfiguration config) |
Modifier and Type | Method and Description |
---|---|
void |
RetryHandlingJobMasterMasterClient.connect() |
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 |
---|---|
void |
AuthenticatedChannelClientDriver.startAuthenticatedChannel(long timeoutMs)
Starts authentication with the server and wait until completion.
|
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. |
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.
|
Modifier and Type | Method and Description |
---|---|
void |
BlockMasterClient.commitBlock(long workerId,
long usedBytesOnTier,
String tierAlias,
String mediumType,
long blockId,
long length)
Commits a block on a worker.
|
Copyright © 2023. All Rights Reserved.