Uses of Class
voldemort.client.rebalance.RebalanceTaskInfo

Packages that use RebalanceTaskInfo
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 Classes that encapsulate a specific rebalance task (between a stealer-node and donor-node). 
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 RebalanceTaskInfo in voldemort.client.protocol.admin
 

Methods in voldemort.client.protocol.admin with parameters of type RebalanceTaskInfo
 int AdminClient.RebalancingOperations.rebalanceNode(RebalanceTaskInfo stealInfo)
          Rebalance a stealer-donor node pair for a set of stores.
 

Method parameters in voldemort.client.protocol.admin with type arguments of type RebalanceTaskInfo
 void AdminClient.RebalancingOperations.rebalanceStateChange(Cluster existingCluster, Cluster transitionCluster, java.util.List<StoreDefinition> existingStoreDefs, java.util.List<StoreDefinition> targetStoreDefs, java.util.List<RebalanceTaskInfo> rebalanceTaskPlanList, boolean swapRO, boolean changeClusterMetadata, boolean changeRebalanceState, boolean rollback, boolean failEarly)
          Used in rebalancing to indicate change in states.
 

Uses of RebalanceTaskInfo in voldemort.client.protocol.pb
 

Methods in voldemort.client.protocol.pb that return RebalanceTaskInfo
static RebalanceTaskInfo ProtoUtils.decodeRebalanceTaskInfoMap(VAdminProto.RebalanceTaskInfoMap rebalanceTaskInfoMap)
          Given a protobuf rebalance-partition info, converts it into our rebalance-partition info
 

Methods in voldemort.client.protocol.pb with parameters of type RebalanceTaskInfo
static VAdminProto.RebalanceTaskInfoMap ProtoUtils.encodeRebalanceTaskInfoMap(RebalanceTaskInfo stealInfo)
          Given a rebalance-task info, convert it into the protobuf equivalent
 

Uses of RebalanceTaskInfo in voldemort.client.rebalance
 

Fields in voldemort.client.rebalance with type parameters of type RebalanceTaskInfo
protected  java.util.List<RebalanceTaskInfo> RebalanceBatchPlan.batchPlan
           
 

Methods in voldemort.client.rebalance that return RebalanceTaskInfo
static RebalanceTaskInfo RebalanceTaskInfo.create(java.util.Map<?,?> map)
           
static RebalanceTaskInfo RebalanceTaskInfo.create(java.lang.String line)
           
 

Methods in voldemort.client.rebalance that return types with arguments of type RebalanceTaskInfo
 java.util.List<RebalanceTaskInfo> RebalanceBatchPlan.getBatchPlan()
           
 

Method parameters in voldemort.client.rebalance with type arguments of type RebalanceTaskInfo
static java.lang.String RebalanceTaskInfo.taskListToString(java.util.List<RebalanceTaskInfo> infos)
          Pretty prints a task list of rebalancing tasks.
 

Uses of RebalanceTaskInfo in voldemort.client.rebalance.task
 

Fields in voldemort.client.rebalance.task with type parameters of type RebalanceTaskInfo
protected  java.util.List<RebalanceTaskInfo> RebalanceTask.stealInfos
           
 

Methods in voldemort.client.rebalance.task that return types with arguments of type RebalanceTaskInfo
 java.util.List<RebalanceTaskInfo> RebalanceTask.getStealInfos()
           
 

Constructors in voldemort.client.rebalance.task with parameters of type RebalanceTaskInfo
StealerBasedRebalanceTask(int batchId, int taskId, RebalanceTaskInfo stealInfo, java.util.concurrent.Semaphore donorPermit, AdminClient adminClient, RebalanceBatchPlanProgressBar progressBar, RebalanceScheduler scheduler)
           
 

Constructor parameters in voldemort.client.rebalance.task with type arguments of type RebalanceTaskInfo
RebalanceTask(int batchId, int taskId, java.util.List<RebalanceTaskInfo> stealInfos, java.util.concurrent.Semaphore donorPermit, AdminClient adminClient, RebalanceBatchPlanProgressBar progressBar, org.apache.log4j.Logger logger)
           
 

