Uses of Class
org.apache.hadoop.hbase.zookeeper.ZooKeeperWatcher

Packages that use ZooKeeperWatcher
org.apache.hadoop.hbase   
org.apache.hadoop.hbase.catalog   
org.apache.hadoop.hbase.client Provides HBase Client 
org.apache.hadoop.hbase.master   
org.apache.hadoop.hbase.regionserver   
org.apache.hadoop.hbase.replication Multi Cluster Replication 
org.apache.hadoop.hbase.replication.regionserver   
org.apache.hadoop.hbase.zookeeper   
 

Uses of ZooKeeperWatcher in org.apache.hadoop.hbase
 

Methods in org.apache.hadoop.hbase that return ZooKeeperWatcher
 ZooKeeperWatcher Server.getZooKeeper()
          Gets the ZooKeeper instance for this server.
 

Constructors in org.apache.hadoop.hbase with parameters of type ZooKeeperWatcher
MasterAddressTracker(ZooKeeperWatcher watcher, Abortable abortable)
          Construct a master address listener with the specified zookeeper reference.
 

Uses of ZooKeeperWatcher in org.apache.hadoop.hbase.catalog
 

Methods in org.apache.hadoop.hbase.catalog with parameters of type ZooKeeperWatcher
static void RootLocationEditor.deleteRootLocation(ZooKeeperWatcher zookeeper)
          Deletes the location of -ROOT- in ZooKeeper.
static void RootLocationEditor.setRootLocation(ZooKeeperWatcher zookeeper, HServerAddress location)
          Sets the location of -ROOT- in ZooKeeper to the specified server address.
 

Constructors in org.apache.hadoop.hbase.catalog with parameters of type ZooKeeperWatcher
CatalogTracker(ZooKeeperWatcher zk, HConnection connection, Abortable abortable)
          Constructs the catalog tracker.
CatalogTracker(ZooKeeperWatcher zk, HConnection connection, Abortable abortable, int defaultTimeout)
          Constructs the catalog tracker.
 

Uses of ZooKeeperWatcher in org.apache.hadoop.hbase.client
 

Methods in org.apache.hadoop.hbase.client that return ZooKeeperWatcher
 ZooKeeperWatcher HConnection.getZooKeeperWatcher()
          Retrieve ZooKeeperWatcher used by this connection.
 

Uses of ZooKeeperWatcher in org.apache.hadoop.hbase.master
 

Methods in org.apache.hadoop.hbase.master that return ZooKeeperWatcher
 ZooKeeperWatcher HMaster.getZooKeeper()
           
 ZooKeeperWatcher HMaster.getZooKeeperWatcher()
          Get the ZK wrapper object - needed by master_jsp.java
 

Uses of ZooKeeperWatcher in org.apache.hadoop.hbase.regionserver
 

Methods in org.apache.hadoop.hbase.regionserver that return ZooKeeperWatcher
 ZooKeeperWatcher HRegionServer.getZooKeeper()
           
 

Uses of ZooKeeperWatcher in org.apache.hadoop.hbase.replication
 

Methods in org.apache.hadoop.hbase.replication that return ZooKeeperWatcher
 ZooKeeperWatcher ReplicationPeer.getZkw()
          Get the ZK connection to this peer
 ZooKeeperWatcher ReplicationZookeeper.getZookeeperWatcher()
          Get this cluster's zk connection
 

Constructors in org.apache.hadoop.hbase.replication with parameters of type ZooKeeperWatcher
ReplicationPeer(org.apache.hadoop.conf.Configuration conf, String key, String id, ZooKeeperWatcher zkw)
          Constructor that takes all the objects required to communicate with the specified peer, except for the region server addresses.
ReplicationZookeeper.ReplicationStatusTracker(ZooKeeperWatcher watcher, Abortable abortable)
           
ReplicationZookeeper(Abortable abortable, org.apache.hadoop.conf.Configuration conf, ZooKeeperWatcher zk)
          Constructor used by clients of replication (like master and HBase clients)
 

Uses of ZooKeeperWatcher in org.apache.hadoop.hbase.replication.regionserver
 

