public class NoOpDataBalanceEngine extends java.lang.Object implements DataBalanceEngine
Constructor and Description |
---|
NoOpDataBalanceEngine() |
Modifier and Type | Method and Description |
---|---|
void |
addBrokers(java.util.Set<java.lang.Integer> brokersToAdd,
java.lang.String uid) |
boolean |
cancelBrokerRemoval(int brokerId)
Cancel the on-going broker removal operation for the given #
brokerId |
DataBalanceEngineContext |
getDataBalanceEngineContext()
Return
DataBalanceEngineContext associated with this DataBalanceEngine. |
boolean |
isActive() |
void |
onActivation(EngineInitializationContext initializationContext)
To be called when this DataBalanceEngine should be activated and start running.
|
void |
onDeactivation()
To be called when this DataBalanceEngine should stop execution.
|
void |
removeBroker(int brokerToRemove,
java.util.Optional<java.lang.Long> brokerToRemoveEpoch,
java.lang.String uid)
Request is invalid if its get handled by SBK while its not controller.
|
void |
setAutoHealMode(boolean shouldAutoHeal)
Enable or disable auto-healing (automatic execution of rebalance plans) when an imbalanced
cluster is detected and broker membership doesn't change.
|
void |
shutdown()
To be called when the object is going away.
|
void |
updateThrottle(java.lang.Long newThrottle)
Update the replication throttles to be used during proposal execution.
|
public DataBalanceEngineContext getDataBalanceEngineContext()
DataBalanceEngine
DataBalanceEngineContext
associated with this DataBalanceEngine.getDataBalanceEngineContext
in interface DataBalanceEngine
public void onActivation(EngineInitializationContext initializationContext)
DataBalanceEngine
onActivation
in interface DataBalanceEngine
public void onDeactivation()
DataBalanceEngine
onDeactivation
in interface DataBalanceEngine
public void shutdown()
DataBalanceEngine
shutdown
in interface DataBalanceEngine
public void updateThrottle(java.lang.Long newThrottle)
DataBalanceEngine
updateThrottle
in interface DataBalanceEngine
newThrottle
- -- new throttle in bytes/second.public void setAutoHealMode(boolean shouldAutoHeal)
DataBalanceEngine
setAutoHealMode
in interface DataBalanceEngine
shouldAutoHeal
- -- if auto-healing should be enabled when goal violations are detected.public boolean isActive()
isActive
in interface DataBalanceEngine
public void removeBroker(int brokerToRemove, java.util.Optional<java.lang.Long> brokerToRemoveEpoch, java.lang.String uid)
removeBroker
in interface DataBalanceEngine
public void addBrokers(java.util.Set<java.lang.Integer> brokersToAdd, java.lang.String uid)
addBrokers
in interface DataBalanceEngine
public boolean cancelBrokerRemoval(int brokerId)
DataBalanceEngine
brokerId
cancelBrokerRemoval
in interface DataBalanceEngine