org.codehaus.wadi.location.balancing
Class PartitionInfoUpdateBuilder

java.lang.Object
  extended by org.codehaus.wadi.location.balancing.PartitionInfoUpdateBuilder

public class PartitionInfoUpdateBuilder
extends java.lang.Object

Version:
$Revision: 1538 $

Constructor Summary
PartitionInfoUpdateBuilder(int nbPartitions, int version, java.util.BitSet lostPartitions)
           
 
Method Summary
 void addPartitionInfos(PartitionBalancingInfo baseline, int nbPartitionToAdd)
           
 void addPartitionInfos(Peer peer, int nbPartitionToAdd)
           
protected  void allocatePartitionToPeer(Peer peer, int nbPartitionToAdd)
           
 PartitionInfoUpdates build()
           
protected  void derivePartitionInfoUpdate(PartitionInfo localPartitionInfo)
           
 int getNumberOfPartitionsOwnedBy(Peer peer)
           
 void mergePartitionInfos(PartitionBalancingInfo baseline)
           
protected  PartitionInfo newPartitionInfo(PartitionInfo localPartitionInfo)
           
 void removePartitions(PartitionBalancingInfo baseline, int nbPartitionToRemove)
           
protected  void trackPartition(PartitionInfo localPartitionInfo)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

PartitionInfoUpdateBuilder

public PartitionInfoUpdateBuilder(int nbPartitions,
                                  int version,
                                  java.util.BitSet lostPartitions)
Method Detail

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 © 2011. All Rights Reserved.