Package org.apache.hadoop.hbase

Class ZKNamespaceManager

java.lang.Object

org.apache.hadoop.hbase.zookeeper.ZKListener

org.apache.hadoop.hbase.ZKNamespaceManager

@Private
public class ZKNamespaceManager
extends ZKListener

Class servers two purposes: 1. Broadcast NamespaceDescriptor information via ZK (Done by the Master) 2. Consume broadcasted NamespaceDescriptor changes (Done by the RegionServers)

Field Summary

Fields

Modifier and Type	Field	Description
private final NavigableMap<String,NamespaceDescriptor>	cache
private static final org.slf4j.Logger	LOG
private final String	nsZNode

Fields inherited from class org.apache.hadoop.hbase.zookeeper.ZKListener

watcher

Constructor Summary

Constructors

Constructor	Description
ZKNamespaceManager(ZKWatcher zkw)

Method Summary

Modifier and Type	Method	Description
private void	deleteNamespace(String name)
NamespaceDescriptor	get(String name)
NavigableSet<NamespaceDescriptor>	list()
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	refreshNodes(List<ZKUtil.NodeAndData> nodes)
void	remove(String name)
void	start()
void	stop()
void	update(NamespaceDescriptor ns)
private void	writeNamespace(NamespaceDescriptor ns)

Methods inherited from class org.apache.hadoop.hbase.zookeeper.ZKListener

getWatcher

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

LOG

private static final org.slf4j.Logger LOG

nsZNode

private final String nsZNode

cache

private final NavigableMap<String,NamespaceDescriptor> cache

Constructor Details

ZKNamespaceManager

public ZKNamespaceManager(ZKWatcher zkw)
                   throws IOException

Throws:

IOException

Method Details

start

public void start()
           throws IOException

Throws:

IOException

stop

public void stop()
          throws IOException

Throws:

IOException

get

public NamespaceDescriptor get(String name)

update

public void update(NamespaceDescriptor ns)
            throws IOException

Throws:

IOException

remove

public void remove(String name)
            throws IOException

Throws:

IOException

list

public NavigableSet<NamespaceDescriptor> list()
                                       throws IOException

Throws:

IOException

nodeCreated

public void nodeCreated(String path)

Description copied from class: ZKListener

Called when a new node has been created.

Overrides:

nodeCreated in class ZKListener

Parameters:

path - full path of the new node

nodeDeleted

public void nodeDeleted(String path)

Description copied from class: ZKListener

Called when a node has been deleted

Overrides:

nodeDeleted in class ZKListener

Parameters:

path - full path of the deleted node

nodeDataChanged

public void nodeDataChanged(String path)

Description copied from class: ZKListener

Called when an existing node has changed data.

Overrides:

nodeDataChanged in class ZKListener

Parameters:

path - full path of the updated node

nodeChildrenChanged

public void nodeChildrenChanged(String path)

Description copied from class: ZKListener

Called when an existing node has a child node added or removed.

Overrides:

nodeChildrenChanged in class ZKListener

Parameters:

path - full path of the node whose children have changed

deleteNamespace

private void deleteNamespace(String name)
                      throws IOException

Throws:

IOException

writeNamespace

private void writeNamespace(NamespaceDescriptor ns)
                     throws IOException

Throws:

IOException

refreshNodes

private void refreshNodes(List<ZKUtil.NodeAndData> nodes)
                   throws IOException

Throws:

IOException