voldemort.client.rebalance
Class RebalanceClusterPlan

java.lang.Object
  voldemort.client.rebalance.RebalanceClusterPlan

public class RebalanceClusterPlan
extends java.lang.Object

Compares the current cluster configuration with the target cluster configuration.
The end result is a map of target node-ids to another map of source node-ids and partitions desired to be stolen or fetched

Constructor Summary

RebalanceClusterPlan(Cluster currentCluster, Cluster targetCluster, java.util.List<StoreDefinition> storeDefs, boolean enabledDeletePartition)
Compares the currentCluster configuration with the desired targetConfiguration and builds a map of Target node-id to map of source node-ids and partitions desired to be stolen/fetched.

Method Summary

java.util.Queue<RebalanceNodePlan>	getRebalancingTaskQueue()
java.lang.String	printPartitionDistribution()
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

RebalanceClusterPlan

public RebalanceClusterPlan(Cluster currentCluster,
                            Cluster targetCluster,
                            java.util.List<StoreDefinition> storeDefs,
                            boolean enabledDeletePartition)

Compares the currentCluster configuration with the desired targetConfiguration and builds a map of Target node-id to map of source node-ids and partitions desired to be stolen/fetched.

Parameters:

currentCluster - The current cluster definition

targetCluster - The target cluster definition

storeDefs - The list of store definitions to rebalance

enabledDeletePartition - Delete the RW partition on the donor side after rebalance

Method Detail

getRebalancingTaskQueue

public java.util.Queue<RebalanceNodePlan> getRebalancingTaskQueue()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

printPartitionDistribution

public java.lang.String printPartitionDistribution()