org.codehaus.wadi.location.balancing
Class PartitionInfoUpdateBuilder
java.lang.Object
org.codehaus.wadi.location.balancing.PartitionInfoUpdateBuilder
public class PartitionInfoUpdateBuilder
- extends java.lang.Object
- Version:
- $Revision: 1538 $
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
PartitionInfoUpdateBuilder
public PartitionInfoUpdateBuilder(int nbPartitions,
int version,
java.util.BitSet lostPartitions)
addPartitionInfos
public void addPartitionInfos(PartitionBalancingInfo baseline,
int nbPartitionToAdd)
mergePartitionInfos
public void mergePartitionInfos(PartitionBalancingInfo baseline)
removePartitions
public void removePartitions(PartitionBalancingInfo baseline,
int nbPartitionToRemove)
addPartitionInfos
public void addPartitionInfos(Peer peer,
int nbPartitionToAdd)
build
public PartitionInfoUpdates build()
trackPartition
protected void trackPartition(PartitionInfo localPartitionInfo)
derivePartitionInfoUpdate
protected void derivePartitionInfoUpdate(PartitionInfo localPartitionInfo)
allocatePartitionToPeer
protected void allocatePartitionToPeer(Peer peer,
int nbPartitionToAdd)
getNumberOfPartitionsOwnedBy
public int getNumberOfPartitionsOwnedBy(Peer peer)
newPartitionInfo
protected PartitionInfo newPartitionInfo(PartitionInfo localPartitionInfo)
Copyright © 2010. All Rights Reserved.