Class TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble

    • 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
    • Constructor Detail

      • 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,
                                                  java.util.Set<java.lang.String> racksOrRegions,
                                                  int minRacksOrRegionsForDurability,
                                                  int minNumRacksPerWriteQuorum)