@InterfaceAudience.Private public class SweepJobNodeTracker extends ZooKeeperListener
watcher
Constructor and Description |
---|
SweepJobNodeTracker(ZooKeeperWatcher watcher,
java.lang.String parentNode,
java.lang.String owner) |
Modifier and Type | Method and Description |
---|---|
void |
nodeDeleted(java.lang.String path)
Called when a node has been deleted
|
void |
start()
Registers the watcher on the sweep job node.
|
getWatcher, nodeChildrenChanged, nodeCreated, nodeDataChanged
public SweepJobNodeTracker(ZooKeeperWatcher watcher, java.lang.String parentNode, java.lang.String owner)
public void start() throws KeeperException
KeeperException
public void nodeDeleted(java.lang.String path)
ZooKeeperListener
nodeDeleted
in class ZooKeeperListener
path
- full path of the deleted node