DefaultEnsemblePlacementPolicy (bookkeeper 4.4.0-SNAPSHOT API)

java.lang.Object
- org.apache.bookkeeper.client.DefaultEnsemblePlacementPolicy

All Implemented Interfaces:

EnsemblePlacementPolicy
```
public class DefaultEnsemblePlacementPolicy
extends Object
implements EnsemblePlacementPolicy
```
Default Ensemble Placement Policy, which picks bookies randomly

Constructor Summary

Constructors
Constructor and Description

DefaultEnsemblePlacementPolicy()

Constructors
Constructor and Description
`DefaultEnsemblePlacementPolicy()`

Method Summary

Methods
Modifier and Type	Method and Description
`EnsemblePlacementPolicy`	`initialize(org.apache.commons.configuration.Configuration conf)` Initialize the policy.
`ArrayList<org.apache.bookkeeper.net.BookieSocketAddress>`	`newEnsemble(int ensembleSize, int quorumSize, Set<org.apache.bookkeeper.net.BookieSocketAddress> excludeBookies)` Choose numBookies bookies for ensemble.
`Set<org.apache.bookkeeper.net.BookieSocketAddress>`	`onClusterChanged(Set<org.apache.bookkeeper.net.BookieSocketAddress> writableBookies, Set<org.apache.bookkeeper.net.BookieSocketAddress> readOnlyBookies)` A consistent view of the cluster (what bookies are available as writable, what bookies are available as readonly) is updated when any changes happen in the cluster.
`org.apache.bookkeeper.net.BookieSocketAddress`	`replaceBookie(org.apache.bookkeeper.net.BookieSocketAddress bookieToReplace, Set<org.apache.bookkeeper.net.BookieSocketAddress> excludeBookies)` Choose a new bookie to replace bookieToReplace.
`void`	`uninitalize()` Uninitialize the policy

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - DefaultEnsemblePlacementPolicy
```
public DefaultEnsemblePlacementPolicy()
```
- Method Detail
  - newEnsemble
```
public ArrayList<org.apache.bookkeeper.net.BookieSocketAddress> newEnsemble(int ensembleSize,
                                                                   int quorumSize,
                                                                   Set<org.apache.bookkeeper.net.BookieSocketAddress> excludeBookies)
                                                                     throws BKException.BKNotEnoughBookiesException
```
    Description copied from interface: EnsemblePlacementPolicy
    
    Choose numBookies bookies for ensemble. If the count is more than the number of available nodes, BKException.BKNotEnoughBookiesException is thrown.
    
    Specified by:
    
    newEnsemble in interface EnsemblePlacementPolicy
    
    Parameters:
    ensembleSize - Ensemble Size
    quorumSize - Write Quorum Size
    excludeBookies - Bookies that should not be considered as targets.
    
    Returns:
    list of bookies chosen as targets.
    
    Throws:
    
    BKException.BKNotEnoughBookiesException - if not enough bookies available.
  - replaceBookie
```
public org.apache.bookkeeper.net.BookieSocketAddress replaceBookie(org.apache.bookkeeper.net.BookieSocketAddress bookieToReplace,
                                                          Set<org.apache.bookkeeper.net.BookieSocketAddress> excludeBookies)
                                                            throws BKException.BKNotEnoughBookiesException
```
    Description copied from interface: EnsemblePlacementPolicy
    
    Choose a new bookie to replace bookieToReplace. If no bookie available in the cluster, BKException.BKNotEnoughBookiesException is thrown.
    
    Specified by:
    
    replaceBookie in interface EnsemblePlacementPolicy
    
    Parameters:
    bookieToReplace - bookie to replace
    excludeBookies - bookies that should not be considered as candidate.
    
    Returns:
    the bookie chosen as target.
    
    Throws:
    
    BKException.BKNotEnoughBookiesException
  - onClusterChanged
```
public Set<org.apache.bookkeeper.net.BookieSocketAddress> onClusterChanged(Set<org.apache.bookkeeper.net.BookieSocketAddress> writableBookies,
                                                                  Set<org.apache.bookkeeper.net.BookieSocketAddress> readOnlyBookies)
```
    Description copied from interface: EnsemblePlacementPolicy
    
    A consistent view of the cluster (what bookies are available as writable, what bookies are available as readonly) is updated when any changes happen in the cluster.
    
    Specified by:
    
    onClusterChanged in interface EnsemblePlacementPolicy
    
    Parameters:
    writableBookies - All the bookies in the cluster available for write/read.
    readOnlyBookies - All the bookies in the cluster available for readonly.
    
    Returns:
    the dead bookies during this cluster change.
  - initialize
```
public EnsemblePlacementPolicy initialize(org.apache.commons.configuration.Configuration conf)
```
    Description copied from interface: EnsemblePlacementPolicy
    
    Initialize the policy.
    
    Specified by:
    
    initialize in interface EnsemblePlacementPolicy
    
    Parameters:
    conf - client configuration.
    
    Returns:
    initialized ensemble placement policy
  - uninitalize
```
public void uninitalize()
```
    Description copied from interface: EnsemblePlacementPolicy
    
    Uninitialize the policy
    
    Specified by:
    
    uninitalize in interface EnsemblePlacementPolicy

Class DefaultEnsemblePlacementPolicy

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

DefaultEnsemblePlacementPolicy

Method Detail

newEnsemble

replaceBookie

onClusterChanged

initialize

uninitalize