Modifier and Type | Method and Description |
---|---|
UserState |
ClientContext.getUserState() |
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.
|
Modifier and Type | Method and Description |
---|---|
static JobContext |
JobContext.create(AlluxioConfiguration alluxioConf,
UserState userState)
Creates a job context.
|
Constructor and Description |
---|
HeartbeatThread(String executorName,
HeartbeatExecutor executor,
com.google.common.base.Supplier<Long> intervalSupplier,
AlluxioConfiguration conf,
UserState userState)
Convenience method for
HeartbeatThread(String, String, HeartbeatExecutor, Supplier, AlluxioConfiguration,
UserState) where threadId is null. |
HeartbeatThread(String executorName,
String threadId,
HeartbeatExecutor executor,
com.google.common.base.Supplier<Long> intervalSupplier,
AlluxioConfiguration conf,
UserState userState)
Creates a
Runnable to execute heartbeats for the given HeartbeatExecutor . |
Modifier and Type | Method and Description |
---|---|
UserState |
MasterContext.getUserState() |
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) |
CoreMasterContext.Builder |
CoreMasterContext.Builder.setUserState(UserState userState) |
Constructor and Description |
---|
MasterContext(JournalSystem journalSystem,
PrimarySelector primarySelector,
UserState userState,
T ufsManager)
Creates a new master context.
|
PollingMasterInquireClient(List<InetSocketAddress> masterAddresses,
AlluxioConfiguration alluxioConf,
UserState userState,
ServiceType serviceType) |
PollingMasterInquireClient(List<InetSocketAddress> masterAddresses,
java.util.function.Supplier<RetryPolicy> retryPolicySupplier,
AlluxioConfiguration alluxioConf,
UserState userState,
ServiceType serviceType) |
Modifier and Type | Field and Description |
---|---|
protected UserState |
AbstractBackupRole.mServerUserState
User information for server.
|
Modifier and Type | Method and Description |
---|---|
void |
TransformManager.start(ExecutorService executorService,
UserState userState)
Starts background heartbeats.
|
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 | Class and Description |
---|---|
class |
BaseUserState
Base implementation of
UserState . |
class |
NoopUserState
A UserState implementation which does nothing.
|
class |
SimpleUserState
UserState implementation for the simple authentication schemes.
|
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 |
SimpleUserState.Factory.create(Subject subject,
AlluxioConfiguration conf,
boolean isServer) |
UserState |
NoopUserState.Factory.create(Subject subject,
AlluxioConfiguration conf,
boolean isServer) |
UserState |
UserStateFactory.create(Subject subject,
AlluxioConfiguration conf,
boolean isServer) |
static UserState |
ServerUserState.global() |
Modifier and Type | Method and Description |
---|---|
static String |
SecurityUtils.getGroup(UserState userState,
AlluxioConfiguration conf) |
static String |
SecurityUtils.getOwner(UserState userState) |
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.
|
Copyright © 2023. All Rights Reserved.