public abstract class AbstractReplicaMovementStrategy extends Object implements ReplicaMovementStrategy
Constructor and Description |
---|
AbstractReplicaMovementStrategy() |
Modifier and Type | Method and Description |
---|---|
Map<Integer,SortedSet<ExecutionTask>> |
applyStrategy(Set<ExecutionTask> replicaMovementTasks,
org.apache.kafka.common.Cluster cluster)
Determine the execution order for replica movement tasks based on a customized strategy.
|
ReplicaMovementStrategy |
chain(ReplicaMovementStrategy strategy)
Chain with another replica movement strategy to create a composite strategy.The returned strategy should use a combined rule
of two strategies in determining the task execution order.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
generateChainedReplicaMovementStrategies, name, taskComparator
public ReplicaMovementStrategy chain(ReplicaMovementStrategy strategy)
ReplicaMovementStrategy
chain
in interface ReplicaMovementStrategy
strategy
- The other replica movement strategy.public Map<Integer,SortedSet<ExecutionTask>> applyStrategy(Set<ExecutionTask> replicaMovementTasks, org.apache.kafka.common.Cluster cluster)
ReplicaMovementStrategy
applyStrategy
in interface ReplicaMovementStrategy
replicaMovementTasks
- The replica movement tasks to be executed.cluster
- The current cluster state.