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.ZKListener
public void nodeCreated(String path)
nodeCreated
in class org.apache.hadoop.hbase.zookeeper.ZKListener
public void nodeDataChanged(String path)
nodeDataChanged
in class org.apache.hadoop.hbase.zookeeper.ZKListener
void waitForDeletion() throws InterruptedException
InterruptedException
void waitForCreation() throws InterruptedException
InterruptedException
void waitForDataChange() throws InterruptedException
InterruptedException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.