Modifier and Type | Method and Description |
---|---|
AlluxioConfiguration |
ClientContext.getClusterConf() |
Modifier and Type | Method and Description |
---|---|
static <T> javax.ws.rs.core.Response |
RestUtils.call(RestUtils.RestCallable<T> callable,
AlluxioConfiguration alluxioConf)
Call response.
|
static <T> javax.ws.rs.core.Response |
RestUtils.call(RestUtils.RestCallable<T> callable,
AlluxioConfiguration alluxioConf,
Map<String,Object> headers)
Calls the given
RestUtils.RestCallable and handles any exceptions thrown. |
static ClientContext |
ClientContext.create(AlluxioConfiguration alluxioConf) |
static ClientContext |
ClientContext.create(Subject subject,
AlluxioConfiguration alluxioConf)
A client context with information about the subject and configuration of the client.
|
Modifier and Type | Method and Description |
---|---|
static void |
Format.format(Format.Mode mode,
AlluxioConfiguration alluxioConf)
Formats the Alluxio file system.
|
static int |
GetConf.getConfImpl(java.util.function.Supplier<RetryHandlingMetaMasterConfigClient> clientSupplier,
AlluxioConfiguration alluxioConf,
String... args)
Implements get configuration.
|
static void |
LogLevel.logLevel(String[] args,
AlluxioConfiguration alluxioConf)
Implements log level setting and getting.
|
static List<LogLevel.TargetInfo> |
LogLevel.parseOptTarget(org.apache.commons.cli.CommandLine cmd,
AlluxioConfiguration conf)
Parse the command options to a list of targets endpoints.
|
Modifier and Type | Method and Description |
---|---|
static String |
FileSystemShellUtils.getFilePath(String path,
AlluxioConfiguration alluxioConf)
Removes
Constants.HEADER and hostname:port information
from a path, leaving only the local file path. |
static String |
FileSystemShellUtils.validatePath(String path,
AlluxioConfiguration alluxioConf)
Validates the path, verifying that it contains the
Constants.HEADER and a
hostname:port specified. |
Modifier and Type | Method and Description |
---|---|
static void |
FileSystemAdminShellUtils.checkMasterClientService(AlluxioConfiguration alluxioConf)
Checks if the master client service is available.
|
Constructor and Description |
---|
BackupCommand(Context context,
AlluxioConfiguration alluxioConf) |
DoctorCommand(Context context,
AlluxioConfiguration alluxioConf) |
GetBlockInfoCommand(Context context,
AlluxioConfiguration alluxioConf) |
JournalCommand(Context context,
AlluxioConfiguration alluxioConf) |
MetricsCommand(Context context,
AlluxioConfiguration alluxioConf) |
PathConfCommand(Context context,
AlluxioConfiguration alluxioConf) |
ReportCommand(Context context,
AlluxioConfiguration alluxioConf) |
StateLockHoldersCommand(Context context,
AlluxioConfiguration alluxioConf) |
UfsCommand(Context context,
AlluxioConfiguration alluxioConf) |
UpdateConfCommand(Context context,
AlluxioConfiguration alluxioConf) |
Constructor and Description |
---|
CheckpointCommand(Context context,
AlluxioConfiguration alluxioConf) |
QuorumCommand(Context context,
AlluxioConfiguration alluxioConf) |
QuorumElectCommand(Context context,
AlluxioConfiguration alluxioConf) |
QuorumInfoCommand(Context context,
AlluxioConfiguration alluxioConf) |
QuorumRemoveCommand(Context context,
AlluxioConfiguration alluxioConf) |
Constructor and Description |
---|
ClearCommand(Context context,
AlluxioConfiguration alluxioConf) |
Constructor and Description |
---|
AddCommand(Context context,
AlluxioConfiguration alluxioConf) |
ListCommand(Context context,
AlluxioConfiguration alluxioConf) |
RemoveCommand(Context context,
AlluxioConfiguration alluxioConf) |
ShowCommand(Context context,
AlluxioConfiguration alluxioConf) |
Modifier and Type | Field and Description |
---|---|
protected AlluxioConfiguration |
HdfsConfValidationTask.mConf |
Constructor and Description |
---|
HdfsConfParityValidationTask(String path,
AlluxioConfiguration conf)
Constructor.
|
HdfsConfValidationTask(String path,
AlluxioConfiguration conf)
Creates a new instance of
HdfsConfValidationTask
for validating HDFS configuration. |
HdfsProxyUserValidationTask(String path,
AlluxioConfiguration conf)
Creates a new instance of
HdfsProxyUserValidationTask
for validating proxyuser configuration. |
HdfsVersionValidationTask(AlluxioConfiguration conf)
Creates a new instance of
HdfsVersionValidationTask
for validating HDFS version. |
SecureHdfsValidationTask(String process,
String path,
AlluxioConfiguration conf)
Constructor of
SecureHdfsValidationTask
for validating Kerberos login ability. |
Modifier and Type | Field and Description |
---|---|
protected AlluxioConfiguration |
AbstractTableCommand.mConf |
Modifier and Type | Method and Description |
---|---|
static BlockLocationPolicy |
BlockLocationPolicy.Factory.create(String blockLocationPolicyClass,
AlluxioConfiguration conf)
Factory for creating
BlockLocationPolicy . |
Constructor and Description |
---|
DeterministicHashPolicy(AlluxioConfiguration conf)
Constructs a new
DeterministicHashPolicy . |
LocalFirstAvoidEvictionPolicy(AlluxioConfiguration conf)
Constructs a new
LocalFirstAvoidEvictionPolicy . |
LocalFirstPolicy(AlluxioConfiguration conf)
Constructs a new
LocalFirstPolicy . |
MostAvailableFirstPolicy(AlluxioConfiguration conf)
Constructs a new
MostAvailableFirstPolicy . |
RoundRobinPolicy(AlluxioConfiguration conf)
Constructs a new
RoundRobinPolicy . |
SpecificHostPolicy(AlluxioConfiguration conf)
Constructs a new
SpecificHostPolicy . |
Modifier and Type | Method and Description |
---|---|
static BlockWorkerClient |
BlockWorkerClient.Factory.create(UserState userState,
GrpcServerAddress address,
AlluxioConfiguration alluxioConf)
Creates a new block worker client.
|
Constructor and Description |
---|
BlockInStream(DataReader.Factory dataReaderFactory,
AlluxioConfiguration conf,
WorkerNetAddress address,
BlockInStream.BlockInStreamSource blockSource,
long id,
long length)
Creates an instance of
BlockInStream . |
BlockWorkerClientPool(UserState userState,
GrpcServerAddress address,
int minCapacity,
int maxCapacity,
AlluxioConfiguration alluxioConf)
Creates a new block master client pool.
|
DefaultBlockWorkerClient(UserState userState,
GrpcServerAddress address,
AlluxioConfiguration alluxioConf)
Creates a client instance for communicating with block worker.
|
Modifier and Type | Method and Description |
---|---|
static Optional<Pair<WorkerNetAddress,Boolean>> |
BlockLocationUtils.nearest(TieredIdentity tieredIdentity,
List<WorkerNetAddress> addresses,
AlluxioConfiguration conf) |
Modifier and Type | Method and Description |
---|---|
AlluxioConfiguration |
FileSystemContext.getClusterConf() |
AlluxioConfiguration |
BaseFileSystem.getConf() |
AlluxioConfiguration |
DelegatingFileSystem.getConf() |
AlluxioConfiguration |
FileSystem.getConf() |
AlluxioConfiguration |
FileSystemCache.InstanceCachingFileSystem.getConf() |
AlluxioConfiguration |
FileSystemContext.getPathConf(AlluxioURI path)
The path level configuration is a
SpecificPathConfiguration . |
Modifier and Type | Method and Description |
---|---|
static FileSystem |
FileSystem.Factory.create(AlluxioConfiguration alluxioConf) |
static FileSystemContext |
FileSystemContext.create(AlluxioConfiguration conf)
Creates a
FileSystemContext with a null subject
and a null local block worker. |
static FileSystemContext |
FileSystemContext.create(Subject subject,
AlluxioConfiguration conf) |
static FileSystemContext |
FileSystemContext.create(Subject subject,
AlluxioConfiguration conf,
BlockWorker blockWorker) |
static FileSystemContext |
FileSystemContext.create(Subject subject,
MasterInquireClient masterInquireClient,
AlluxioConfiguration alluxioConf)
This method is provided for testing, use the
FileSystemContext.create(alluxio.conf.AlluxioConfiguration) methods. |
static FileSystem |
FileSystem.Factory.get(Subject subject,
AlluxioConfiguration conf) |
Constructor and Description |
---|
Key(Subject subject,
AlluxioConfiguration conf) |
Modifier and Type | Method and Description |
---|---|
AlluxioConfiguration |
LocalCacheFileSystem.getConf() |
Modifier and Type | Method and Description |
---|---|
static LocalCacheManager |
LocalCacheManager.create(AlluxioConfiguration conf) |
static MetaStore |
MetaStore.create(AlluxioConfiguration conf) |
static CacheManager |
CacheManager.Factory.get(AlluxioConfiguration conf) |
Constructor and Description |
---|
CacheManagerWithShadowCache(CacheManager cacheManager,
AlluxioConfiguration conf) |
DefaultMetaStore(AlluxioConfiguration conf) |
LocalCacheFileInStream(URIStatus status,
LocalCacheFileInStream.FileInStreamOpener fileOpener,
CacheManager cacheManager,
AlluxioConfiguration conf)
Constructor when the
URIStatus is already available. |
LocalCacheFileSystem(CacheManager cacheManage,
FileSystem fs,
AlluxioConfiguration conf) |
QuotaMetaStore(AlluxioConfiguration conf) |
Modifier and Type | Method and Description |
---|---|
static CacheEvictor |
CacheEvictor.create(AlluxioConfiguration conf) |
Constructor and Description |
---|
FIFOCacheEvictor(AlluxioConfiguration conf)
Required constructor.
|
LFUCacheEvictor(AlluxioConfiguration conf)
Required constructor.
|
LRUCacheEvictor(AlluxioConfiguration conf)
Required constructor.
|
NondeterministicLRUCacheEvictor(AlluxioConfiguration conf)
Required constructor.
|
UnevictableCacheEvictor(AlluxioConfiguration conf)
Required constructor.
|
Modifier and Type | Method and Description |
---|---|
static PageStoreOptions |
PageStoreOptions.create(AlluxioConfiguration conf) |
Modifier and Type | Method and Description |
---|---|
static OutStreamOptions |
OutStreamOptions.defaults(ClientContext context,
AlluxioConfiguration alluxioConf) |
Constructor and Description |
---|
InStreamOptions(URIStatus status,
AlluxioConfiguration alluxioConf)
Creates with the default
OpenFilePOptions . |
InStreamOptions(URIStatus status,
OpenFilePOptions options,
AlluxioConfiguration alluxioConf)
Creates with given
OpenFilePOptions instance. |
OutStreamOptions(CreateFilePOptions options,
ClientContext context,
AlluxioConfiguration alluxioConf)
Creates an
OutStreamOptions instance from given options. |
Modifier and Type | Method and Description |
---|---|
static JobContext |
JobContext.create(AlluxioConfiguration alluxioConf,
UserState userState)
Creates a job context.
|
static JobInfo |
JobGrpcClientUtils.getJobStatus(long jobId,
AlluxioConfiguration alluxioConf,
boolean verbose) |
static long |
JobGrpcClientUtils.run(JobConfig config,
int attempts,
AlluxioConfiguration alluxioConf)
Runs the specified job and waits for it to finish.
|
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 |
---|---|
AlluxioConfiguration |
ManagedBlockingUfsForwarder.getConfiguration() |
Modifier and Type | Class and Description |
---|---|
class |
InstancedConfiguration
Alluxio configuration.
|
Modifier and Type | Field and Description |
---|---|
static AlluxioConfiguration |
InstancedConfiguration.EMPTY_CONFIGURATION |
Constructor and Description |
---|
InstancedConfiguration(AlluxioConfiguration conf)
Creates a new instance of
InstancedConfiguration . |
Modifier and Type | Class and Description |
---|---|
class |
SpecificPathConfiguration
Configuration for a specific Alluxio path.
|
Modifier and Type | Method and Description |
---|---|
Optional<AlluxioConfiguration> |
PrefixPathConfiguration.getConfiguration(AlluxioURI path,
PropertyKey key) |
Optional<AlluxioConfiguration> |
PathConfiguration.getConfiguration(AlluxioURI path,
PropertyKey key) |
Modifier and Type | Method and Description |
---|---|
static PathConfiguration |
PathConfiguration.create(Map<String,AlluxioConfiguration> pathConf)
Factory method to create an implementation of
PathConfiguration . |
Constructor and Description |
---|
SpecificPathConfiguration(AlluxioConfiguration clusterConf,
PathConfiguration pathConf,
AlluxioURI path)
Constructs a new instance with the specified references without copying the underlying
properties.
|
Constructor and Description |
---|
PrefixPathConfiguration(Map<String,AlluxioConfiguration> configurations)
Constructs a new path level configuration.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ExtensionFactory<T,S extends AlluxioConfiguration>
A factory class for creating instance of
T based on configuration S . |
class |
ExtensionFactoryRegistry<T extends ExtensionFactory<?,S>,S extends AlluxioConfiguration>
An extension registry that uses the
ServiceLoader mechanism to automatically discover
available factories and provides a central place for obtaining actual extension instances. |
Modifier and Type | Method and Description |
---|---|
static FuseUmountable |
AlluxioFuse.launchFuse(FileSystem fs,
AlluxioConfiguration conf,
FuseMountOptions opts,
boolean blocking)
Launches Fuse application.
|
static List<String> |
AlluxioFuse.parseFuseOptions(String[] fuseOptions,
AlluxioConfiguration alluxioConf)
Parses user given fuse options to the format that Fuse application needs.
|
Constructor and Description |
---|
AlluxioFuseFileSystem(FileSystem fs,
FuseMountOptions opts,
AlluxioConfiguration conf)
Creates a new instance of
AlluxioFuseFileSystem . |
AlluxioJniFuseFileSystem(FileSystem fs,
FuseMountOptions opts,
AlluxioConfiguration conf)
Creates a new instance of
AlluxioJniFuseFileSystem . |
Modifier and Type | Method and Description |
---|---|
static AuthPolicy |
AuthPolicyFactory.create(FileSystem fileSystem,
AlluxioConfiguration conf,
AbstractFuseFileSystem fuseFileSystem)
Creates a new instance of
AuthPolicy . |
Constructor and Description |
---|
CustomAuthPolicy(FileSystem fileSystem,
AlluxioConfiguration conf,
AbstractFuseFileSystem fuseFileSystem) |
SystemUserGroupAuthPolicy(FileSystem fileSystem,
AlluxioConfiguration conf,
AbstractFuseFileSystem fuseFileSystem) |
Constructor and Description |
---|
FuseShell(FileSystem fs,
AlluxioConfiguration conf)
Creates a new instance of
FuseShell . |
Constructor and Description |
---|
MetadataCacheCommand(FileSystem fileSystem,
AlluxioConfiguration alluxioConfiguration) |
Modifier and Type | Method and Description |
---|---|
AlluxioConfiguration |
GrpcConnection.getConfiguration() |
Modifier and Type | Method and Description |
---|---|
GrpcConnection |
GrpcConnectionPool.acquireConnection(GrpcChannelKey channelKey,
AlluxioConfiguration conf)
Acquires and increases the ref-count for the
ManagedChannel . |
static GrpcChannelKey |
GrpcChannelKey.create(AlluxioConfiguration conf)
Creates a
GrpcChannelKey . |
static GrpcServerBuilder |
GrpcServerBuilder.forAddress(GrpcServerAddress serverAddress,
AlluxioConfiguration conf,
UserState userState)
Create an new instance of
GrpcServerBuilder with authentication support. |
static GrpcServerBuilder |
GrpcServerBuilder.forAddress(GrpcServerAddress serverAddress,
AuthenticationServer authenticationServer,
AlluxioConfiguration conf,
UserState userState)
Create an new instance of
GrpcServerBuilder with authentication support. |
static GrpcChannelBuilder |
GrpcChannelBuilder.newBuilder(GrpcServerAddress address,
AlluxioConfiguration conf)
Create a channel builder for given address using the given configuration.
|
void |
GrpcConnectionPool.releaseConnection(GrpcConnectionKey connectionKey,
AlluxioConfiguration conf)
Decreases the ref-count of the
ManagedChannel for the given address. |
Constructor and Description |
---|
GrpcConnection(GrpcConnectionKey key,
io.grpc.ManagedChannel managedChannel,
AlluxioConfiguration conf)
Creates a new connection object.
|
Modifier and Type | Field and Description |
---|---|
protected AlluxioConfiguration |
AbstractFileSystem.mAlluxioConf |
Modifier and Type | Method and Description |
---|---|
static AlluxioConfiguration |
HadoopUtils.toAlluxioConf(org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractFileSystem.initialize(URI uri,
org.apache.hadoop.conf.Configuration conf,
AlluxioConfiguration alluxioConfiguration)
Initialize the
FileSystem . |
static org.apache.hadoop.conf.Configuration |
HadoopConfigurationUtils.mergeAlluxioConfiguration(org.apache.hadoop.conf.Configuration source,
AlluxioConfiguration alluxioConf)
Merges an
AlluxioConfiguration into an hadoop
Configuration . |
Constructor and Description |
---|
HeartbeatThread(String executorName,
HeartbeatExecutor executor,
long intervalMs,
AlluxioConfiguration conf,
UserState userState)
Convenience method for
HeartbeatThread(String, String, HeartbeatExecutor, long, AlluxioConfiguration, UserState)
where threadId is null. |
HeartbeatThread(String executorName,
String threadId,
HeartbeatExecutor executor,
long intervalMs,
AlluxioConfiguration conf,
UserState userState)
Creates a
Runnable to execute heartbeats for the given HeartbeatExecutor . |
Constructor and Description |
---|
AgentProcess(AlluxioConfiguration conf)
Creates a new
AgentProcess . |
AgentProcessContext(AlluxioConfiguration conf)
Creates a new instance of
AgentProcessContext . |
AgentProcessContext(AlluxioConfiguration conf,
RpcClient<ManagerAgentServiceGrpc.ManagerAgentServiceBlockingStub> client)
Creates a new instance of
AgentProcessContext . |
Modifier and Type | Method and Description |
---|---|
static InetSocketAddress |
AgentRpcServer.getConfiguredAddress(AlluxioConfiguration conf) |
Constructor and Description |
---|
AgentRpcServer(AlluxioConfiguration conf,
AgentProcessContext ctx)
Creates and starts a new
GrpcServer . |
Constructor and Description |
---|
ProcessLauncher(AlluxioConfiguration conf)
Creates a new instances of
ProcessLauncher . |
Modifier and Type | Method and Description |
---|---|
static GrpcChannel |
RpcClient.createChannel(InetSocketAddress addr,
AlluxioConfiguration conf)
Creates a gRPC channel that uses NOSASL for security authentication type.
|
void |
HubSslContextProvider.init(AlluxioConfiguration conf) |
Constructor and Description |
---|
RpcClient(AlluxioConfiguration conf,
InetSocketAddress connectAddress,
java.util.function.Function<io.grpc.Channel,T> channelFactory,
java.util.function.Supplier<RetryPolicy> policySupplier)
Create a new instance of the
RpcClient . |
Modifier and Type | Method and Description |
---|---|
AlluxioConfiguration |
ManagerProcessContext.getConf() |
AlluxioConfiguration |
ManagerProcessContext.getUpdatedProps(AlluxioConfigurationSet configSet)
Get updated cluster configuration from the configuration set.
|
Constructor and Description |
---|
ManagerProcess(AlluxioConfiguration conf)
Creates a new
ManagerProcess . |
ManagerProcessContext(AlluxioConfiguration conf)
Creates a new instance of
ManagerProcessContext . |
Modifier and Type | Method and Description |
---|---|
static InetSocketAddress |
ManagerRpcServer.getBindAddress(AlluxioConfiguration conf) |
static InetSocketAddress |
ManagerRpcServer.getConnectAddress(AlluxioConfiguration conf) |
Constructor and Description |
---|
ManagerRpcServer(AlluxioConfiguration conf,
ManagerProcessContext ctx)
Creates and starts a new
GrpcServer . |
Modifier and Type | Method and Description |
---|---|
<T> Map<HubNodeAddress,T> |
HubCluster.exec(Set<HubNodeAddress> hosts,
AlluxioConfiguration conf,
java.util.function.Function<AgentManagerServiceGrpc.AgentManagerServiceBlockingStub,T> action,
ExecutorService svc)
Execute an RPC action on all nodes in the cluster.
|
Modifier and Type | Method and Description |
---|---|
static MasterInquireClient |
MasterInquireClient.Factory.create(AlluxioConfiguration conf,
UserState userState) |
static MasterInquireClient |
MasterInquireClient.Factory.createForJobMaster(AlluxioConfiguration conf,
UserState userState) |
static MasterInquireClient.ConnectDetails |
MasterInquireClient.Factory.getConnectDetails(AlluxioConfiguration conf) |
MasterHealthCheckClient.Builder |
MasterHealthCheckClient.Builder.withConfiguration(AlluxioConfiguration alluxioConf) |
Constructor and Description |
---|
JobMasterRpcHealthCheckClient(InetSocketAddress jobMasterAddress,
java.util.function.Supplier<RetryPolicy> retryPolicySupplier,
AlluxioConfiguration alluxioConf)
Creates a job_master health check client.
|
Constructor and Description |
---|
JournalSpaceMonitor(AlluxioConfiguration configuration)
Convenience method for
JournalSpaceMonitor(String, long) . |
Constructor and Description |
---|
GrpcMessagingClient(AlluxioConfiguration conf,
UserState userState,
ExecutorService executor,
String clientType)
Creates messaging client that can be used to connect to remote messaging servers.
|
GrpcMessagingServer(AlluxioConfiguration conf,
UserState userState,
ExecutorService executor,
GrpcMessagingProxy proxy)
Creates a transport server that can be used to accept connections from remote clients.
|
GrpcMessagingTransport(AlluxioConfiguration clientConf,
AlluxioConfiguration serverConf,
UserState clientUser,
UserState serverUser,
String clientType)
Creates
GrpcMessagingTransport based on Alluxio gRPC messaging. |
GrpcMessagingTransport(AlluxioConfiguration conf,
UserState user,
String clientType)
Creates
GrpcMessagingTransport based on Alluxio gRPC messaging. |
Modifier and Type | Method and Description |
---|---|
static TieredIdentity |
TieredIdentityFactory.fromString(String identityString,
AlluxioConfiguration conf) |
static TieredIdentity |
TieredIdentityFactory.localIdentity(AlluxioConfiguration conf) |
Modifier and Type | Field and Description |
---|---|
protected AlluxioConfiguration |
DefaultAuthenticationServer.mConfiguration
Alluxio client configuration.
|
Modifier and Type | Method and Description |
---|---|
static AuthenticationProvider |
AuthenticationProvider.Factory.create(AuthType authType,
AlluxioConfiguration conf) |
static User |
AuthenticatedClientUser.get(AlluxioConfiguration conf)
Gets the
User from the ThreadLocal variable. |
static String |
AuthenticatedClientUser.getAuthMethod(AlluxioConfiguration conf)
Gets the connection authentication method from the
ThreadLocal variable. |
static String |
AuthenticatedClientUser.getClientUser(AlluxioConfiguration conf)
Gets the user name from the
ThreadLocal variable. |
static String |
AuthenticatedClientUser.getConnectionUser(AlluxioConfiguration conf)
Gets the connection user name from the
ThreadLocal variable. |
static String |
AuthenticationUserUtils.getImpersonationUser(Subject subject,
AlluxioConfiguration conf) |
Constructor and Description |
---|
ChannelAuthenticator(GrpcConnection connection,
Subject subject,
AuthType authType,
AlluxioConfiguration conf)
Creates
ChannelAuthenticator instance. |
DefaultAuthenticationServer(String hostName,
AlluxioConfiguration conf)
Creates
DefaultAuthenticationServer instance. |
ImpersonationAuthenticator(AlluxioConfiguration conf)
Constructs a new
ImpersonationAuthenticator . |
Constructor and Description |
---|
SaslClientHandlerPlain(Subject subject,
AlluxioConfiguration conf)
Creates
SaslClientHandler instance for Plain/Custom. |
SaslServerHandlerPlain(String serverName,
AlluxioConfiguration conf,
ImpersonationAuthenticator authenticator)
Creates
SaslServerHandler for Plain/Custom. |
Modifier and Type | Method and Description |
---|---|
static GroupMappingService |
GroupMappingService.Factory.get(AlluxioConfiguration conf)
Gets the cached groups mapping service being used to map user-to-groups.
|
Modifier and Type | Field and Description |
---|---|
protected AlluxioConfiguration |
BaseUserState.mConf |
Modifier and Type | Method and Description |
---|---|
static UserState |
UserState.Factory.create(AlluxioConfiguration conf) |
static UserState |
UserState.Factory.create(AlluxioConfiguration conf,
Subject subject) |
static UserState |
UserState.Factory.create(AlluxioConfiguration conf,
Subject subject,
CommonUtils.ProcessType processType) |
UserState |
NoopUserState.Factory.create(Subject subject,
AlluxioConfiguration conf,
boolean isServer) |
UserState |
SimpleUserState.Factory.create(Subject subject,
AlluxioConfiguration conf,
boolean isServer) |
UserState |
UserStateFactory.create(Subject subject,
AlluxioConfiguration conf,
boolean isServer) |
Constructor and Description |
---|
BaseUserState(Subject subject,
AlluxioConfiguration conf) |
Constructor and Description |
---|
CachingBlockMapIterator(Map<BlockStoreLocation,List<Long>> blockLocationMap,
AlluxioConfiguration conf)
Constructor.
|
Constructor and Description |
---|
ClientIOWritePolicy(AlluxioConfiguration conf)
Constructs a new
ClientIOWritePolicy . |
Modifier and Type | Class and Description |
---|---|
class |
UnderFileSystemConfiguration
Ufs configuration properties, including ufs specific configuration and global configuration.
|
Modifier and Type | Method and Description |
---|---|
AlluxioConfiguration |
UnderFileSystemWithLogging.getConfiguration() |
AlluxioConfiguration |
BaseUnderFileSystem.getConfiguration() |
default AlluxioConfiguration |
UnderFileSystem.getConfiguration()
Gets the under file system configuration.
|
Modifier and Type | Method and Description |
---|---|
static UnderFileSystem |
UnderFileSystem.Factory.create(String path,
AlluxioConfiguration conf)
Creates the
UnderFileSystem instance according to its UFS path. |
static UnderFileSystem |
UnderFileSystem.Factory.createForRoot(AlluxioConfiguration conf) |
static UnderFileSystemConfiguration |
UnderFileSystemConfiguration.defaults(AlluxioConfiguration alluxioConf) |
static UnderFileSystemFactory |
UnderFileSystemFactoryRegistry.find(String path,
AlluxioConfiguration alluxioConf)
Finds the first Under File System factory that supports the given path.
|
protected int |
ObjectUnderFileSystem.getListingChunkLength(AlluxioConfiguration conf)
The number of items to query in a single listing chunk.
|
Modifier and Type | Method and Description |
---|---|
static MkdirsOptions |
MkdirsOptions.defaults(AlluxioConfiguration conf) |
static CreateOptions |
CreateOptions.defaults(AlluxioConfiguration conf) |
Modifier and Type | Method and Description |
---|---|
static AlluxioConfiguration |
ConfigurationUtils.getClusterConf(GetConfigurationPResponse response,
AlluxioConfiguration conf,
Scope scope)
Loads the cluster level configuration from the get configuration response,
filters out the configuration for certain scope, and merges it with the existing configuration.
|
static AlluxioConfiguration |
ConfigurationUtils.merge(AlluxioConfiguration conf,
Map<?,?> properties,
Source source)
Merges the current configuration properties with new properties.
|
Modifier and Type | Method and Description |
---|---|
static CheckAccessPOptions |
FileSystemOptions.checkAccessDefaults(AlluxioConfiguration conf) |
static CheckConsistencyPOptions |
FileSystemOptions.checkConsistencyDefaults(AlluxioConfiguration conf) |
static float |
ConfigurationUtils.checkRatio(AlluxioConfiguration conf,
PropertyKey key)
Checks that the given property key is a ratio from 0.0 and 1.0, throwing an exception if it is
not.
|
static FileSystemMasterCommonPOptions |
FileSystemOptions.commonDefaults(AlluxioConfiguration conf) |
static FileSystemMasterCommonPOptions |
FileSystemOptions.commonDefaults(AlluxioConfiguration conf,
boolean withOpId) |
static CreateDirectoryPOptions |
FileSystemOptions.createDirectoryDefaults(AlluxioConfiguration conf) |
static CreateFilePOptions |
FileSystemOptions.createFileDefaults(AlluxioConfiguration conf) |
static String |
IdUtils.createOrGetAppIdFromConfig(AlluxioConfiguration conf) |
static DeletePOptions |
FileSystemOptions.deleteDefaults(AlluxioConfiguration conf) |
static ExistsPOptions |
FileSystemOptions.existsDefaults(AlluxioConfiguration conf) |
static FreePOptions |
FileSystemOptions.freeDefaults(AlluxioConfiguration conf) |
static AlluxioConfiguration |
ConfigurationUtils.getClusterConf(GetConfigurationPResponse response,
AlluxioConfiguration conf,
Scope scope)
Loads the cluster level configuration from the get configuration response,
filters out the configuration for certain scope, and merges it with the existing configuration.
|
static List<ConfigProperty> |
ConfigurationUtils.getConfiguration(AlluxioConfiguration conf,
Scope scope)
Gets all configuration properties filtered by the specified scope.
|
static List<InetSocketAddress> |
ConfigurationUtils.getEmbeddedJournalAddresses(AlluxioConfiguration conf,
NetworkAddressUtils.ServiceType serviceType)
Gets the embedded journal addresses to use for the given service type (either master-raft or
job-master-raft).
|
static String |
SecurityUtils.getGroup(UserState userState,
AlluxioConfiguration conf) |
static String |
SecurityUtils.getGroupFromGrpcClient(AlluxioConfiguration conf) |
static List<String> |
CommonUtils.getGroups(String userName,
AlluxioConfiguration conf)
Using
CachedGroupMapping to get the group list of a user. |
static List<InetSocketAddress> |
ConfigurationUtils.getJobMasterEmbeddedJournalAddresses(AlluxioConfiguration conf) |
static List<InetSocketAddress> |
ConfigurationUtils.getJobMasterRpcAddresses(AlluxioConfiguration conf)
Gets the RPC addresses of all job masters based on the configuration.
|
static List<InetSocketAddress> |
ConfigurationUtils.getMasterEmbeddedJournalAddresses(AlluxioConfiguration conf) |
static Set<String> |
ConfigurationUtils.getMasterHostnames(AlluxioConfiguration conf)
Gets list of masters in conf directory.
|
static List<InetSocketAddress> |
ConfigurationUtils.getMasterRpcAddresses(AlluxioConfiguration conf)
Gets the RPC addresses of all masters based on the configuration.
|
static String |
SecurityUtils.getOwnerFromGrpcClient(AlluxioConfiguration conf) |
static PathConfiguration |
ConfigurationUtils.getPathConf(GetConfigurationPResponse response,
AlluxioConfiguration clusterConf)
Loads the path level configuration from the get configuration response.
|
static String |
CommonUtils.getPrimaryGroupName(String userName,
AlluxioConfiguration conf)
Gets the primary group name of a user.
|
static String |
ConfigurationUtils.getSchemeAuthority(AlluxioConfiguration conf) |
static Set<String> |
ConfigurationUtils.getServerHostnames(AlluxioConfiguration conf)
Gets list of masters/workers in conf directory.
|
static GetStatusPOptions |
FileSystemOptions.getStatusDefaults(AlluxioConfiguration conf) |
static String |
CommonUtils.getWorkerDataDirectory(String storageDir,
AlluxioConfiguration conf) |
static Set<String> |
ConfigurationUtils.getWorkerHostnames(AlluxioConfiguration conf)
Gets list of workers in conf directory.
|
static boolean |
SecurityUtils.isAuthenticationEnabled(AlluxioConfiguration conf)
Checks if authentication is enabled.
|
static boolean |
SecurityUtils.isAuthorizationEnabled(AlluxioConfiguration conf)
Checks if authorization is enabled.
|
static boolean |
ConfigurationUtils.isHaMode(AlluxioConfiguration conf) |
static boolean |
CommonUtils.isLocalHost(WorkerNetAddress address,
AlluxioConfiguration conf) |
static boolean |
SecurityUtils.isSecurityEnabled(AlluxioConfiguration conf)
Checks if security is enabled.
|
static boolean |
ConfigurationUtils.jobMasterHostConfigured(AlluxioConfiguration conf) |
static ListStatusPOptions |
FileSystemOptions.listStatusDefaults(AlluxioConfiguration conf) |
static GetConfigurationPResponse |
ConfigurationUtils.loadConfiguration(InetSocketAddress address,
AlluxioConfiguration conf,
boolean ignoreClusterConf,
boolean ignorePathConf)
Loads configuration from meta master in one RPC.
|
static LoadMetadataPOptions |
FileSystemOptions.loadMetadataDefaults(AlluxioConfiguration conf) |
static boolean |
ConfigurationUtils.masterHostConfigured(AlluxioConfiguration conf) |
static AlluxioConfiguration |
ConfigurationUtils.merge(AlluxioConfiguration conf,
Map<?,?> properties,
Source source)
Merges the current configuration properties with new properties.
|
static MountPOptions |
FileSystemOptions.mountDefaults(AlluxioConfiguration conf) |
static Optional<TieredIdentity> |
TieredIdentityUtils.nearest(TieredIdentity tieredIdentity,
List<TieredIdentity> identities,
AlluxioConfiguration conf) |
static OpenFilePOptions |
FileSystemOptions.openFileDefaults(AlluxioConfiguration conf) |
static RenamePOptions |
FileSystemOptions.renameDefaults(AlluxioConfiguration conf) |
static ScheduleAsyncPersistencePOptions |
FileSystemOptions.scheduleAsyncPersistDefaults(AlluxioConfiguration conf) |
static ScheduleAsyncPersistencePOptions |
FileSystemOptions.scheduleAsyncPersistenceDefaults(AlluxioConfiguration conf) |
static SetAclPOptions |
FileSystemOptions.setAclDefaults(AlluxioConfiguration conf) |
static SetAttributePOptions |
FileSystemOptions.setAttributeClientDefaults(AlluxioConfiguration conf)
Defaults for the SetAttribute RPC which should only be used on the client side.
|
static SetAttributePOptions |
FileSystemOptions.setAttributeDefaults(AlluxioConfiguration conf) |
static UnmountPOptions |
FileSystemOptions.unmountDefaults(AlluxioConfiguration conf) |
Modifier and Type | Method and Description |
---|---|
static boolean |
NetworkAddressUtils.containsLocalIp(List<InetSocketAddress> clusterAddresses,
AlluxioConfiguration conf) |
static InetSocketAddress |
NetworkAddressUtils.getBindAddress(NetworkAddressUtils.ServiceType service,
AlluxioConfiguration conf)
Helper method to get the bind hostname for a given service.
|
static String |
NetworkAddressUtils.getBindHost(NetworkAddressUtils.ServiceType service,
AlluxioConfiguration conf)
Helper method to get the
InetSocketAddress bind address on a given service. |
static Class<? extends io.netty.channel.Channel> |
NettyUtils.getChannelClass(boolean isDomainSocket,
PropertyKey key,
AlluxioConfiguration conf)
Get the proper channel class.
|
static ChannelType |
NettyUtils.getChannelType(PropertyKey key,
AlluxioConfiguration conf)
Get the proper channel type.
|
static String |
NetworkAddressUtils.getClientHostName(AlluxioConfiguration conf)
Gets the local hostname to be used by the client.
|
static InetSocketAddress |
NetworkAddressUtils.getConnectAddress(NetworkAddressUtils.ServiceType service,
AlluxioConfiguration conf)
Helper method to get the
InetSocketAddress address for client to communicate with the
service. |
static String |
NetworkAddressUtils.getConnectHost(NetworkAddressUtils.ServiceType service,
AlluxioConfiguration conf)
Provides an externally resolvable hostname for client to communicate with the service.
|
static SocketAddress |
NetworkAddressUtils.getDataPortSocketAddress(WorkerNetAddress netAddress,
AlluxioConfiguration conf)
Extracts dataPort socket address from Alluxio representation of network address.
|
static String |
NetworkAddressUtils.getLocalNodeName(AlluxioConfiguration conf)
Gets a local node name from configuration if it is available, falling back on localhost lookup.
|
static int |
NetworkAddressUtils.getPort(NetworkAddressUtils.ServiceType service,
AlluxioConfiguration conf)
Gets the port number on a given service type.
|
static Class<? extends io.netty.channel.ServerChannel> |
NettyUtils.getServerChannelClass(boolean isDomainSocket,
AlluxioConfiguration conf)
Returns the correct
ServerSocketChannel class for use by the
worker. |
static ChannelType |
NettyUtils.getUserChannel(AlluxioConfiguration conf)
Gets the ChannelType properly from the USER_NETWORK_NETTY_CHANNEL property key.
|
static ChannelType |
NettyUtils.getWorkerChannel(AlluxioConfiguration conf)
Gets the worker channel properly from the WORKER_NETWORK_NETTY_CHANNEL property key.
|
static boolean |
NettyUtils.isDomainSocketAccessible(WorkerNetAddress workerNetAddress,
AlluxioConfiguration conf) |
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 |
---|---|
static SslContextProvider |
SslContextProvider.Factory.create(AlluxioConfiguration conf)
Creates and initializes
SslContextProvider implementation
based on Alluxio configuration. |
void |
DefaultSslContextProvider.init(AlluxioConfiguration conf) |
void |
SslContextProvider.init(AlluxioConfiguration conf)
Initializes provider.
|
Constructor and Description |
---|
UIFileBlockInfo(FileBlockInfo fileBlockInfo,
AlluxioConfiguration alluxioConfiguration)
Creates a new instance of
UIFileBlockInfo . |
UIFileBlockInfo(long blockId,
long blockLength,
long blockLastAccessTimeMs,
String tierAlias,
AlluxioConfiguration alluxioConfiguration)
Creates a new instance of
UIFileBlockInfo . |
UIFileInfo(FileInfo info,
AlluxioConfiguration alluxioConfiguration,
List<String> orderedTierAliases)
Creates a new instance of
UIFileInfo . |
UIFileInfo(UIFileInfo.LocalFileInfo fileInfo,
AlluxioConfiguration alluxioConfiguration,
List<String> orderedTierAliases)
Creates a new instance of
UIFileInfo . |
UIFileInfo(URIStatus status,
AlluxioConfiguration alluxioConfiguration,
List<String> orderedTierAliases)
Creates a new instance of
UIFileInfo . |
Constructor and Description |
---|
WorkerHealthCheckClient(InetSocketAddress workerAddress,
java.util.function.Supplier<RetryPolicy> retryPolicySupplier,
AlluxioConfiguration alluxioConf)
Creates a worker health check client.
|
Constructor and Description |
---|
BlockMapIterator(Map<BlockStoreLocation,List<Long>> blockLocationMap,
AlluxioConfiguration conf)
Constructor.
|
Constructor and Description |
---|
JobWorkerHealthCheckClient(InetSocketAddress jobWorkerAddress,
java.util.function.Supplier<RetryPolicy> retryPolicySupplier,
AlluxioConfiguration alluxioConf)
Creates a worker health check client.
|
Copyright © 2023. All Rights Reserved.