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.
|
protected void |
ClientContext.setClusterConf(AlluxioConfiguration alluxioConfiguration) |
Constructor and Description |
---|
ClientContext(Subject subject,
AlluxioConfiguration alluxioConf) |
Modifier and Type | Field and Description |
---|---|
protected AlluxioConfiguration |
AbstractShell.mConfiguration |
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.
|
Constructor and Description |
---|
CollectInfo(AlluxioConfiguration alluxioConf)
Creates a new instance of
CollectInfo . |
Modifier and Type | Field and Description |
---|---|
protected AlluxioConfiguration |
AbstractFuseShellCommand.mConf |
Constructor and Description |
---|
AbstractFuseShellCommand(FileSystem fileSystem,
AlluxioConfiguration conf,
String commandName) |
MetadataCacheCommand(FileSystem fs,
AlluxioConfiguration conf) |
Constructor and Description |
---|
AbstractMetadataCacheSubCommand(FileSystem fileSystem,
AlluxioConfiguration conf,
String commandName) |
DropAllCommand(FileSystem fs,
AlluxioConfiguration conf,
String parentCommandName) |
DropCommand(FileSystem fs,
AlluxioConfiguration conf,
String parentCommandName) |
SizeCommand(FileSystem fs,
AlluxioConfiguration conf,
String parentCommandName) |
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. |
Constructor and Description |
---|
FileSystemShell(AlluxioConfiguration alluxioConf)
Creates a new instance of
FileSystemShell . |
Modifier and Type | Method and Description |
---|---|
static void |
FileSystemAdminShellUtils.checkMasterClientService(AlluxioConfiguration alluxioConf)
Checks if the master client service is available.
|
Constructor and Description |
---|
FileSystemAdminShell(AlluxioConfiguration alluxioConf)
Construct a new instance of
FileSystemAdminShell . |
Modifier and Type | Method and Description |
---|---|
static List<WorkerNetAddress> |
WorkerAddressUtils.parseWorkerAddresses(String workerAddressesStr,
AlluxioConfiguration alluxioConf)
Parses a string to worker addresses.
|
Constructor and Description |
---|
BackupCommand(Context context,
AlluxioConfiguration alluxioConf) |
DecommissionWorkerCommand(Context context,
AlluxioConfiguration alluxioConf)
Constructs a new instance to decommission a given batch of workers from Alluxio.
|
DoctorCommand(Context context,
AlluxioConfiguration alluxioConf) |
EnableWorkerCommand(Context context,
AlluxioConfiguration alluxioConf) |
JournalCommand(Context context,
AlluxioConfiguration alluxioConf) |
MetricsCommand(Context context,
AlluxioConfiguration alluxioConf) |
NodesCommand(Context context,
AlluxioConfiguration alluxioConf) |
ReportCommand(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 |
---|
WorkerStatusCommand(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 | Method and Description |
---|---|
static BlockWorkerClient |
BlockWorkerClient.Factory.create(UserState userState,
GrpcServerAddress address,
AlluxioConfiguration alluxioConf)
Creates a new block worker client.
|
Constructor and Description |
---|
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.
|
DefaultBlockWorkerClient(UserState userState,
GrpcServerAddress address,
AlluxioConfiguration alluxioConf,
GrpcChannel streamingChannel,
GrpcChannel rpcChannel) |
Modifier and Type | Method and Description |
---|---|
static AllMastersWorkerInfo |
WorkerInfoUtil.getWorkerReportsFromAllMasters(AlluxioConfiguration configuration,
BlockMasterClient primaryMasterClient,
GetWorkerReportOptions options)
Get worker reports from all masters, including standby masters.
|
Modifier and Type | Method and Description |
---|---|
AlluxioConfiguration |
FileSystemContext.getClusterConf() |
AlluxioConfiguration |
FileSystemCache.InstanceCachingFileSystem.getConf() |
AlluxioConfiguration |
FileSystem.getConf() |
AlluxioConfiguration |
DelegatingFileSystem.getConf() |
Modifier and Type | Method and Description |
---|---|
static FileSystem |
FileSystem.Factory.create(AlluxioConfiguration alluxioConf) |
static FileSystemContext |
FileSystemContext.create(AlluxioConfiguration conf)
Creates a
FileSystemContext with an empty subject
and a null local block worker. |
FileSystemContext |
FileSystemContext.FileSystemContextFactory.create(AlluxioConfiguration conf)
Creates a
FileSystemContext with an empty subject
and a null local block worker. |
static FileSystemContext |
FileSystemContext.create(AlluxioConfiguration conf,
List<InetSocketAddress> masterAddresses)
Creates a
FileSystemContext with an empty subject
, a null local block worker, and the given master addresses. |
FileSystemContext |
FileSystemContext.FileSystemContextFactory.create(AlluxioConfiguration conf,
List<InetSocketAddress> masterAddresses)
Creates a
FileSystemContext with an empty subject
, a null local block worker, and the given master addresses. |
static FileSystemContext |
FileSystemContext.create(Subject subject,
AlluxioConfiguration conf) |
FileSystemContext |
FileSystemContext.FileSystemContextFactory.create(Subject subject,
AlluxioConfiguration conf) |
static FileSystemContext |
FileSystemContext.create(Subject subject,
MasterInquireClient masterInquireClient,
AlluxioConfiguration alluxioConf)
This method is provided for testing, use the
FileSystemContext.create(alluxio.conf.AlluxioConfiguration, java.util.List<java.net.InetSocketAddress>) methods. |
FileSystemContext |
FileSystemContext.FileSystemContextFactory.create(Subject subject,
MasterInquireClient masterInquireClient,
AlluxioConfiguration alluxioConf)
This method is provided for testing, use the
FileSystemContext.create(alluxio.conf.AlluxioConfiguration, java.util.List<java.net.InetSocketAddress>) methods. |
static FileSystem |
FileSystem.Factory.get(Subject subject,
AlluxioConfiguration conf)
Get a FileSystem from the cache with a given subject.
|
static boolean |
FileSystemUtils.metadataEnabled(AlluxioConfiguration conf) |
Constructor and Description |
---|
FileSystemContext(AlluxioConfiguration conf,
BlockWorker blockWorker,
List<InetSocketAddress> masterAddresses)
Initializes FileSystemContext ID.
|
Key(Subject subject,
AlluxioConfiguration conf) |
Modifier and Type | Method and Description |
---|---|
AlluxioConfiguration |
LocalCacheFileSystem.getConf() |
Modifier and Type | Method and Description |
---|---|
static ShadowCacheManager |
ShadowCacheManager.create(AlluxioConfiguration conf) |
static CacheManager |
CacheManager.Factory.create(AlluxioConfiguration conf) |
static CacheManagerOptions |
CacheManagerOptions.create(AlluxioConfiguration conf) |
static LocalCachePositionReader |
LocalCachePositionReader.create(AlluxioConfiguration conf,
CacheManager cacheManager,
CloseableSupplier<PositionReader> fallbackReader,
URIStatus status,
long pageSize,
CacheContext cacheContext) |
static CacheManager |
CacheManager.Factory.create(AlluxioConfiguration conf,
CacheManagerOptions options,
PageMetaStore pageMetaStore) |
static CacheManagerOptions |
CacheManagerOptions.createForWorker(AlluxioConfiguration conf) |
static CacheManager |
CacheManager.Factory.get(AlluxioConfiguration conf) |
Constructor and Description |
---|
CacheManagerWithShadowCache(CacheManager cacheManager,
AlluxioConfiguration conf) |
ClockCuckooShadowCacheManager(AlluxioConfiguration conf)
Create a ClockCuckooShadowCacheManager.
|
LocalCacheFileInStream(URIStatus status,
LocalCacheFileInStream.FileInStreamOpener fileOpener,
CacheManager cacheManager,
AlluxioConfiguration conf,
Optional<FileInStream> externalFileInStream)
Constructor when the
URIStatus is already available. |
LocalCacheFileSystem(CacheManager cacheManage,
FileSystem fs,
AlluxioConfiguration conf) |
MultipleBloomShadowCacheManager(AlluxioConfiguration conf)
Create a MultipleBloomShadowCacheManager.
|
Modifier and Type | Method and Description |
---|---|
static CacheFilter |
CacheFilter.create(AlluxioConfiguration conf)
Create a CacheFilter.
|
Constructor and Description |
---|
DefaultCacheFilter(AlluxioConfiguration conf,
String cacheConfigFile)
The default constructor.
|
Modifier and Type | Method and Description |
---|---|
static List<PageStoreOptions> |
PageStoreOptions.create(AlluxioConfiguration conf) |
static List<PageStoreOptions> |
PageStoreOptions.createForWorkerPageStore(AlluxioConfiguration conf) |
Modifier and Type | Method and Description |
---|---|
static WorkerLocationPolicy |
WorkerLocationPolicy.Factory.create(AlluxioConfiguration conf)
Factory for creating
WorkerLocationPolicy . |
Constructor and Description |
---|
ConsistentHashPolicy(AlluxioConfiguration conf)
Constructs a new
ConsistentHashPolicy . |
LocalWorkerPolicy(AlluxioConfiguration conf)
Constructs a new
LocalWorkerPolicy . |
Modifier and Type | Method and Description |
---|---|
static OutStreamOptions |
OutStreamOptions.defaults(FileSystemContext context,
AlluxioConfiguration alluxioConf) |
static FileSystemOptions.Builder |
FileSystemOptions.Builder.fromConf(AlluxioConfiguration conf)
Creates new builder from configuration.
|
Constructor and Description |
---|
InStreamOptions(URIStatus status,
AlluxioConfiguration alluxioConf)
Creates with the default
OpenFilePOptions . |
InStreamOptions(URIStatus status,
AlluxioConfiguration alluxioConf,
FileSystemContext context)
Creates with the default
OpenFilePOptions . |
InStreamOptions(URIStatus status,
OpenFilePOptions options,
AlluxioConfiguration alluxioConf,
FileSystemContext context)
Creates with given
OpenFilePOptions instance. |
OutStreamOptions(CreateFilePOptions options,
FileSystemContext context,
AlluxioConfiguration alluxioConf)
Creates an
OutStreamOptions instance from given options. |
OutStreamOptions(FileSystemContext context,
AlluxioConfiguration alluxioConf) |
Modifier and Type | Method and Description |
---|---|
AlluxioConfiguration |
UfsBaseFileSystem.getConf() |
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.
|
Modifier and Type | Method and Description |
---|---|
protected AlluxioConfiguration |
RpcPortHealthCheckClient.getConfiguration() |
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 | Method and Description |
---|---|
static AlluxioConfiguration |
Configuration.global() |
Modifier and Type | Method and Description |
---|---|
static InstancedConfiguration |
Configuration.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 GetConfigurationPResponse |
Configuration.loadConfiguration(InetSocketAddress address,
AlluxioConfiguration conf,
boolean ignoreClusterConf,
boolean ignorePathConf)
Loads configuration from meta master in one RPC.
|
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 AlluxioConfiguration |
AlluxioFuseUtils.tryLoadingConfigFromMaster(FileSystemContext fsContext)
Tries to laod Alluxio config from Alluxio Master through Grpc.
|
Modifier and Type | Method and Description |
---|---|
static LibfuseVersion |
AlluxioFuseUtils.getLibfuseVersion(AlluxioConfiguration conf)
Gets the libjnifuse version preference set by user.
|
static String |
AlluxioFuseUtils.getMountedRootPath(AlluxioConfiguration conf,
FuseOptions fuseOptions)
Gets the path be mounted to local fuse mount point.
|
static com.google.common.cache.LoadingCache<String,AlluxioURI> |
AlluxioFuseUtils.getPathResolverCache(AlluxioConfiguration conf,
FuseOptions options)
Gets the cache for resolving FUSE path into
AlluxioURI . |
void |
AlluxioFuse.start(AlluxioConfiguration conf)
Startup the FUSE process.
|
protected void |
AlluxioFuse.startCommon(AlluxioConfiguration conf,
FuseOptions fuseOptions,
FileSystemContext fsContext)
Start common functionalities for a fuse client.
|
protected static void |
AlluxioFuse.validateFuseConfAndOptions(AlluxioConfiguration conf,
FuseOptions options) |
Modifier and Type | Method and Description |
---|---|
static AuthPolicy |
AuthPolicyFactory.create(FileSystem fileSystem,
AlluxioConfiguration conf,
FuseFileSystem fuseFileSystem)
Creates a new instance of
AuthPolicy . |
static SystemUserGroupAuthPolicy |
SystemUserGroupAuthPolicy.create(FileSystem fileSystem,
AlluxioConfiguration conf,
Optional<FuseFileSystem> fuseFileSystem)
Creates a new system auth policy.
|
static LaunchUserGroupAuthPolicy |
LaunchUserGroupAuthPolicy.create(FileSystem fileSystem,
AlluxioConfiguration conf,
Optional<FuseFileSystem> fuseFileSystem)
Creates a new launch user auth policy.
|
static CustomAuthPolicy |
CustomAuthPolicy.create(FileSystem fileSystem,
AlluxioConfiguration conf,
Optional<FuseFileSystem> fuseFileSystem)
Creates a new custom auth policy.
|
Modifier and Type | Method and Description |
---|---|
static FuseOptions.Builder |
FuseOptions.Builder.fromConfig(AlluxioConfiguration conf)
Creates a new builder pre-populated with settings from the given configurations.
|
Modifier and Type | Method and Description |
---|---|
protected AlluxioConfiguration |
GrpcChannelBuilder.getConfiguration() |
Modifier and Type | Method and Description |
---|---|
GrpcChannel |
GrpcChannelPool.acquireChannel(GrpcNetworkGroup networkGroup,
GrpcServerAddress serverAddress,
AlluxioConfiguration conf,
boolean alwaysEnableTLS)
Acquires and increases the ref-count for the
ManagedChannel . |
protected void |
GrpcChannel.authenticate(AuthType authType,
Subject subject,
AlluxioConfiguration config) |
void |
GrpcChannel.authenticate(AuthType authType,
Subject subject,
AlluxioConfiguration config,
SaslClientHandler clientHandler) |
protected SaslClientHandler |
GrpcChannel.createSaslClientHandler(AuthType authType,
Subject subject,
AlluxioConfiguration config) |
static GrpcServerBuilder |
GrpcServerBuilder.forAddress(GrpcServerAddress serverAddress,
AlluxioConfiguration conf)
Create an new instance of
GrpcServerBuilder with authentication support. |
static GrpcServerBuilder |
GrpcServerBuilder.forAddress(GrpcServerAddress serverAddress,
AuthenticationServer authenticationServer,
AlluxioConfiguration conf)
Create a 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.
|
static GrpcChannelBuilder |
GrpcChannelBuilder.newBuilder(GrpcServerAddress address,
AlluxioConfiguration conf,
AuthType authType,
boolean alwaysEnableTLS)
Create a channel builder for given address using the given configuration.
|
static GrpcChannelBuilder |
GrpcChannelBuilder.newBuilder(GrpcServerAddress address,
AlluxioConfiguration conf,
boolean alwaysEnableTLS)
Create a channel builder for given address using the given configuration.
|
Constructor and Description |
---|
GrpcChannelBuilder(GrpcServerAddress address,
AlluxioConfiguration conf,
AuthType authType,
boolean alwaysEnableTLS) |
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 . |
Modifier and Type | Method and Description |
---|---|
static MasterInquireClient |
MasterInquireClient.Factory.create(AlluxioConfiguration conf,
UserState userState) |
static MasterInquireClient |
MasterInquireClient.Factory.createForAddresses(List<InetSocketAddress> addresses,
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)
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 StaticMembershipManager |
StaticMembershipManager.create(AlluxioConfiguration conf) |
static EtcdMembershipManager |
EtcdMembershipManager.create(AlluxioConfiguration conf) |
static MembershipManager |
MembershipManager.Factory.create(AlluxioConfiguration conf) |
static MembershipManager |
MembershipManager.Factory.get(AlluxioConfiguration conf)
Get or create a MembershipManager instance.
|
static AlluxioEtcdClient |
AlluxioEtcdClient.getInstance(AlluxioConfiguration conf)
Get the singleton instance of AlluxioEtcdClient.
|
Constructor and Description |
---|
AlluxioEtcdClient(AlluxioConfiguration conf)
CTOR for AlluxioEtcdClient.
|
EtcdMembershipManager(AlluxioConfiguration conf)
CTOR for EtcdMembershipManager.
|
EtcdMembershipManager(AlluxioConfiguration conf,
AlluxioEtcdClient alluxioEtcdClient)
CTOR for EtcdMembershipManager with given AlluxioEtcdClient client.
|
Modifier and Type | Method and Description |
---|---|
static String |
S3RestUtils.getUserFromAuthorization(String authorization,
AlluxioConfiguration conf)
Gets the user from the authorization header string for AWS Signature Version 4.
|
static boolean |
S3RestUtils.isAuthenticationEnabled(AlluxioConfiguration conf)
Checks if authentication is enabled.
|
Modifier and Type | Method and Description |
---|---|
static String |
NettyRestUtils.getUserFromAuthorization(String authorization,
AlluxioConfiguration conf)
Gets the user from the authorization header string for AWS Signature Version 4.
|
Modifier and Type | Method and Description |
---|---|
static Authenticator |
Authenticator.Factory.create(AlluxioConfiguration conf)
Creates and initializes
Authenticator implementation. |
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 |
AuthenticationUtils.getImpersonationUser(Subject subject,
AlluxioConfiguration conf) |
Constructor and Description |
---|
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) |
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 |
BaseUnderFileSystem.getConfiguration() |
AlluxioConfiguration |
UnderFileSystemWithLogging.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.
|
static List<String> |
UnderFileSystemFactoryRegistry.getSupportedVersions(String path,
AlluxioConfiguration ufsConf)
Get a list of supported versions for a particular UFS path.
|
Constructor and Description |
---|
ObjectLowLevelOutputStream(String bucketName,
String key,
com.google.common.util.concurrent.ListeningExecutorService executor,
long streamingUploadPartitionSize,
AlluxioConfiguration ufsConf)
Constructs a new stream for writing a file.
|
ObjectMultipartUploadOutputStream(String bucketName,
String key,
com.google.common.util.concurrent.ListeningExecutorService executor,
long multipartUploadPartitionSize,
AlluxioConfiguration ufsConf)
Constructs a new stream for writing a file.
|
UnderFileSystemConfiguration(AlluxioConfiguration alluxioConf,
boolean readOnly)
Constructs a new instance of
UnderFileSystemConfiguration with the given properties. |
Constructor and Description |
---|
COSMultipartUploadOutputStream(String bucketName,
String key,
com.qcloud.cos.COS COSClient,
com.google.common.util.concurrent.ListeningExecutorService executor,
AlluxioConfiguration ufsConf)
Constructs a new stream for writing a file.
|
Constructor and Description |
---|
OBSLowLevelOutputStream(String bucketName,
String key,
com.obs.services.IObsClient obsClient,
com.google.common.util.concurrent.ListeningExecutorService executor,
AlluxioConfiguration ufsConf)
Constructs a new stream for writing a file.
|
OBSMultipartUploadOutputStream(String bucketName,
String key,
com.obs.services.ObsClient OBSClient,
com.google.common.util.concurrent.ListeningExecutorService executor,
AlluxioConfiguration ufsConf)
Constructs a new stream for writing a file.
|
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 com.aliyun.oss.ClientBuilderConfiguration |
OSSUnderFileSystem.initializeOSSClientConfig(AlluxioConfiguration alluxioConf)
Creates an OSS
ClientConfiguration using an Alluxio Configuration. |
Constructor and Description |
---|
OSSLowLevelOutputStream(String bucketName,
String key,
com.aliyun.oss.OSS oss,
com.google.common.util.concurrent.ListeningExecutorService executor,
AlluxioConfiguration ufsConf)
Constructs a new stream for writing a file.
|
OSSMultipartUploadOutputStream(String bucketName,
String key,
com.aliyun.oss.OSS OSSClient,
com.google.common.util.concurrent.ListeningExecutorService executor,
AlluxioConfiguration ufsConf)
Constructs a new stream for writing a file.
|
Constructor and Description |
---|
S3ALowLevelOutputStream(String bucketName,
String key,
com.amazonaws.services.s3.AmazonS3 s3Client,
com.google.common.util.concurrent.ListeningExecutorService executor,
AlluxioConfiguration ufsConf)
Constructs a new stream for writing a file.
|
S3AMultipartUploadOutputStream(String bucketName,
String key,
com.amazonaws.services.s3.AmazonS3 s3Client,
com.google.common.util.concurrent.ListeningExecutorService executor,
AlluxioConfiguration ufsConf)
Constructs a new stream for writing a file.
|
Modifier and Type | Method and Description |
---|---|
static CheckAccessPOptions |
FileSystemOptionsUtils.checkAccessDefaults(AlluxioConfiguration conf) |
static CheckConsistencyPOptions |
FileSystemOptionsUtils.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 |
FileSystemOptionsUtils.commonDefaults(AlluxioConfiguration conf) |
static FileSystemMasterCommonPOptions |
FileSystemOptionsUtils.commonDefaults(AlluxioConfiguration conf,
boolean withOpId) |
static CreateDirectoryPOptions |
FileSystemOptionsUtils.createDirectoryDefaults(AlluxioConfiguration conf) |
static CreateDirectoryPOptions |
FileSystemOptionsUtils.createDirectoryDefaults(AlluxioConfiguration conf,
boolean withOpId) |
static CreateFilePOptions |
FileSystemOptionsUtils.createFileDefaults(AlluxioConfiguration conf) |
static CreateFilePOptions |
FileSystemOptionsUtils.createFileDefaults(AlluxioConfiguration conf,
boolean withOpId) |
static String |
IdUtils.createOrGetAppIdFromConfig(AlluxioConfiguration conf) |
static DeletePOptions |
FileSystemOptionsUtils.deleteDefaults(AlluxioConfiguration conf) |
static DeletePOptions |
FileSystemOptionsUtils.deleteDefaults(AlluxioConfiguration conf,
boolean withOpId) |
static ExistsPOptions |
FileSystemOptionsUtils.existsDefaults(AlluxioConfiguration conf) |
static FreePOptions |
FileSystemOptionsUtils.freeDefaults(AlluxioConfiguration conf) |
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 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 |
FileSystemOptionsUtils.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 |
FileSystemOptionsUtils.listStatusDefaults(AlluxioConfiguration conf) |
static ListStatusPartialPOptions |
FileSystemOptionsUtils.listStatusPartialDefaults(AlluxioConfiguration conf) |
static LoadMetadataPOptions |
FileSystemOptionsUtils.loadMetadataDefaults(AlluxioConfiguration conf) |
static boolean |
ConfigurationUtils.masterHostConfigured(AlluxioConfiguration conf) |
static MountPOptions |
FileSystemOptionsUtils.mountDefaults(AlluxioConfiguration conf) |
static OpenFilePOptions |
FileSystemOptionsUtils.openFileDefaults(AlluxioConfiguration conf) |
static RenamePOptions |
FileSystemOptionsUtils.renameDefaults(AlluxioConfiguration conf) |
static RenamePOptions |
FileSystemOptionsUtils.renameDefaults(AlluxioConfiguration conf,
boolean withOpId) |
static ScheduleAsyncPersistencePOptions |
FileSystemOptionsUtils.scheduleAsyncPersistDefaults(AlluxioConfiguration conf) |
static ScheduleAsyncPersistencePOptions |
FileSystemOptionsUtils.scheduleAsyncPersistenceDefaults(AlluxioConfiguration conf) |
static SetAclPOptions |
FileSystemOptionsUtils.setAclDefaults(AlluxioConfiguration conf) |
static SetAttributePOptions |
FileSystemOptionsUtils.setAttributeClientDefaults(AlluxioConfiguration conf)
Defaults for the SetAttribute RPC which should only be used on the client side.
|
static SetAttributePOptions |
FileSystemOptionsUtils.setAttributeDefaults(AlluxioConfiguration conf) |
static UnmountPOptions |
FileSystemOptionsUtils.unmountDefaults(AlluxioConfiguration conf) |
Modifier and Type | Method and Description |
---|---|
static String |
PathUtils.getPersistentTmpPath(AlluxioConfiguration ufsConfiguration,
String path)
Get temp path for async persistence job.
|
Modifier and Type | Method and Description |
---|---|
static boolean |
NetworkAddressUtils.containsLocalIp(List<InetSocketAddress> clusterAddresses,
AlluxioConfiguration conf) |
static InetSocketAddress |
NetworkAddressUtils.getBindAddress(NetworkAddressUtils.ServiceAttributeProvider service,
AlluxioConfiguration conf)
Helper method to get the bind hostname for a given service.
|
static String |
NetworkAddressUtils.getBindHost(NetworkAddressUtils.ServiceAttributeProvider 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.ServiceAttributeProvider service,
AlluxioConfiguration conf)
Helper method to get the
InetSocketAddress address for client to communicate with the
service. |
static String |
NetworkAddressUtils.getConnectHost(NetworkAddressUtils.ServiceAttributeProvider 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 int |
NetworkAddressUtils.getPort(NetworkAddressUtils.ServiceAttributeProvider service,
AlluxioConfiguration conf)
Gets the port number on a given service type.
|
static SocketAddress |
NetworkAddressUtils.getRpcPortSocketAddress(WorkerNetAddress netAddress,
AlluxioConfiguration conf)
Extracts rpcPort socket address from Alluxio representation of network address.
|
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 |
SslContextProvider.init(AlluxioConfiguration conf)
Initializes provider.
|
void |
DefaultSslContextProvider.init(AlluxioConfiguration conf) |
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.
|
Modifier and Type | Field and Description |
---|---|
protected AlluxioConfiguration |
PagedDoraWorker.mConf |
Modifier and Type | Method and Description |
---|---|
static PagedFileReader |
PagedFileReader.create(AlluxioConfiguration conf,
CacheManager cacheManager,
UnderFileSystem ufs,
String fileId,
String ufsPath,
long fileSize,
long startPosition)
Creates a new
PagedFileReader . |
Constructor and Description |
---|
DoraMetaManager(AlluxioConfiguration conf,
PagedDoraWorker doraWorker,
CacheManager cacheManger,
DoraUfsManager ufsManager)
Creates a dora meta manager.
|
PagedDoraWorker(AtomicReference<Long> workerId,
WorkerIdentity identity,
AlluxioConfiguration conf,
CacheManager cacheManager,
MembershipManager membershipManager)
Constructor.
|
PagedDoraWorker(AtomicReference<Long> workerId,
WorkerIdentity identity,
AlluxioConfiguration conf,
CacheManager cacheManager,
MembershipManager membershipManager,
BlockMasterClientPool blockMasterClientPool,
FileSystemContext fileSystemContext) |
Constructor and Description |
---|
JobWorkerHealthCheckClient(InetSocketAddress jobWorkerAddress,
java.util.function.Supplier<RetryPolicy> retryPolicySupplier,
AlluxioConfiguration alluxioConf)
Creates a worker health check client.
|
Constructor and Description |
---|
WorkerIdentityProvider(AlluxioConfiguration conf) |
WorkerIdentityProvider(AlluxioConfiguration conf,
java.util.function.Supplier<UUID> uuidGenerator) |
Copyright © 2023. All Rights Reserved.