Constructors in org.apache.hadoop.hbase.replication.regionserver with parameters of type ZooKeeperWatcher
ReplicationSourceManager.OtherRegionServerWatcher(ZooKeeperWatcher watcher)
          Construct a ZooKeeper event listener.
ReplicationSourceManager.PeersWatcher(ZooKeeperWatcher watcher)
          Construct a ZooKeeper event listener.
 

Uses of ZooKeeperWatcher in org.apache.hadoop.hbase.zookeeper
 

Fields in org.apache.hadoop.hbase.zookeeper declared as ZooKeeperWatcher
protected  ZooKeeperWatcher ZooKeeperListener.watcher
           
 

Methods in org.apache.hadoop.hbase.zookeeper with parameters of type ZooKeeperWatcher
static void ZKUtil.asyncCreate(ZooKeeperWatcher zkw, String znode, byte[] data, org.apache.zookeeper.AsyncCallback.StringCallback cb, Object ctx)
          Async creates the specified node with the specified data.
static void ZKAssign.asyncCreateNodeOffline(ZooKeeperWatcher zkw, HRegionInfo region, String serverName, org.apache.zookeeper.AsyncCallback.StringCallback cb, Object ctx)
          Creates an unassigned node in the OFFLINE state for the specified region.
static void ZKAssign.blockUntilNoRIT(ZooKeeperWatcher zkw)
          Blocks until there are no node in regions in transition.
static void ZKAssign.blockUntilRIT(ZooKeeperWatcher zkw)
          Blocks until there is at least one node in regions in transition.
static int ZKUtil.checkExists(ZooKeeperWatcher zkw, String znode)
          Check if the specified node exists.
static void ZKUtil.createAndFailSilent(ZooKeeperWatcher zkw, String znode)
          Creates the specified node, if the node does not exist.
static int ZKUtil.createAndWatch(ZooKeeperWatcher zkw, String znode, byte[] data)
          Creates the specified node with the specified data and watches it.
static boolean ZKUtil.createEphemeralNodeAndWatch(ZooKeeperWatcher zkw, String znode, byte[] data)
          Set the specified znode to be an ephemeral node carrying the specified data.
static int ZKAssign.createNodeClosing(ZooKeeperWatcher zkw, HRegionInfo region, String serverName)
          Creates a new unassigned node in the CLOSING state for the specified region.
static boolean ZKUtil.createNodeIfNotExistsAndWatch(ZooKeeperWatcher zkw, String znode, byte[] data)
          Creates the specified znode to be a persistent node carrying the specified data.
static void ZKAssign.createNodeOffline(ZooKeeperWatcher zkw, HRegionInfo region, String serverName)
          Creates a new unassigned node in the OFFLINE state for the specified region.
static void ZKAssign.createNodeOffline(ZooKeeperWatcher zkw, HRegionInfo region, String serverName, EventHandler.EventType event)
           
static boolean ZKAssign.createOrForceNodeOffline(ZooKeeperWatcher zkw, HRegionInfo region, String serverName)
          Creates or force updates an unassigned node to the OFFLINE state for the specified region.
static void ZKUtil.createSetData(ZooKeeperWatcher zkw, String znode, byte[] data)
          Set data into node creating node if it doesn't yet exist.
static void ZKUtil.createWithParents(ZooKeeperWatcher zkw, String znode)
          Creates the specified node and all parent nodes required for it to exist.
static void ZKAssign.deleteAllNodes(ZooKeeperWatcher zkw)
          Deletes all unassigned nodes regardless of their state.
static void ZKUtil.deleteChildrenRecursively(ZooKeeperWatcher zkw, String node)
          Delete all the children of the specified node but not the node itself.
static boolean ZKAssign.deleteClosedNode(ZooKeeperWatcher zkw, String regionName)
          Deletes an existing unassigned node that is in the CLOSED state for the specified region.
static boolean ZKAssign.deleteClosingNode(ZooKeeperWatcher zkw, HRegionInfo region)
          Deletes an existing unassigned node that is in the CLOSING state for the specified region.
static void ZKUtil.deleteNode(ZooKeeperWatcher zkw, String node)
          Delete the specified node.
