org.apache.bookkeeper.client

Class TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble

java.lang.Object

org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble

All Implemented Interfaces:

ITopologyAwareEnsemblePlacementPolicy.Ensemble<org.apache.bookkeeper.net.BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Predicate<org.apache.bookkeeper.net.BookieNode>

Enclosing class:

TopologyAwareEnsemblePlacementPolicy

protected static class TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble
extends java.lang.Object
implements ITopologyAwareEnsemblePlacementPolicy.Predicate<org.apache.bookkeeper.net.BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<org.apache.bookkeeper.net.BookieNode>

A predicate checking the rack coverage for write quorum in RoundRobinDistributionSchedule, which ensures that a write quorum should be covered by at least two racks.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static interface	TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble.CoverageSet
protected class	TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble.RackOrRegionDurabilityCoverageSet
protected class	TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble.RackQuorumCoverageSet

Field Summary

Fields

Modifier and Type	Field and Description
(package private) int	ackQuorumSize
(package private) java.util.List<org.apache.bookkeeper.net.BookieNode>	chosenNodes
(package private) int	distanceFromLeaves
(package private) int	ensembleSize
(package private) int	minNumRacksPerWriteQuorum
(package private) int	minRacksOrRegionsForDurability
(package private) ITopologyAwareEnsemblePlacementPolicy.Ensemble<org.apache.bookkeeper.net.BookieNode>	parentEnsemble
(package private) ITopologyAwareEnsemblePlacementPolicy.Predicate<org.apache.bookkeeper.net.BookieNode>	parentPredicate
(package private) java.util.Set<java.lang.String>	racksOrRegions
(package private) int	writeQuorumSize

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	RRTopologyAwareCoverageEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, int distanceFromLeaves, ITopologyAwareEnsemblePlacementPolicy.Ensemble<org.apache.bookkeeper.net.BookieNode> parentEnsemble, ITopologyAwareEnsemblePlacementPolicy.Predicate<org.apache.bookkeeper.net.BookieNode> parentPredicate, int minNumRacksPerWriteQuorum)
protected	RRTopologyAwareCoverageEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, int distanceFromLeaves, ITopologyAwareEnsemblePlacementPolicy.Ensemble<org.apache.bookkeeper.net.BookieNode> parentEnsemble, ITopologyAwareEnsemblePlacementPolicy.Predicate<org.apache.bookkeeper.net.BookieNode> parentPredicate, java.util.Set<java.lang.String> racksOrRegions, int minRacksOrRegionsForDurability, int minNumRacksPerWriteQuorum)
protected	RRTopologyAwareCoverageEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, int distanceFromLeaves, java.util.Set<java.lang.String> racksOrRegions, int minRacksOrRegionsForDurability, int minNumRacksPerWriteQuorum)
protected	RRTopologyAwareCoverageEnsemble(TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble that)

Method Summary

Modifier and Type	Method and Description
boolean	addNode(org.apache.bookkeeper.net.BookieNode node) Append the new bookie node to the ensemble only if the ensemble doesnt already contain the same bookie.
boolean	apply(org.apache.bookkeeper.net.BookieNode candidate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<org.apache.bookkeeper.net.BookieNode> ensemble)
java.util.List<org.apache.bookkeeper.net.BookieSocketAddress>	toList()
java.lang.String	toString()
boolean	validate() Validates if an ensemble is valid.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

distanceFromLeaves

final int distanceFromLeaves

ensembleSize

final int ensembleSize

writeQuorumSize

final int writeQuorumSize

ackQuorumSize

final int ackQuorumSize

minRacksOrRegionsForDurability

final int minRacksOrRegionsForDurability

minNumRacksPerWriteQuorum

final int minNumRacksPerWriteQuorum

chosenNodes

final java.util.List<org.apache.bookkeeper.net.BookieNode> chosenNodes

racksOrRegions

final java.util.Set<java.lang.String> racksOrRegions

parentPredicate

final ITopologyAwareEnsemblePlacementPolicy.Predicate<org.apache.bookkeeper.net.BookieNode> parentPredicate

parentEnsemble

final ITopologyAwareEnsemblePlacementPolicy.Ensemble<org.apache.bookkeeper.net.BookieNode> parentEnsemble

Constructor Detail

RRTopologyAwareCoverageEnsemble

protected RRTopologyAwareCoverageEnsemble(TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble that)

RRTopologyAwareCoverageEnsemble

protected RRTopologyAwareCoverageEnsemble(int ensembleSize,
                                          int writeQuorumSize,
                                          int ackQuorumSize,
                                          int distanceFromLeaves,
                                          java.util.Set<java.lang.String> racksOrRegions,
                                          int minRacksOrRegionsForDurability,
                                          int minNumRacksPerWriteQuorum)

RRTopologyAwareCoverageEnsemble

protected RRTopologyAwareCoverageEnsemble(int ensembleSize,
                                          int writeQuorumSize,
                                          int ackQuorumSize,
                                          int distanceFromLeaves,
                                          ITopologyAwareEnsemblePlacementPolicy.Ensemble<org.apache.bookkeeper.net.BookieNode> parentEnsemble,
                                          ITopologyAwareEnsemblePlacementPolicy.Predicate<org.apache.bookkeeper.net.BookieNode> parentPredicate,
                                          int minNumRacksPerWriteQuorum)

RRTopologyAwareCoverageEnsemble

protected RRTopologyAwareCoverageEnsemble(int ensembleSize,
                                          int writeQuorumSize,
                                          int ackQuorumSize,
                                          int distanceFromLeaves,
                                          ITopologyAwareEnsemblePlacementPolicy.Ensemble<org.apache.bookkeeper.net.BookieNode> parentEnsemble,
                                          ITopologyAwareEnsemblePlacementPolicy.Predicate<org.apache.bookkeeper.net.BookieNode> parentPredicate,
                                          java.util.Set<java.lang.String> racksOrRegions,
                                          int minRacksOrRegionsForDurability,
                                          int minNumRacksPerWriteQuorum)

Method Detail

apply

public boolean apply(org.apache.bookkeeper.net.BookieNode candidate,
                     ITopologyAwareEnsemblePlacementPolicy.Ensemble<org.apache.bookkeeper.net.BookieNode> ensemble)

Specified by:

apply in interface ITopologyAwareEnsemblePlacementPolicy.Predicate<org.apache.bookkeeper.net.BookieNode>

addNode

public boolean addNode(org.apache.bookkeeper.net.BookieNode node)

Description copied from interface: ITopologyAwareEnsemblePlacementPolicy.Ensemble

Append the new bookie node to the ensemble only if the ensemble doesnt already contain the same bookie.

Specified by:

addNode in interface ITopologyAwareEnsemblePlacementPolicy.Ensemble<org.apache.bookkeeper.net.BookieNode>

Parameters:

node - new candidate bookie node.

Returns:

true if the node was added

toList

public java.util.List<org.apache.bookkeeper.net.BookieSocketAddress> toList()

Specified by:

toList in interface ITopologyAwareEnsemblePlacementPolicy.Ensemble<org.apache.bookkeeper.net.BookieNode>

Returns:

list of addresses representing the ensemble

validate

public boolean validate()

Validates if an ensemble is valid.

Specified by:

validate in interface ITopologyAwareEnsemblePlacementPolicy.Ensemble<org.apache.bookkeeper.net.BookieNode>

Returns:

true if the ensemble is valid; false otherwise

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object