|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
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. |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |