public static class TestZKNodeTracker.TestingZKListener extends org.apache.hadoop.hbase.zookeeper.ZKListener
| Modifier and Type | Field and Description |
|---|---|
private Semaphore |
changedLock |
private Semaphore |
createdLock |
private Semaphore |
deletedLock |
private static org.slf4j.Logger |
LOG |
private String |
node |
| Constructor and Description |
|---|
TestingZKListener(org.apache.hadoop.hbase.zookeeper.ZKWatcher watcher,
String node) |
| Modifier and Type | Method and Description |
|---|---|
void |
nodeCreated(String path) |
void |
nodeDataChanged(String path) |
void |
nodeDeleted(String path) |
(package private) void |
waitForCreation() |
(package private) void |
waitForDataChange() |
(package private) void |
waitForDeletion() |
private static final org.slf4j.Logger LOG
private Semaphore deletedLock
private Semaphore createdLock
private Semaphore changedLock
TestingZKListener(org.apache.hadoop.hbase.zookeeper.ZKWatcher watcher, String node)
public void nodeDeleted(String path)
nodeDeleted in class org.apache.hadoop.hbase.zookeeper.ZKListenerpublic void nodeCreated(String path)
nodeCreated in class org.apache.hadoop.hbase.zookeeper.ZKListenerpublic void nodeDataChanged(String path)
nodeDataChanged in class org.apache.hadoop.hbase.zookeeper.ZKListenervoid waitForDeletion() throws InterruptedException
InterruptedExceptionvoid waitForCreation() throws InterruptedException
InterruptedExceptionvoid waitForDataChange() throws InterruptedException
InterruptedExceptionCopyright © 2007–2020 The Apache Software Foundation. All rights reserved.