Package org.apache.bookkeeper.client

Class TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble

java.lang.Object

org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble

All Implemented Interfaces:

ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>

Enclosing class:

TopologyAwareEnsemblePlacementPolicy

protected static class TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble
extends Object
implements ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<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	Description
protected static interface	TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble.CoverageSet
protected class	TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble.RackOrRegionDurabilityCoverageSet
protected class	TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble.RackQuorumCoverageSet

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final int	ackQuorumSize
(package private) final List<BookieNode>	chosenNodes
(package private) final int	distanceFromLeaves
(package private) final int	ensembleSize
(package private) final int	minNumRacksPerWriteQuorum
(package private) final int	minRacksOrRegionsForDurability
(package private) final ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>	parentEnsemble
(package private) final ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>	parentPredicate
(package private) final Set<String>	racksOrRegions
(package private) final int	writeQuorumSize

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	RRTopologyAwareCoverageEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, int distanceFromLeaves, Set<String> racksOrRegions, int minRacksOrRegionsForDurability, int minNumRacksPerWriteQuorum)
protected	RRTopologyAwareCoverageEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, int distanceFromLeaves, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> parentEnsemble, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> parentPredicate, int minNumRacksPerWriteQuorum)
protected	RRTopologyAwareCoverageEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, int distanceFromLeaves, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> parentEnsemble, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> parentPredicate, Set<String> racksOrRegions, int minRacksOrRegionsForDurability, int minNumRacksPerWriteQuorum)
protected	RRTopologyAwareCoverageEnsemble(TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble that)

Method Summary

Modifier and Type	Method	Description
boolean	addNode(BookieNode node)	Append the new bookie node to the ensemble only if the ensemble doesnt already contain the same bookie.
boolean	apply(BookieNode candidate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> ensemble)
List<BookieId>	toList()
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 Details

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 List<BookieNode> chosenNodes

racksOrRegions

final Set<String> racksOrRegions

parentPredicate

final ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> parentPredicate

parentEnsemble

final ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> parentEnsemble

Constructor Details

RRTopologyAwareCoverageEnsemble

protected RRTopologyAwareCoverageEnsemble(TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble that)

RRTopologyAwareCoverageEnsemble

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

RRTopologyAwareCoverageEnsemble

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

RRTopologyAwareCoverageEnsemble

protected RRTopologyAwareCoverageEnsemble(int ensembleSize,
 int writeQuorumSize,
 int ackQuorumSize,
 int distanceFromLeaves,
 ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> parentEnsemble,
 ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> parentPredicate,
 Set<String> racksOrRegions,
 int minRacksOrRegionsForDurability,
 int minNumRacksPerWriteQuorum)

Method Details

apply

public boolean apply(BookieNode candidate,
 ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> ensemble)

Specified by:

apply in interface ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>

addNode

public boolean addNode(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<BookieNode>

Parameters:

node - new candidate bookie node.

Returns:

true if the node was added

toList

public List<BookieId> toList()

Specified by:

toList in interface ITopologyAwareEnsemblePlacementPolicy.Ensemble<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<BookieNode>

Returns:

true if the ensemble is valid; false otherwise

toString

public String toString()

Overrides:

toString in class Object