Field Detail

• LOG

  private static final org.apache.commons.logging.Log LOG

• VISIBILITY_LABEL_ZK_PATH

  private static final String VISIBILITY_LABEL_ZK_PATH

  See Also:

  Constant Field Values

• DEFAULT_VISIBILITY_LABEL_NODE

  private static final String DEFAULT_VISIBILITY_LABEL_NODE

  See Also:

  Constant Field Values

• VISIBILITY_USER_AUTHS_ZK_PATH

  private static final String VISIBILITY_USER_AUTHS_ZK_PATH

  See Also:

  Constant Field Values

• DEFAULT_VISIBILITY_USER_AUTHS_NODE

  private static final String DEFAULT_VISIBILITY_USER_AUTHS_NODE

  See Also:

  Constant Field Values

• labelsCache

  private VisibilityLabelsCache labelsCache

• labelZnode

  private String labelZnode

• userAuthsZnode

  private String userAuthsZnode

Constructor Detail

• ZKVisibilityLabelWatcher

  public ZKVisibilityLabelWatcher(ZooKeeperWatcher watcher,
                          VisibilityLabelsCache labelsCache,
                          org.apache.hadoop.conf.Configuration conf)

Method Detail

• start

  public void start()
             throws org.apache.zookeeper.KeeperException

  Throws:

  org.apache.zookeeper.KeeperException

• refreshVisibilityLabelsCache

  private void refreshVisibilityLabelsCache(byte[] data)

• refreshUserAuthsCache

  private void refreshUserAuthsCache(byte[] data)

• nodeCreated

  public void nodeCreated(String path)

  Description copied from class: ZooKeeperListener
  Called when a new node has been created.

  Overrides:

  nodeCreated in class ZooKeeperListener

  Parameters:

  path - full path of the new node

• nodeDeleted

  public void nodeDeleted(String path)

  Description copied from class: ZooKeeperListener
  Called when a node has been deleted

  Overrides:

  nodeDeleted in class ZooKeeperListener

  Parameters:

  path - full path of the deleted node

• nodeDataChanged

  public void nodeDataChanged(String path)

  Description copied from class: ZooKeeperListener
  Called when an existing node has changed data.

  Overrides:

  nodeDataChanged in class ZooKeeperListener

  Parameters:

  path - full path of the updated node

• nodeChildrenChanged

  public void nodeChildrenChanged(String path)

  Description copied from class: ZooKeeperListener
  Called when an existing node has a child node added or removed.

  Overrides:

  nodeChildrenChanged in class ZooKeeperListener

  Parameters:

  path - full path of the node whose children have changed

• writeToZookeeper

  public void writeToZookeeper(byte[] data,
                      boolean labelsOrUserAuths)

  Write a labels mirror or user auths mirror into zookeeper

  Parameters:

  data -

  labelsOrUserAuths - true for writing labels and false for user auths.