static boolean ZKUtil.deleteNode(ZooKeeperWatcher zkw, String node, int version)
          Delete the specified node with the specified version.
static void ZKAssign.deleteNodeFailSilent(ZooKeeperWatcher watcher, HRegionInfo regionInfo)
          Delete the assignment node regardless of its current state.
static void ZKUtil.deleteNodeFailSilent(ZooKeeperWatcher zkw, String node)
          Deletes the specified node.
static void ZKUtil.deleteNodeRecursively(ZooKeeperWatcher zkw, String node)
          Delete the specified node and all of it's children.
static boolean ZKAssign.deleteOfflineNode(ZooKeeperWatcher zkw, String regionName)
          Deletes an existing unassigned node that is in the OFFLINE state for the specified region.
static boolean ZKAssign.deleteOpenedNode(ZooKeeperWatcher zkw, String regionName)
          Deletes an existing unassigned node that is in the OPENED state for the specified region.
static String ZKUtil.dump(ZooKeeperWatcher zkw)
           
static void ZKAssign.forceNodeOffline(ZooKeeperWatcher zkw, HRegionInfo region, String serverName)
          Forces an existing unassigned node to the OFFLINE state for the specified region.
static RegionTransitionData ZKAssign.getData(ZooKeeperWatcher zkw, String pathOrRegionName)
          Gets the current data in the unassigned node for the specified region name or fully-qualified path.
static byte[] ZKUtil.getData(ZooKeeperWatcher zkw, String znode)
          Get znode data.
static byte[] ZKUtil.getDataAndWatch(ZooKeeperWatcher zkw, String znode)
          Get the data at the specified znode and set a watch.
static HServerAddress ZKUtil.getDataAsAddress(ZooKeeperWatcher zkw, String znode)
          Get the data at the specified znode, deserialize it as an HServerAddress, and set a watch.
static RegionTransitionData ZKAssign.getDataNoWatch(ZooKeeperWatcher zkw, String pathOrRegionName, org.apache.zookeeper.data.Stat stat)
          Gets the current data in the unassigned node for the specified region name or fully-qualified path.
static byte[] ZKUtil.getDataNoWatch(ZooKeeperWatcher zkw, String znode, org.apache.zookeeper.data.Stat stat)
          Get the data at the specified znode without setting a watch.
static Set<String> ZKTable.getDisabledOrDisablingTables(ZooKeeperWatcher zkw)
          Gets a list of all the tables set as disabled in zookeeper.
static Set<String> ZKTable.getDisabledTables(ZooKeeperWatcher zkw)
          Gets a list of all the tables set as disabled in zookeeper.
static String ZKAssign.getNodeName(ZooKeeperWatcher zkw, String regionName)
          Gets the full path node name for the unassigned node for the specified region.
static int ZKUtil.getNumberOfChildren(ZooKeeperWatcher zkw, String znode)
          Get the number of children of the specified node.
static String ZKAssign.getRegionName(ZooKeeperWatcher zkw, String path)
          Gets the region name from the full path node name of an unassigned node.
static boolean ZKTable.isDisabledTable(ZooKeeperWatcher zkw, String tableName)
          Go to zookeeper and see if state of table is ZKTable.TableState.DISABLED.
static boolean ZKTable.isDisablingOrDisabledTable(ZooKeeperWatcher zkw, String tableName)
          Go to zookeeper and see if state of table is ZKTable.TableState.DISABLING of ZKTable.TableState.DISABLED.
static boolean ZKTable.isEnabledTable(ZooKeeperWatcher zkw, String tableName)
          Go to zookeeper and see if state of table is ZKTable.TableState.ENABLED.
static List<HServerAddress> ZKUtil.listChildrenAndGetAsAddresses(ZooKeeperWatcher zkw, String znode)
          Lists the children of the specified znode, retrieving the data of each child as a server address.
static List<String> ZKUtil.listChildrenAndWatchForNewChildren(ZooKeeperWatcher zkw, String znode)
          Lists the children znodes of the specified znode.
