org.codehaus.wadi.location.balancing
Class BasicPartitionBalancer

java.lang.Object
  extended by org.codehaus.wadi.location.balancing.BasicPartitionBalancer
All Implemented Interfaces:
Lifecycle, PartitionBalancer

public class BasicPartitionBalancer
extends java.lang.Object
implements PartitionBalancer

Version:
$Revision: 1538 $

Constructor Summary
BasicPartitionBalancer(Dispatcher dispatcher, int nbPartitions)
           
 
Method Summary
 void balancePartitions()
           
protected  java.util.Map fetchBalancingInfoState(java.util.Set peers)
           
protected  PartitionBalancingStrategy newBalancingStrategy(int nbPartitions, java.util.Map peerToBalancingInfoState)
           
protected  void publishBalancingInfoUpdate(java.util.Map peerToBalancingState, PartitionInfoUpdates partitionInfoUpdates)
           
 void start()
           
 void stop()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

BasicPartitionBalancer

public BasicPartitionBalancer(Dispatcher dispatcher,
                              int nbPartitions)
Method Detail

start

public void start()
           throws java.lang.Exception
Specified by:
start in interface Lifecycle
Throws:
java.lang.Exception

stop

public void stop()
          throws java.lang.Exception
Specified by:
stop in interface Lifecycle
Throws:
java.lang.Exception

balancePartitions

public void balancePartitions()
                       throws MessageExchangeException
Specified by:
balancePartitions in interface PartitionBalancer
Throws:
MessageExchangeException

fetchBalancingInfoState

protected java.util.Map fetchBalancingInfoState(java.util.Set peers)
                                         throws MessageExchangeException
Throws:
MessageExchangeException

publishBalancingInfoUpdate

protected void publishBalancingInfoUpdate(java.util.Map peerToBalancingState,
                                          PartitionInfoUpdates partitionInfoUpdates)
                                   throws MessageExchangeException
Throws:
MessageExchangeException

newBalancingStrategy

protected PartitionBalancingStrategy newBalancingStrategy(int nbPartitions,
                                                          java.util.Map peerToBalancingInfoState)


Copyright © 2010. All Rights Reserved.