Package | Description |
---|---|
alluxio.client.file | |
alluxio.client.metrics | |
alluxio.master | |
alluxio.master.selectionpolicy | |
alluxio.multi.process | |
alluxio.worker.job |
Modifier and Type | Method and Description |
---|---|
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. |
Modifier and Type | Method and Description |
---|---|
static void |
MetricsHeartbeatContext.addHeartbeat(ClientContext ctx,
MasterInquireClient inquireClient)
Sets up a new metrics heartbeat with the given client information.
|
Constructor and Description |
---|
ClientMasterSync(String appId,
ClientContext ctx,
MasterInquireClient inquireClient)
Constructs a new
ClientMasterSync . |
Modifier and Type | Class and Description |
---|---|
class |
PollingMasterInquireClient
PollingMasterInquireClient finds the address of the primary master by polling a list of master
addresses to see if their RPC servers are serving.
|
class |
SingleMasterInquireClient
A
MasterInquireClient which always returns a fixed master address. |
class |
ZkMasterInquireClient
Utility to get leader from zookeeper.
|
Modifier and Type | Field and Description |
---|---|
protected MasterInquireClient |
MasterClientContextBuilder.mMasterInquireClient |
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) |
MasterInquireClient |
MasterClientContext.getConfMasterInquireClient() |
MasterInquireClient |
MasterClientContext.getMasterInquireClient() |
Modifier and Type | Method and Description |
---|---|
MasterClientContextBuilder |
MasterClientContextBuilder.setMasterInquireClient(MasterInquireClient masterInquireClient)
Set the
MasterInquireClient that the config will use. |
Constructor and Description |
---|
MasterClientContext(ClientContext ctx,
MasterInquireClient masterInquireClient) |
Modifier and Type | Method and Description |
---|---|
InetSocketAddress |
SelectionPolicyAnyMaster.getGrpcMasterAddress(MasterInquireClient masterInquireClient) |
InetSocketAddress |
SelectionPolicyPrimaryMaster.getGrpcMasterAddress(MasterInquireClient masterInquireClient) |
InetSocketAddress |
SelectionPolicySpecifiedMaster.getGrpcMasterAddress(MasterInquireClient masterInquireClient) |
InetSocketAddress |
MasterSelectionPolicy.getGrpcMasterAddress(MasterInquireClient masterInquireClient)
Gets the master address the client makes gRPC request to.
|
abstract InetSocketAddress |
AbstractMasterSelectionPolicy.getGrpcMasterAddress(MasterInquireClient masterInquireClient) |
InetSocketAddress |
SelectionPolicyAnyStandbyMaster.getGrpcMasterAddress(MasterInquireClient masterInquireClient) |
InetSocketAddress |
MasterSelectionPolicy.getPrimaryMasterAddressCached(MasterInquireClient masterInquireClient)
Get and cache the primary master address.
|
InetSocketAddress |
AbstractMasterSelectionPolicy.getPrimaryMasterAddressCached(MasterInquireClient masterInquireClient) |
Modifier and Type | Method and Description |
---|---|
MasterInquireClient |
MultiProcessCluster.getMasterInquireClient() |
Modifier and Type | Method and Description |
---|---|
MasterInquireClient |
JobMasterClientContext.getConfMasterInquireClient() |
Constructor and Description |
---|
JobMasterClientContext(ClientContext context,
MasterInquireClient masterInquireClient,
MasterInquireClient confMasterInquireClient) |
Copyright © 2023. All Rights Reserved.