Uses of Class
voldemort.client.rebalance.RebalancePartitionsInfo

Packages that use RebalancePartitionsInfo

voldemort.client.protocol.admin	Classes that abstract admin based Voldemort requests.
voldemort.client.protocol.pb	A protocol buffers based client-side request format.
voldemort.client.rebalance	All classes associated with the rebalance controller tool.
voldemort.client.rebalance.task
voldemort.server.rebalance	Classes dealing with rebalancing on the server side.
voldemort.server.rebalance.async
voldemort.store.metadata	Our in-memory metadata store on the server which is backed by the configuration files.
voldemort.utils	Basic helper functions.

Uses of RebalancePartitionsInfo in voldemort.client.protocol.admin

Methods in voldemort.client.protocol.admin with parameters of type RebalancePartitionsInfo

int	AdminClient.RebalancingOperations.rebalanceNode(RebalancePartitionsInfo stealInfo) Rebalance a stealer-donor node pair for a set of stores.

Method parameters in voldemort.client.protocol.admin with type arguments of type RebalancePartitionsInfo

int	AdminClient.RebalancingOperations.rebalanceNode(java.util.List<RebalancePartitionsInfo> stealInfos) Rebalance a stealer-donor node pair for a set of stores.
void	AdminClient.RebalancingOperations.rebalanceStateChange(Cluster existingCluster, Cluster transitionCluster, java.util.List<RebalancePartitionsInfo> rebalancePartitionPlanList, boolean swapRO, boolean changeClusterMetadata, boolean changeRebalanceState, boolean rollback, boolean failEarly) Used in rebalancing to indicate change in states.

Uses of RebalancePartitionsInfo in voldemort.client.protocol.pb

Methods in voldemort.client.protocol.pb that return RebalancePartitionsInfo

static RebalancePartitionsInfo

ProtoUtils.decodeRebalancePartitionInfoMap(VAdminProto.RebalancePartitionInfoMap rebalancePartitionInfoMap) Given a protobuf rebalance-partition info, converts it into our rebalance-partition info

Methods in voldemort.client.protocol.pb that return types with arguments of type RebalancePartitionsInfo

static java.util.List<RebalancePartitionsInfo>

ProtoUtils.decodeRebalancePartitionInfoMap(java.util.List<VAdminProto.RebalancePartitionInfoMap> rebalancePartitionInfoMaps) Given a list protobuf rebalance-partition info, converts it into a list of our rebalance-partition info

Methods in voldemort.client.protocol.pb with parameters of type RebalancePartitionsInfo

static VAdminProto.RebalancePartitionInfoMap

ProtoUtils.encodeRebalancePartitionInfoMap(RebalancePartitionsInfo stealInfo) Given a rebalance-partition info, convert it into the protobuf equivalent

Method parameters in voldemort.client.protocol.pb with type arguments of type RebalancePartitionsInfo

static java.util.List<VAdminProto.RebalancePartitionInfoMap>

ProtoUtils.encodeRebalancePartitionInfoMap(java.util.List<RebalancePartitionsInfo> stealInfos) Given a list of rebalance-partition info, convert it into a list of protobuf equivalent

Uses of RebalancePartitionsInfo in voldemort.client.rebalance

Methods in voldemort.client.rebalance that return RebalancePartitionsInfo

static RebalancePartitionsInfo	RebalancePartitionsInfo.create(java.util.Map<?,?> map)
static RebalancePartitionsInfo	RebalancePartitionsInfo.create(java.lang.String line)

Methods in voldemort.client.rebalance that return types with arguments of type RebalancePartitionsInfo

java.util.List<RebalancePartitionsInfo>	OrderedClusterTransition.getOrderedRebalancePartitionsInfoList()
java.util.List<RebalancePartitionsInfo>	RebalanceNodePlan.getRebalanceTaskList()

Constructor parameters in voldemort.client.rebalance with type arguments of type RebalancePartitionsInfo

RebalanceNodePlan(int nodeId, java.util.List<RebalancePartitionsInfo> rebalanceTaskList, boolean isNodeStealer)

Uses of RebalancePartitionsInfo in voldemort.client.rebalance.task

Fields in voldemort.client.rebalance.task with type parameters of type RebalancePartitionsInfo

protected java.util.List<RebalancePartitionsInfo>

RebalanceTask.stealInfos

Methods in voldemort.client.rebalance.task that return types with arguments of type RebalancePartitionsInfo

java.util.List<RebalancePartitionsInfo>

RebalanceTask.getStealInfos()

Constructors in voldemort.client.rebalance.task with parameters of type RebalancePartitionsInfo

StealerBasedRebalanceTask(int taskId, RebalancePartitionsInfo stealInfo, RebalanceClientConfig config, java.util.concurrent.Semaphore donorPermit, AdminClient adminClient)

Constructor parameters in voldemort.client.rebalance.task with type arguments of type RebalancePartitionsInfo

DonorBasedRebalanceTask(int taskId, java.util.List<RebalancePartitionsInfo> stealInfos, RebalanceClientConfig config, java.util.concurrent.Semaphore donorPermit, AdminClient adminClient)

