org.codehaus.wadi.dindex.impl
Class RedistributionPlan

java.lang.Object
  extended byorg.codehaus.wadi.dindex.impl.RedistributionPlan

public class RedistributionPlan
extends Object


Field Summary
protected  List _consumers
           
protected  Log _log
           
protected  List _producers
           
 
Constructor Summary
RedistributionPlan(Node[] living, Node[] leaving, int totalNumPartitions)
           
 
Method Summary
protected  void decide(Node node, int numPartitions, int numPartitionsPerNode, Collection producers, Collection consumers)
           
 Collection getConsumers()
           
 Collection getProducers()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

_log

protected final Log _log

_producers

protected final List _producers

_consumers

protected final List _consumers
Constructor Detail

RedistributionPlan

public RedistributionPlan(Node[] living,
                          Node[] leaving,
                          int totalNumPartitions)
Method Detail

decide

protected void decide(Node node,
                      int numPartitions,
                      int numPartitionsPerNode,
                      Collection producers,
                      Collection consumers)

getProducers

public Collection getProducers()

getConsumers

public Collection getConsumers()


Copyright © 2004-2008 Core Developers Network Ltd.. All Rights Reserved.