Package | Description |
---|---|
alluxio | |
alluxio.client.block | |
alluxio.client.file | |
alluxio.client.job | |
alluxio.client.journal | |
alluxio.client.meta | |
alluxio.client.metrics | |
alluxio.client.table | |
alluxio.common | |
alluxio.grpc | |
alluxio.master | |
alluxio.master.backup | |
alluxio.master.block | |
alluxio.master.file | |
alluxio.master.job | |
alluxio.master.meta | |
alluxio.master.metrics | |
alluxio.master.table | |
alluxio.util.network | |
alluxio.worker |
Worker process and utils for working with the worker remotely.
|
alluxio.worker.block | |
alluxio.worker.file | |
alluxio.worker.job |
Modifier and Type | Method and Description |
---|---|
protected abstract ServiceType |
AbstractClient.getRemoteServiceType() |
Modifier and Type | Method and Description |
---|---|
Map<ServiceType,GrpcService> |
Server.getServices() |
Modifier and Type | Method and Description |
---|---|
protected ServiceType |
RetryHandlingBlockMasterClient.getRemoteServiceType() |
Modifier and Type | Method and Description |
---|---|
protected ServiceType |
RetryHandlingFileSystemMasterClient.getRemoteServiceType() |
Modifier and Type | Method and Description |
---|---|
protected ServiceType |
RetryHandlingJobMasterClient.getRemoteServiceType() |
Modifier and Type | Method and Description |
---|---|
protected ServiceType |
RetryHandlingJournalMasterClient.getRemoteServiceType() |
Modifier and Type | Method and Description |
---|---|
protected ServiceType |
RetryHandlingMetaMasterClient.getRemoteServiceType() |
protected ServiceType |
RetryHandlingMetaMasterConfigClient.getRemoteServiceType() |
Modifier and Type | Method and Description |
---|---|
protected ServiceType |
RetryHandlingMetricsMasterClient.getRemoteServiceType() |
Modifier and Type | Method and Description |
---|---|
protected ServiceType |
RetryHandlingTableMasterClient.getRemoteServiceType() |
Constructor and Description |
---|
RpcPortHealthCheckClient(InetSocketAddress nodeAddress,
ServiceType serviceType,
java.util.function.Supplier<RetryPolicy> retryPolicySupplier,
AlluxioConfiguration alluxioConf)
Creates a worker health check client.
|
Modifier and Type | Method and Description |
---|---|
static ServiceType |
ServiceType.forNumber(int value) |
ServiceType |
GetServiceVersionPRequestOrBuilder.getServiceType()
optional .alluxio.grpc.version.ServiceType serviceType = 1; |
ServiceType |
GetServiceVersionPRequest.getServiceType()
optional .alluxio.grpc.version.ServiceType serviceType = 1; |
ServiceType |
GetServiceVersionPRequest.Builder.getServiceType()
optional .alluxio.grpc.version.ServiceType serviceType = 1; |
static ServiceType |
ServiceType.valueOf(com.google.protobuf.Descriptors.EnumValueDescriptor desc) |
static ServiceType |
ServiceType.valueOf(int value)
Deprecated.
Use
forNumber(int) instead. |
static ServiceType |
ServiceType.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static ServiceType[] |
ServiceType.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
static com.google.protobuf.Internal.EnumLiteMap<ServiceType> |
ServiceType.internalGetValueMap() |
Modifier and Type | Method and Description |
---|---|
GrpcServerBuilder |
GrpcServerBuilder.addService(ServiceType serviceType,
GrpcService serviceDefinition)
Add a service to this server.
|
GetServiceVersionPRequest.Builder |
GetServiceVersionPRequest.Builder.setServiceType(ServiceType value)
optional .alluxio.grpc.version.ServiceType serviceType = 1; |
Constructor and Description |
---|
ServiceVersionClientServiceHandler(Set<ServiceType> services)
Creates service version handler that allows given services.
|
Modifier and Type | Method and Description |
---|---|
Map<ServiceType,GrpcService> |
NoopMaster.getServices() |
Constructor and Description |
---|
MasterServingHealthCheck(InetSocketAddress nodeAddress,
ServiceType serviceType,
java.util.function.Supplier<RetryPolicy> retryPolicySupplier,
AlluxioConfiguration alluxioConf)
Creates a new instance of
MasterHealthCheckClient.MasterServingHealthCheck to check for an open RPC port
for the given service. |
Modifier and Type | Method and Description |
---|---|
Map<ServiceType,GrpcService> |
BackupLeaderRole.getRoleServices() |
Map<ServiceType,GrpcService> |
BackupRole.getRoleServices() |
Map<ServiceType,GrpcService> |
BackupWorkerRole.getRoleServices() |
Modifier and Type | Method and Description |
---|---|
Map<ServiceType,GrpcService> |
DefaultBlockMaster.getServices() |
Modifier and Type | Method and Description |
---|---|
protected ServiceType |
FileSystemMasterClient.getRemoteServiceType() |
Modifier and Type | Method and Description |
---|---|
Map<ServiceType,GrpcService> |
DefaultFileSystemMaster.getServices() |
Modifier and Type | Method and Description |
---|---|
Map<ServiceType,GrpcService> |
JobMaster.getServices() |
Modifier and Type | Method and Description |
---|---|
protected ServiceType |
RetryHandlingMetaMasterMasterClient.getRemoteServiceType() |
Modifier and Type | Method and Description |
---|---|
Map<ServiceType,GrpcService> |
DefaultMetaMaster.getServices() |
Modifier and Type | Method and Description |
---|---|
Map<ServiceType,GrpcService> |
DefaultMetricsMaster.getServices() |
Modifier and Type | Method and Description |
---|---|
Map<ServiceType,GrpcService> |
DefaultTableMaster.getServices() |
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 |
---|---|
Map<ServiceType,GrpcService> |
JobWorker.getServices() |
Modifier and Type | Method and Description |
---|---|
protected ServiceType |
BlockMasterClient.getRemoteServiceType() |
Modifier and Type | Method and Description |
---|---|
Map<ServiceType,GrpcService> |
DefaultBlockWorker.getServices() |
Modifier and Type | Method and Description |
---|---|
protected ServiceType |
FileSystemMasterClient.getRemoteServiceType() |
Modifier and Type | Method and Description |
---|---|
protected ServiceType |
RetryHandlingJobMasterClient.getRemoteServiceType() |
Copyright © 2023. All Rights Reserved.