public class DrainingServerTracker
extends ZKListener
This class is responsible for watching for changes to the draining servers list. It handles adds/deletes in the draining RS list and watches each node.
If an RS gets deleted from draining list, we call
ServerManager.removeServerFromDrainList(ServerName)
If an RS gets added to the draining list, we add a watcher to it and call
ServerManager.addServerToDrainList(ServerName)
This class is deprecated in 2.0 because decommission/draining API goes through master in 2.0. Can remove this class in 3.0.
Constructor and Description |
---|
DrainingServerTracker(ZKWatcher watcher,
Abortable abortable,
ServerManager serverManager) |
Modifier and Type | Method and Description |
---|---|
void |
nodeChildrenChanged(java.lang.String path) |
void |
nodeDeleted(java.lang.String path) |
void |
start()
Starts the tracking of draining RegionServers.
|
public DrainingServerTracker(ZKWatcher watcher, Abortable abortable, ServerManager serverManager)
public void start() throws KeeperException, java.io.IOException
All Draining RSs will be tracked after this method is called.
KeeperException
java.io.IOException
public void nodeDeleted(java.lang.String path)
public void nodeChildrenChanged(java.lang.String path)