Uses of Interface
org.apache.bookkeeper.net.Node
-
Packages that use Node Package Description org.apache.bookkeeper.client BookKeeper Client.org.apache.bookkeeper.net Network-related classes. -
-
Uses of Node in org.apache.bookkeeper.client
Classes in org.apache.bookkeeper.client with type parameters of type Node Modifier and Type Interface Description interface
ITopologyAwareEnsemblePlacementPolicy<T extends Node>
Interface for topology aware ensemble placement policy.static interface
ITopologyAwareEnsemblePlacementPolicy.Ensemble<T extends Node>
Ensemble used to hold the result of an ensemble selected for placement.static interface
ITopologyAwareEnsemblePlacementPolicy.Predicate<T extends Node>
Predicate used when choosing an ensemble.Methods in org.apache.bookkeeper.client that return types with arguments of type Node Modifier and Type Method Description protected java.util.Set<Node>
TopologyAwareEnsemblePlacementPolicy. convertBookiesToNodes(java.util.Collection<BookieId> bookies)
Method parameters in org.apache.bookkeeper.client with type arguments of type Node Modifier and Type Method Description (package private) static java.util.Set<java.lang.String>
TopologyAwareEnsemblePlacementPolicy. getNetworkLocations(java.util.Set<Node> bookieNodes)
protected BookieNode
RegionAwareEnsemblePlacementPolicy. replaceFromRack(BookieNode bookieNodeToReplace, java.util.Set<Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> ensemble, boolean enforceDurability)
T
ITopologyAwareEnsemblePlacementPolicy. selectFromNetworkLocation(java.lang.String networkLoc, java.util.Set<Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<T> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<T> ensemble, boolean fallbackToRandom)
Select a node from a given network location.BookieNode
RackawareEnsemblePlacementPolicy. selectFromNetworkLocation(java.lang.String networkLoc, java.util.Set<Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> ensemble, boolean fallbackToRandom)
BookieNode
RackawareEnsemblePlacementPolicyImpl. selectFromNetworkLocation(java.lang.String networkLoc, java.util.Set<Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> ensemble, boolean fallbackToRandom)
BookieNode
ZoneawareEnsemblePlacementPolicyImpl. selectFromNetworkLocation(java.lang.String networkLoc, java.util.Set<Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> ensemble, boolean fallbackToRandom)
protected java.util.List<BookieNode>
RackawareEnsemblePlacementPolicyImpl. selectRandom(int numBookies, java.util.Set<Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> ensemble)
Choose a random node from whole cluster.protected BookieNode
RackawareEnsemblePlacementPolicyImpl. selectRandomFromRack(java.lang.String netPath, java.util.Set<Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> ensemble)
Choose random node under a given network path.protected java.util.List<BookieNode>
RackawareEnsemblePlacementPolicyImpl. selectRandomInternal(java.util.List<BookieNode> bookiesToSelectFrom, int numBookies, java.util.Set<Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> ensemble)
-
Uses of Node in org.apache.bookkeeper.net
Classes in org.apache.bookkeeper.net that implement Node Modifier and Type Class Description class
BookieNode
Bookie Node implementation.(package private) static class
NetworkTopologyImpl.InnerNode
InnerNode represents a switch/router of a data center or rack.class
NodeBase
A base class that implements interface Node.Fields in org.apache.bookkeeper.net declared as Node Modifier and Type Field Description protected Node
NodeBase. parent
Fields in org.apache.bookkeeper.net with type parameters of type Node Modifier and Type Field Description protected java.util.List<Node>
NetworkTopologyImpl.InnerNode. children
protected java.util.concurrent.ConcurrentMap<Node,StabilizeNetworkTopology.NodeStatus>
StabilizeNetworkTopology. nodeStatuses
Methods in org.apache.bookkeeper.net that return Node Modifier and Type Method Description Node
NetworkTopologyImpl. chooseRandom(java.lang.String scope)
Randomly choose one node from scope.(package private) Node
NetworkTopologyImpl.InnerNode. getLeaf(int leafIndex, Node excludedNode)
Get leafIndex leaf of this subtree if it is not in the excludedNode.Node
NetworkTopology. getNode(java.lang.String loc)
Retrieve a node from the network topology.Node
NetworkTopologyImpl. getNode(java.lang.String loc)
Given a string representation of a node, return its reference.Node
StabilizeNetworkTopology. getNode(java.lang.String loc)
protected Node
NetworkTopologyImpl. getNodeForNetworkLocation(Node node)
Return a reference to the node given its string representation.Node
Node. getParent()
Node
NodeBase. getParent()
Methods in org.apache.bookkeeper.net that return types with arguments of type Node Modifier and Type Method Description (package private) java.util.List<Node>
NetworkTopologyImpl.InnerNode. getChildren()
java.util.List<Node>
NetworkTopologyImpl. getDatanodesInRack(java.lang.String loc)
Given a string representation of a rack, return its children.java.util.Set<Node>
NetworkTopology. getLeaves(java.lang.String loc)
Returns the nodes under a location.java.util.Set<Node>
NetworkTopologyImpl. getLeaves(java.lang.String scope)
java.util.Set<Node>
StabilizeNetworkTopology. getLeaves(java.lang.String loc)
Methods in org.apache.bookkeeper.net with parameters of type Node Modifier and Type Method Description void
NetworkTopology. add(Node node)
Add a node to the network topology.void
NetworkTopologyImpl. add(Node node)
Add a leaf node.(package private) boolean
NetworkTopologyImpl.InnerNode. add(Node n)
Add node n to the subtree of this node.void
StabilizeNetworkTopology. add(Node node)
boolean
NetworkTopology. contains(Node node)
Check if the tree contains node node.boolean
NetworkTopologyImpl. contains(Node node)
Check if the tree contains node node.boolean
StabilizeNetworkTopology. contains(Node node)
int
NetworkTopologyImpl. getDistance(Node node1, Node node2)
Return the distance between two nodes.(package private) Node
NetworkTopologyImpl.InnerNode. getLeaf(int leafIndex, Node excludedNode)
Get leafIndex leaf of this subtree if it is not in the excludedNode.protected Node
NetworkTopologyImpl. getNodeForNetworkLocation(Node node)
Return a reference to the node given its string representation.static java.lang.String
NodeBase. getPath(Node node)
Get the path of a node.(package private) boolean
NetworkTopologyImpl.InnerNode. isAncestor(Node n)
Judge if this node is an ancestor of node n.boolean
NetworkTopologyImpl. isOnSameNodeGroup(Node node1, Node node2)
Return false directly as not aware of NodeGroup, to be override in sub-class.boolean
NetworkTopologyImpl. isOnSameRack(Node node1, Node node2)
Check if two nodes are on the same rack.(package private) boolean
NetworkTopologyImpl.InnerNode. isParent(Node n)
Judge if this node is the parent of node n.protected boolean
NetworkTopologyImpl. isSameParents(Node node1, Node node2)
Compare the parents of each node for equality.void
NetworkTopologyImpl. pseudoSortByDistance(Node reader, Node[] nodes)
Sort nodes array by their distances to reader It linearly scans the array, if a local node is found, swap it with the first element of the array.void
NetworkTopology. remove(Node node)
Remove a node from network topology.(package private) boolean
NetworkTopologyImpl.InnerNode. remove(Node n)
Remove node n from the subtree of this node.void
NetworkTopologyImpl. remove(Node node)
Remove a node.void
StabilizeNetworkTopology. remove(Node node)
void
Node. setParent(Node parent)
Set this node's parent.void
NodeBase. setParent(Node parent)
Set this node's parent.protected static void
NetworkTopologyImpl. swap(Node[] nodes, int i, int j)
Swap two array items.(package private) void
StabilizeNetworkTopology. updateNode(Node node, boolean tentativeToRemove)
Method parameters in org.apache.bookkeeper.net with type arguments of type Node Modifier and Type Method Description int
NetworkTopology. countNumOfAvailableNodes(java.lang.String scope, java.util.Collection<Node> excludedNodes)
Return the number of leaves in scope but not in excludedNodes.int
NetworkTopologyImpl. countNumOfAvailableNodes(java.lang.String scope, java.util.Collection<Node> excludedNodes)
int
StabilizeNetworkTopology. countNumOfAvailableNodes(java.lang.String scope, java.util.Collection<Node> excludedNodes)
Constructors in org.apache.bookkeeper.net with parameters of type Node Constructor Description NodeBase(java.lang.String name, java.lang.String location, Node parent, int level)
Construct a node from its name and its location.
-