Package | Description |
---|---|
alluxio.master.block | |
alluxio.master.meta | |
alluxio.master.meta.checkconf | |
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.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 |
---|---|
Address |
MasterInfo.getAddress() |
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 |
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 |
---|
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>> |
ServerConfigurationStore.getConfMap() |
List<Address> |
ServerConfigurationStore.getLiveNodeAddresses() |
Modifier and Type | Method and Description |
---|---|
void |
ServerConfigurationStore.handleNodeLost(Address address)
Updates configuration when a live node becomes lost.
|
void |
ServerConfigurationStore.lostNodeFound(Address address)
Updates configuration when a lost node is found.
|
void |
ServerConfigurationStore.registerNewConf(Address address,
List<ConfigProperty> configList)
Registers new configuration information.
|
Modifier and Type | Method and Description |
---|---|
static Address |
Address.fromProto(NetAddress address)
Creates a new instance of
Address from proto representation. |
Address |
Address.setHost(String host) |
Address |
Address.setRpcPort(int rpcPort) |
Copyright © 2023. All Rights Reserved.