@InterfaceAudience.Private public class RegionServerTracker extends ZooKeeperListener
Handling of new RSs checking in is done via RPC. This class is only responsible for watching for expired nodes. It handles listening for changes in the RS node list and watching each node.
If an RS node gets deleted, this automatically handles calling of
ServerManager.expireServer(ServerName)
watcher| Constructor and Description |
|---|
RegionServerTracker(ZooKeeperWatcher watcher,
MasterServices server,
ServerManager serverManager) |
| Modifier and Type | Method and Description |
|---|---|
List<ServerName> |
getOnlineServers()
Gets the online servers.
|
org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.RegionServerInfo |
getRegionServerInfo(ServerName sn) |
void |
nodeChildrenChanged(String path)
Called when an existing node has a child node added or removed.
|
void |
nodeDeleted(String path)
Called when a node has been deleted
|
void |
start()
Starts the tracking of online RegionServers.
|
getWatcher, nodeCreated, nodeDataChangedpublic RegionServerTracker(ZooKeeperWatcher watcher, MasterServices server, ServerManager serverManager)
public void start()
throws org.apache.zookeeper.KeeperException,
IOException
All RSs will be tracked after this method is called.
org.apache.zookeeper.KeeperExceptionIOExceptionpublic void nodeDeleted(String path)
ZooKeeperListenernodeDeleted in class ZooKeeperListenerpath - full path of the deleted nodepublic void nodeChildrenChanged(String path)
ZooKeeperListenernodeChildrenChanged in class ZooKeeperListenerpath - full path of the node whose children have changedpublic org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.RegionServerInfo getRegionServerInfo(ServerName sn)
public List<ServerName> getOnlineServers()
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.