@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 n * @param labelsOrUserAuths true for
writing labels and false for user auths.
|
getWatcher
private 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.KeeperException
private void refreshVisibilityLabelsCache(byte[] data)
private void refreshUserAuthsCache(byte[] data)
public void nodeCreated(String path)
ZKListener
nodeCreated
in class ZKListener
path
- full path of the new nodepublic void nodeDeleted(String path)
ZKListener
nodeDeleted
in class ZKListener
path
- full path of the deleted nodepublic void nodeDataChanged(String path)
ZKListener
nodeDataChanged
in class ZKListener
path
- full path of the updated nodepublic void nodeChildrenChanged(String path)
ZKListener
nodeChildrenChanged
in class ZKListener
path
- full path of the node whose children have changedpublic void writeToZookeeper(byte[] data, boolean labelsOrUserAuths)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.