@InterfaceAudience.Private public class ZKVisibilityLabelWatcher extends ZKListener
| Modifier and Type | Field and Description | 
|---|---|
| private static String | DEFAULT_VISIBILITY_LABEL_NODE | 
| private static String | DEFAULT_VISIBILITY_USER_AUTHS_NODE | 
| private VisibilityLabelsCache | labelsCache | 
| private String | labelZnode | 
| private static org.slf4j.Logger | LOG | 
| private String | userAuthsZnode | 
| private static String | VISIBILITY_LABEL_ZK_PATH | 
| private static String | VISIBILITY_USER_AUTHS_ZK_PATH | 
watcher| Constructor and Description | 
|---|
| ZKVisibilityLabelWatcher(ZKWatcher watcher,
                        VisibilityLabelsCache labelsCache,
                        org.apache.hadoop.conf.Configuration conf) | 
| Modifier and Type | Method and Description | 
|---|---|
| void | nodeChildrenChanged(String path)Called when an existing node has a child node added or removed. | 
| void | nodeCreated(String path)Called when a new node has been created. | 
| void | nodeDataChanged(String path)Called when an existing node has changed data. | 
| void | nodeDeleted(String path)Called when a node has been deleted | 
| private void | refreshUserAuthsCache(byte[] data) | 
| private void | refreshVisibilityLabelsCache(byte[] data) | 
| void | start() | 
| void | writeToZookeeper(byte[] data,
                boolean labelsOrUserAuths)Write a labels mirror or user auths mirror into zookeeper | 
getWatcherprivate static final org.slf4j.Logger LOG
private static final String VISIBILITY_LABEL_ZK_PATH
private static final String DEFAULT_VISIBILITY_LABEL_NODE
private static final String VISIBILITY_USER_AUTHS_ZK_PATH
private static final String DEFAULT_VISIBILITY_USER_AUTHS_NODE
private VisibilityLabelsCache labelsCache
private String labelZnode
private String userAuthsZnode
public ZKVisibilityLabelWatcher(ZKWatcher watcher, VisibilityLabelsCache labelsCache, org.apache.hadoop.conf.Configuration conf)
public void start() throws org.apache.zookeeper.KeeperException
org.apache.zookeeper.KeeperExceptionprivate void refreshVisibilityLabelsCache(byte[] data)
private void refreshUserAuthsCache(byte[] data)
public void nodeCreated(String path)
ZKListenernodeCreated in class ZKListenerpath - full path of the new nodepublic void nodeDeleted(String path)
ZKListenernodeDeleted in class ZKListenerpath - full path of the deleted nodepublic void nodeDataChanged(String path)
ZKListenernodeDataChanged in class ZKListenerpath - full path of the updated nodepublic void nodeChildrenChanged(String path)
ZKListenernodeChildrenChanged in class ZKListenerpath - full path of the node whose children have changedpublic void writeToZookeeper(byte[] data, boolean labelsOrUserAuths)
data - labelsOrUserAuths - true for writing labels and false for user auths.Copyright © 2007–2021 The Apache Software Foundation. All rights reserved.