Package | Description |
---|---|
alluxio.client.block | |
alluxio.client.file | |
alluxio.master | |
alluxio.multi.process |
Constructor and Description |
---|
BlockMasterClientPool(Subject subject,
MasterInquireClient masterInquireClient)
Creates a new block master client pool.
|
Modifier and Type | Method and Description |
---|---|
MasterInquireClient |
FileSystemContext.getMasterInquireClient() |
Modifier and Type | Method and Description |
---|---|
static FileSystemContext |
FileSystemContext.create(Subject subject,
MasterInquireClient masterInquireClient)
This method is provided for testing, use the
FileSystemContext.get() methods. |
Constructor and Description |
---|
FileSystemMasterClientPool(Subject subject,
MasterInquireClient masterInquireClient)
Creates a new file system master client pool.
|
FileSystemMasterClientPool(Subject subject,
MasterInquireClient masterInquireClient,
int clientThreads)
Creates a new file system master client pool.
|
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 | Method and Description |
---|---|
static MasterInquireClient |
MasterInquireClient.Factory.create()
Creates an instance of
MasterInquireClient based on the current configuration. |
static MasterInquireClient |
MasterInquireClient.Factory.create(AlluxioConfiguration conf) |
MasterInquireClient |
MasterClientConfig.getMasterInquireClient() |
Modifier and Type | Method and Description |
---|---|
MasterClientConfig |
MasterClientConfig.withMasterInquireClient(MasterInquireClient masterInquireClient) |
Modifier and Type | Method and Description |
---|---|
MasterInquireClient |
MultiProcessCluster.getMasterInquireClient() |
Copyright © 2023. All Rights Reserved.