@InterfaceAudience.Private public class ZKVisibilityLabelWatcher extends ZKListener
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
|
void |
start() |
void |
writeToZookeeper(byte[] data,
boolean labelsOrUserAuths)
Write a labels mirror or user auths mirror into zookeeper
|
getWatcher
public ZKVisibilityLabelWatcher(ZKWatcher watcher, VisibilityLabelsCache labelsCache, org.apache.hadoop.conf.Configuration conf)
public void start() throws org.apache.zookeeper.KeeperException
org.apache.zookeeper.KeeperException
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)
data
- labelsOrUserAuths
- true for writing labels and false for user auths.Copyright © 2007–2019 Cloudera. All rights reserved.