static List<String> ZKUtil.listChildrenAndWatchThem(ZooKeeperWatcher zkw, String znode)
          List all the children of the specified znode, setting a watch for children changes and also setting a watch on every individual child in order to get the NodeCreated and NodeDeleted events.
static List<String> ZKUtil.listChildrenNoWatch(ZooKeeperWatcher zkw, String znode)
          Lists the children of the specified znode without setting any watches.
static boolean ZKUtil.nodeHasChildren(ZooKeeperWatcher zkw, String znode)
          Checks if the specified znode has any children.
static int ZKAssign.retransitionNodeOpening(ZooKeeperWatcher zkw, HRegionInfo region, String serverName, int expectedVersion)
          Retransitions an existing unassigned node for the specified region which is currently in the OPENING state to be in the OPENING state.
static boolean ZKUtil.setAddressAndWatch(ZooKeeperWatcher zkw, String znode, HServerAddress address)
          Set the specified znode to be an ephemeral node carrying the specified server address.
static void ZKUtil.setData(ZooKeeperWatcher zkw, String znode, byte[] data)
          Sets the data of the existing znode to be the specified data.
static boolean ZKUtil.setData(ZooKeeperWatcher zkw, String znode, byte[] data, int expectedVersion)
          Sets the data of the existing znode to be the specified data.
static int ZKAssign.transitionNode(ZooKeeperWatcher zkw, HRegionInfo region, String serverName, EventHandler.EventType beginState, EventHandler.EventType endState, int expectedVersion)
          Private method that actually performs unassigned node transitions.
static int ZKAssign.transitionNodeClosed(ZooKeeperWatcher zkw, HRegionInfo region, String serverName, int expectedVersion)
          Transitions an existing unassigned node for the specified region which is currently in the CLOSING state to be in the CLOSED state.
static int ZKAssign.transitionNodeOpened(ZooKeeperWatcher zkw, HRegionInfo region, String serverName, int expectedVersion)
          Transitions an existing unassigned node for the specified region which is currently in the OPENING state to be in the OPENED state.
static int ZKAssign.transitionNodeOpening(ZooKeeperWatcher zkw, HRegionInfo region, String serverName)
          Transitions an existing unassigned node for the specified region which is currently in the OFFLINE state to be in the OPENING state.
static int ZKAssign.transitionNodeOpening(ZooKeeperWatcher zkw, HRegionInfo region, String serverName, EventHandler.EventType beginState)
           
static void ZKUtil.updateExistingNodeData(ZooKeeperWatcher zkw, String znode, byte[] data, int expectedVersion)
          Update the data of an existing node with the expected version to have the specified data.
static boolean ZKAssign.verifyRegionState(ZooKeeperWatcher zkw, HRegionInfo region, EventHandler.EventType expectedState)
          Verifies that the specified region is in the specified state in ZooKeeper.
static boolean ZKUtil.watchAndCheckExists(ZooKeeperWatcher zkw, String znode)
          Watch the specified znode for delete/create/change events.
static List<ZKUtil.NodeAndData> ZKUtil.watchAndGetNewChildren(ZooKeeperWatcher zkw, String baseNode)
          Atomically add watches and read data from all unwatched unassigned nodes.
 

Constructors in org.apache.hadoop.hbase.zookeeper with parameters of type ZooKeeperWatcher
ClusterStatusTracker(ZooKeeperWatcher watcher, Abortable abortable)
          Creates a cluster status tracker.
MetaNodeTracker(ZooKeeperWatcher watcher, CatalogTracker catalogTracker, Abortable abortable)
          Creates a meta node tracker.
RegionServerTracker(ZooKeeperWatcher watcher, Abortable abortable, ServerManager serverManager)
           
RootRegionTracker(ZooKeeperWatcher watcher, Abortable abortable)
          Creates a root region location tracker.
ZKTable(ZooKeeperWatcher zkw)
           
ZooKeeperListener(ZooKeeperWatcher watcher)
          Construct a ZooKeeper event listener.
ZooKeeperNodeTracker(ZooKeeperWatcher watcher, String node, Abortable abortable)
          Constructs a new ZK node tracker.
 



Copyright © 2011 The Apache Software Foundation. All Rights Reserved.