voldemort.client.rebalance
Class RebalanceController

java.lang.Object
  voldemort.client.rebalance.RebalanceController

public class RebalanceController
extends java.lang.Object

Constructor Summary

RebalanceController(Cluster cluster, RebalanceClientConfig config)

RebalanceController(java.lang.String bootstrapUrl, RebalanceClientConfig rebalanceConfig)

Method Summary

AdminClient	getAdminClient()
void	rebalance(Cluster targetCluster) Grabs the latest cluster definition rebalance(voldemort.cluster.Cluster, voldemort.cluster.Cluster)
void	rebalance(Cluster currentCluster, Cluster targetCluster) Grabs the store definition and calls rebalance(voldemort.cluster.Cluster, voldemort.cluster.Cluster, java.util.List)
void	rebalance(Cluster currentCluster, Cluster targetCluster, java.util.List<StoreDefinition> storeDefs) Does basic verification of the metadata + server state.
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

RebalanceController

public RebalanceController(java.lang.String bootstrapUrl,
                           RebalanceClientConfig rebalanceConfig)

RebalanceController

public RebalanceController(Cluster cluster,
                           RebalanceClientConfig config)

Method Detail

rebalance

public void rebalance(Cluster targetCluster)

Grabs the latest cluster definition rebalance(voldemort.cluster.Cluster, voldemort.cluster.Cluster)

Parameters:

targetCluster - Target cluster metadata

rebalance

public void rebalance(Cluster currentCluster,
                      Cluster targetCluster)

Grabs the store definition and calls rebalance(voldemort.cluster.Cluster, voldemort.cluster.Cluster, java.util.List)

Parameters:

currentCluster - Current cluster metadata

targetCluster - Target cluster metadata

rebalance

public void rebalance(Cluster currentCluster,
                      Cluster targetCluster,
                      java.util.List<StoreDefinition> storeDefs)

Does basic verification of the metadata + server state. Finally starts the rebalancing.

Parameters:

currentCluster - The cluster currently used on each node

targetCluster - The desired cluster after rebalance

storeDefs - Stores to rebalance

getAdminClient

public AdminClient getAdminClient()

stop

public void stop()