Modifier and Type | Method and Description |
---|---|
UserState |
ClientContext.getUserState() |
Modifier and Type | Method and Description |
---|---|
static JobContext |
JobContext.create(AlluxioConfiguration alluxioConf,
UserState userState)
Creates a job context.
|
Modifier and Type | Method and Description |
---|---|
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. |
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 . |
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.createForJobMaster(AlluxioConfiguration conf,
UserState userState) |
CoreMasterContext.Builder |
CoreMasterContext.Builder.setUserState(UserState userState) |
Constructor and Description |
---|
MasterContext(JournalSystem journalSystem,
UserState userState)
Creates a new master context.
|
PollingMasterInquireClient(List<InetSocketAddress> masterAddresses,
AlluxioConfiguration alluxioConf,
UserState userState) |
PollingMasterInquireClient(List<InetSocketAddress> masterAddresses,
java.util.function.Supplier<RetryPolicy> retryPolicySupplier,
AlluxioConfiguration alluxioConf,
UserState userState) |
Constructor and Description |
---|
CopycatGrpcClient(AlluxioConfiguration conf,
UserState userState,
ExecutorService executor)
Creates copycat transport client that can be used to connect to remote copycat servers.
|
CopycatGrpcServer(AlluxioConfiguration conf,
UserState userState,
ExecutorService executor,
CopycatGrpcProxy proxy)
Creates copycat transport server that can be used to accept connections from remote copycat
clients.
|
CopycatGrpcTransport(AlluxioConfiguration clientConf,
AlluxioConfiguration serverConf,
UserState clientUser,
UserState serverUser)
Creates
Transport for CopyCat that uses Alluxio gRPC. |
CopycatGrpcTransport(AlluxioConfiguration conf,
UserState user)
Creates
Transport for CopyCat that uses Alluxio gRPC. |
Modifier and Type | Method and Description |
---|---|
void |
TransformManager.start(ExecutorService executorService,
UserState userState)
Starts background heartbeats.
|
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 |
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) |
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.