Package | Description |
---|---|
alluxio.master.block | |
alluxio.master.job | |
alluxio.master.meta | |
alluxio.master.meta.checkconf | |
alluxio.proxy | |
alluxio.wire |
Modifier and Type | Method and Description |
---|---|
void |
DefaultBlockMaster.registerLostWorkerFoundListener(java.util.function.Consumer<Address> function) |
void |
BlockMaster.registerLostWorkerFoundListener(java.util.function.Consumer<Address> function)
Registers callback functions to use when lost workers become alive.
|
void |
DefaultBlockMaster.registerNewWorkerConfListener(java.util.function.BiConsumer<Address,List<ConfigProperty>> function) |
void |
BlockMaster.registerNewWorkerConfListener(java.util.function.BiConsumer<Address,List<ConfigProperty>> function)
Registers callback functions to use when workers register with configuration.
|
void |
DefaultBlockMaster.registerWorkerDeleteListener(java.util.function.Consumer<Address> function) |
void |
BlockMaster.registerWorkerDeleteListener(java.util.function.Consumer<Address> function)
Registers callback functions to use when detecting lost workers.
|
void |
DefaultBlockMaster.registerWorkerLostListener(java.util.function.Consumer<Address> function) |
void |
BlockMaster.registerWorkerLostListener(java.util.function.Consumer<Address> function)
Registers callback functions to use when detecting lost workers.
|
Modifier and Type | Method and Description |
---|---|
long |
JobMaster.getMasterId(Address address)
Allocates an ID for the job master from the target address.
|
Modifier and Type | Method and Description |
---|---|
Address |
JobMasterInfo.getAddress() |
Address |
MasterInfo.getAddress() |
Address |
DefaultMetaMaster.getMasterAddress() |
Address |
MetaMaster.getMasterAddress() |
Modifier and Type | Method and Description |
---|---|
List<Address> |
DefaultMetaMaster.getMasterAddresses() |
List<Address> |
MetaMaster.getMasterAddresses() |
List<Address> |
DefaultMetaMaster.getWorkerAddresses() |
List<Address> |
MetaMaster.getWorkerAddresses() |
Modifier and Type | Method and Description |
---|---|
long |
RetryHandlingJobMasterMasterClient.getId(Address address)
Returns a master id for a master address.
|
long |
RetryHandlingMetaMasterMasterClient.getId(Address address)
Returns a master id for a master address.
|
long |
DefaultMetaMaster.getMasterId(Address address) |
long |
MetaMaster.getMasterId(Address address)
Returns a master id for the given master, creating one if the master is new.
|
Constructor and Description |
---|
JobMasterInfo(long id,
Address address)
Creates a new instance of
MasterInfo . |
JobMasterSync(Address masterAddress,
RetryHandlingJobMasterMasterClient masterClient)
Creates a new instance of
MetaMasterSync . |
MasterInfo(long id,
Address address)
Creates a new instance of
MasterInfo . |
MetaMasterSync(Address masterAddress,
RetryHandlingMetaMasterMasterClient masterClient)
Creates a new instance of
MetaMasterSync . |
Modifier and Type | Method and Description |
---|---|
Map<Address,List<ConfigRecord>> |
ConfigurationStore.getConfMap() |
List<Address> |
ConfigurationStore.getLiveNodeAddresses() |
Modifier and Type | Method and Description |
---|---|
void |
ConfigurationStore.handleNodeDelete(Address address)
Updates configuration when a node delete.
|
void |
ConfigurationStore.handleNodeLost(Address address)
Updates configuration when a live node becomes lost.
|
void |
ConfigurationStore.lostNodeFound(Address address)
Updates configuration when a lost node is found.
|
void |
ConfigurationStore.registerNewConf(Address address,
List<ConfigProperty> configList)
Registers new configuration information.
|
Constructor and Description |
---|
ProxyMasterSync(Address address,
MasterClientContext context,
long startTimeMs)
Creates a new instance of
ProxyMasterSync . |
RetryHandlingMetaMasterProxyClient(Address proxyAddress,
MasterClientContext conf,
long startTimeMs)
Creates a new meta master client.
|
Modifier and Type | Method and Description |
---|---|
static Address |
Address.fromProto(NetAddress address)
Creates a new instance of
Address from proto representation. |
Address |
MasterInfo.getAddress() |
Address |
Address.setHost(String host) |
Address |
Address.setRpcPort(int rpcPort) |
Modifier and Type | Method and Description |
---|---|
MasterInfo |
MasterInfo.setAddress(Address address) |
Constructor and Description |
---|
MasterInfo(long id,
Address address)
Creates a new instance of
MasterInfo . |
Copyright © 2023. All Rights Reserved.