RebalanceTask(int taskId, java.util.List<RebalancePartitionsInfo> stealInfos, RebalanceClientConfig config, java.util.concurrent.Semaphore donorPermit, AdminClient adminClient)

Uses of RebalancePartitionsInfo in voldemort.server.rebalance

Fields in voldemort.server.rebalance with type parameters of type RebalancePartitionsInfo

protected java.util.Map<java.lang.Integer,RebalancePartitionsInfo>

RebalancerState.stealInfoMap

Methods in voldemort.server.rebalance that return RebalancePartitionsInfo

RebalancePartitionsInfo	RebalancerState.find(int donorId)
RebalancePartitionsInfo	RebalancerState.find(java.lang.String storeName, java.util.List<java.lang.Integer> keyPartitions, java.util.List<java.lang.Integer> nodePartitions)

Methods in voldemort.server.rebalance that return types with arguments of type RebalancePartitionsInfo

java.util.Collection<RebalancePartitionsInfo>

RebalancerState.getAll()

Methods in voldemort.server.rebalance with parameters of type RebalancePartitionsInfo

int	Rebalancer.rebalanceNode(RebalancePartitionsInfo stealInfo) This function is responsible for starting the actual async rebalance operation.
boolean	RebalancerState.remove(RebalancePartitionsInfo rebalancePartitionsInfo)
boolean	RebalancerState.update(RebalancePartitionsInfo rebalancePartitionsInfo)

Method parameters in voldemort.server.rebalance with type arguments of type RebalancePartitionsInfo

int	Rebalancer.rebalanceNodeOnDonor(java.util.List<RebalancePartitionsInfo> stealInfos) This function is responsible for starting the actual async rebalance operation.
void	Rebalancer.rebalanceStateChange(Cluster cluster, java.util.List<RebalancePartitionsInfo> rebalancePartitionsInfo, boolean swapRO, boolean changeClusterMetadata, boolean changeRebalanceState, boolean rollback) Support four different stages For normal operation:

Constructor parameters in voldemort.server.rebalance with type arguments of type RebalancePartitionsInfo

RebalancerState(java.util.List<RebalancePartitionsInfo> stealInfoList)

Uses of RebalancePartitionsInfo in voldemort.server.rebalance.async

Constructors in voldemort.server.rebalance.async with parameters of type RebalancePartitionsInfo

StealerBasedRebalanceAsyncOperation(Rebalancer rebalancer, VoldemortConfig voldemortConfig, MetadataStore metadataStore, int requestId, RebalancePartitionsInfo stealInfo)

Constructor parameters in voldemort.server.rebalance.async with type arguments of type RebalancePartitionsInfo

DonorBasedRebalanceAsyncOperation(Rebalancer rebalancer, StoreRepository storeRepository, VoldemortConfig voldemortConfig, MetadataStore metadataStore, int requestId, java.util.List<RebalancePartitionsInfo> stealInfos, boolean usePartitionScan)

Uses of RebalancePartitionsInfo in voldemort.store.metadata

Methods in voldemort.store.metadata with parameters of type RebalancePartitionsInfo

void	MetadataStore.addRebalancingState(RebalancePartitionsInfo stealInfo) Add the steal information to the rebalancer state
void	MetadataStore.deleteRebalancingState(RebalancePartitionsInfo stealInfo) Delete the partition steal information from the rebalancer state

Uses of RebalancePartitionsInfo in voldemort.utils

Methods in voldemort.utils that return types with arguments of type RebalancePartitionsInfo

static java.util.List<RebalancePartitionsInfo>	RebalanceUtils.filterPartitionPlanWithStores(java.util.List<RebalancePartitionsInfo> existingPlanList, java.util.List<StoreDefinition> storeDefs) Given a list of partition plans and a set of stores, copies the store names to every individual plan and creates a new list
static java.util.List<RebalancePartitionsInfo>	RebalanceUtils.flattenNodePlans(java.util.List<RebalanceNodePlan> rebalanceNodePlanList) Given a list of node plans flattens it into a list of partitions info
static java.util.HashMap<java.lang.Integer,java.util.List<RebalancePartitionsInfo>>	RebalanceUtils.groupPartitionsInfoByNode(java.util.List<RebalancePartitionsInfo> rebalancePartitionPlanList, boolean groupByStealerNode) Given a list of partition infos, generates a map of stealer / donor node to list of partition infos

Method parameters in voldemort.utils with type arguments of type RebalancePartitionsInfo

static void	RebalanceUtils.assertSameDonor(java.util.List<RebalancePartitionsInfo> partitionInfos, int expectedDonorId) Given a list of partition informations check all of them belong to the same donor node
static java.util.List<RebalancePartitionsInfo>	RebalanceUtils.filterPartitionPlanWithStores(java.util.List<RebalancePartitionsInfo> existingPlanList, java.util.List<StoreDefinition> storeDefs) Given a list of partition plans and a set of stores, copies the store names to every individual plan and creates a new list
static java.util.HashMap<java.lang.Integer,java.util.List<RebalancePartitionsInfo>>	RebalanceUtils.groupPartitionsInfoByNode(java.util.List<RebalancePartitionsInfo> rebalancePartitionPlanList, boolean groupByStealerNode) Given a list of partition infos, generates a map of stealer / donor node to list of partition infos