Uses of RebalanceTaskInfo in voldemort.server.rebalance
 

Fields in voldemort.server.rebalance with type parameters of type RebalanceTaskInfo
protected  java.util.Map<java.lang.Integer,RebalanceTaskInfo> RebalancerState.stealInfoMap
           
 

Methods in voldemort.server.rebalance that return RebalanceTaskInfo
 RebalanceTaskInfo RebalancerState.find(int donorId)
           
 

Methods in voldemort.server.rebalance that return types with arguments of type RebalanceTaskInfo
 java.util.Collection<RebalanceTaskInfo> RebalancerState.getAll()
           
 

Methods in voldemort.server.rebalance with parameters of type RebalanceTaskInfo
 int Rebalancer.rebalanceNode(RebalanceTaskInfo stealInfo)
          This function is responsible for starting the actual async rebalance operation.
 boolean RebalancerState.remove(RebalanceTaskInfo rebalanceTaskInfo)
           
 boolean RebalancerState.update(RebalanceTaskInfo rebalanceTaskInfo)
           
 

Method parameters in voldemort.server.rebalance with type arguments of type RebalanceTaskInfo
 void Rebalancer.rebalanceStateChange(Cluster cluster, java.util.List<StoreDefinition> storeDefs, java.util.List<RebalanceTaskInfo> rebalanceTaskInfo, boolean swapRO, boolean changeClusterAndStoresMetadata, boolean changeRebalanceState, boolean rollback)
          Support four different stages
For normal operation:
 

Constructor parameters in voldemort.server.rebalance with type arguments of type RebalanceTaskInfo
RebalancerState(java.util.List<RebalanceTaskInfo> stealInfoList)
           
 

Uses of RebalanceTaskInfo in voldemort.server.rebalance.async
 

Constructors in voldemort.server.rebalance.async with parameters of type RebalanceTaskInfo
StealerBasedRebalanceAsyncOperation(Rebalancer rebalancer, VoldemortConfig voldemortConfig, MetadataStore metadataStore, int requestId, RebalanceTaskInfo stealInfo)
           
 

Uses of RebalanceTaskInfo in voldemort.store.metadata
 

Methods in voldemort.store.metadata with parameters of type RebalanceTaskInfo
 void MetadataStore.addRebalancingState(RebalanceTaskInfo stealInfo)
          Add the steal information to the rebalancer state
 void MetadataStore.deleteRebalancingState(RebalanceTaskInfo stealInfo)
          Delete the partition steal information from the rebalancer state
 

Uses of RebalanceTaskInfo in voldemort.utils
 

Methods in voldemort.utils that return types with arguments of type RebalanceTaskInfo
static java.util.List<RebalanceTaskInfo> RebalanceUtils.filterTaskPlanWithStores(java.util.List<RebalanceTaskInfo> 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<RebalanceTaskInfo>> RebalanceUtils.groupPartitionsTaskByNode(java.util.List<RebalanceTaskInfo> rebalanceTaskPlanList, 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 RebalanceTaskInfo
static int RebalanceUtils.countTaskStores(java.util.List<RebalanceTaskInfo> infos)
           
static java.util.List<RebalanceTaskInfo> RebalanceUtils.filterTaskPlanWithStores(java.util.List<RebalanceTaskInfo> 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<RebalanceTaskInfo>> RebalanceUtils.groupPartitionsTaskByNode(java.util.List<RebalanceTaskInfo> rebalanceTaskPlanList, boolean groupByStealerNode)
          Given a list of partition infos, generates a map of stealer / donor node to list of partition infos
 



Jay Kreps, Roshan Sumbaly, Alex Feinberg, Bhupesh Bansal, Lei Gao, Chinmay Soman, Vinoth Chandar, Zhongjie Wu