public class RegionServerTracker
extends ZKListener
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)
Constructor and Description |
---|
RegionServerTracker(ZKWatcher watcher,
MasterServices server,
ServerManager serverManager) |
Modifier and Type | Method and Description |
---|---|
java.util.List<ServerName> |
getOnlineServers()
Gets the online servers.
|
RegionServerInfo |
getRegionServerInfo(ServerName sn) |
void |
nodeChildrenChanged(java.lang.String path) |
void |
nodeCreated(java.lang.String path) |
void |
nodeDeleted(java.lang.String path) |
void |
start()
Starts the tracking of online RegionServers.
|
public RegionServerTracker(ZKWatcher watcher, MasterServices server, ServerManager serverManager)
public void start() throws KeeperException, java.io.IOException
All RSs will be tracked after this method is called.
KeeperException
java.io.IOException
public void nodeCreated(java.lang.String path)
public void nodeDeleted(java.lang.String path)
public void nodeChildrenChanged(java.lang.String path)
public RegionServerInfo getRegionServerInfo(ServerName sn)
public java.util.List<ServerName> getOnlineServers()