|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
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 |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |