public class PartitionBalancingAction extends Object implements BalancingAction
Constructor and Description |
---|
PartitionBalancingAction(Map<Replica,Broker> replicaMoves)
Create a partition balancing action that will move all replica of a
partition from one set of brokers to another set of brokers.
|
Modifier and Type | Method and Description |
---|---|
ActionAcceptance |
actionAcceptance(GoalBalancingActionAcceptance actionAcceptance,
ClusterModel clusterModel) |
ActionType |
balancingAction()
Get the type of action that provides balancing.
|
boolean |
equals(Object other) |
Map<String,Object> |
getJsonStructure() |
int |
hashCode() |
Map<Replica,Broker> |
replicaMoves()
Get the replica moves.
|
boolean |
selfSatisfied(ClusterModel clusterModel,
GoalBalancingActionAcceptance actionAcceptance) |
org.apache.kafka.common.TopicPartition |
topicPartition() |
String |
toString() |
public PartitionBalancingAction(Map<Replica,Broker> replicaMoves)
replicaMoves
- A map containing replica of a partition and their new
destination brokers.public ActionType balancingAction()
BalancingAction
balancingAction
in interface BalancingAction
public ActionAcceptance actionAcceptance(GoalBalancingActionAcceptance actionAcceptance, ClusterModel clusterModel)
actionAcceptance
in interface BalancingAction
public boolean selfSatisfied(ClusterModel clusterModel, GoalBalancingActionAcceptance actionAcceptance)
selfSatisfied
in interface BalancingAction
public Map<Replica,Broker> replicaMoves()
public org.apache.kafka.common.TopicPartition topicPartition()
topicPartition
in interface BalancingAction
public Map<String,Object> getJsonStructure()
getJsonStructure
in interface BalancingAction