Modifier and Type | Method and Description |
---|---|
ZKWatcher |
Server.getZooKeeper()
Gets the ZooKeeper instance for this server.
|
Constructor and Description |
---|
ZKNamespaceManager(ZKWatcher zkw) |
Modifier and Type | Field and Description |
---|---|
private ZKWatcher |
HFileArchiveManager.zooKeeper |
Modifier and Type | Method and Description |
---|---|
ZKWatcher |
TableHFileArchiveTracker.getZooKeeperWatcher() |
Modifier and Type | Method and Description |
---|---|
private static TableHFileArchiveTracker |
TableHFileArchiveTracker.create(ZKWatcher zkw,
HFileArchiveTableMonitor monitor)
Create an archive tracker with the special passed in table monitor.
|
private void |
HFileArchiveManager.disable(ZKWatcher zooKeeper,
byte[] table)
Disable all archiving of files for a given table
|
private void |
HFileArchiveManager.enable(ZKWatcher zooKeeper,
byte[] table)
Perform a best effort enable of hfile retention, which relies on zookeeper communicating the //
* change back to the hfile cleaner.
|
static String |
ZKTableArchiveClient.getArchiveZNode(org.apache.hadoop.conf.Configuration conf,
ZKWatcher zooKeeper) |
Constructor and Description |
---|
TableHFileArchiveTracker(ZKWatcher watcher,
HFileArchiveTableMonitor monitor) |
Modifier and Type | Field and Description |
---|---|
protected ZKWatcher |
ZkCoordinatedStateManager.watcher |
Modifier and Type | Method and Description |
---|---|
protected static int |
ZkSplitLogWorkerCoordination.attemptToOwnTask(boolean isFirstTime,
ZKWatcher zkw,
ServerName server,
String task,
int taskZKVersion)
Try to own the task by transitioning the zk node data from UNASSIGNED to OWNED.
|
Constructor and Description |
---|
ZKSplitLogManagerCoordination(org.apache.hadoop.conf.Configuration conf,
ZKWatcher watcher) |
ZkSplitLogWorkerCoordination(ServerName serverName,
ZKWatcher watcher) |
Modifier and Type | Method and Description |
---|---|
ZKWatcher |
HMaster.getZooKeeper() |
Modifier and Type | Method and Description |
---|---|
private List<String> |
ServerManager.getRegionServersInZK(ZKWatcher zkw) |
Constructor and Description |
---|
ActiveMasterManager(ZKWatcher watcher,
ServerName sn,
Server master) |
DrainingServerTracker(ZKWatcher watcher,
Abortable abortable,
ServerManager serverManager) |
RegionServerTracker(ZKWatcher watcher,
MasterServices server,
ServerManager serverManager) |
SplitOrMergeTracker(ZKWatcher watcher,
org.apache.hadoop.conf.Configuration conf,
Abortable abortable) |
SwitchStateTracker(ZKWatcher watcher,
String node,
Abortable abortable) |
Modifier and Type | Field and Description |
---|---|
private ZKWatcher |
ReplicationZKNodeCleaner.zkw |
Constructor and Description |
---|
ReplicationQueueDeletor(ZKWatcher zk,
org.apache.hadoop.conf.Configuration conf,
Abortable abortable) |
ReplicationZKNodeCleaner(org.apache.hadoop.conf.Configuration conf,
ZKWatcher zkw,
Abortable abortable) |
Modifier and Type | Field and Description |
---|---|
private ZKWatcher |
ReplicationManager.zkw |
Constructor and Description |
---|
ReplicationManager(org.apache.hadoop.conf.Configuration conf,
ZKWatcher zkw,
Abortable abortable) |
Modifier and Type | Field and Description |
---|---|
(package private) ZKWatcher |
ZKProcedureCoordinator.watcher |
Modifier and Type | Method and Description |
---|---|
ZKWatcher |
ZKProcedureUtil.getWatcher() |
Constructor and Description |
---|
ZKProcedureCoordinator(ZKWatcher watcher,
String procedureClass,
String coordName) |
ZKProcedureMemberRpcs(ZKWatcher watcher,
String procType)
Must call
ZKProcedureMemberRpcs.start(String, ProcedureMember) before this can be used. |
ZKProcedureUtil(ZKWatcher watcher,
String procDescription)
Top-level watcher/controller for procedures across the cluster.
|
Modifier and Type | Field and Description |
---|---|
protected ZKWatcher |
HRegionServer.zooKeeper |
Modifier and Type | Method and Description |
---|---|
ZKWatcher |
HRegionServer.getZooKeeper() |
Modifier and Type | Method and Description |
---|---|
(package private) void |
RSRpcServices.start(ZKWatcher zkWatcher) |
Modifier and Type | Field and Description |
---|---|
private ZKWatcher |
ReplicationQueuesArguments.zk |
private ZKWatcher |
HBaseReplicationEndpoint.zkw |
protected ZKWatcher |
ReplicationStateZKBase.zookeeper |
Modifier and Type | Method and Description |
---|---|
ZKWatcher |
ReplicationQueuesArguments.getZk() |
protected ZKWatcher |
HBaseReplicationEndpoint.getZkw()
Get the ZK connection to this peer
|
Modifier and Type | Method and Description |
---|---|
protected static List<ServerName> |
HBaseReplicationEndpoint.fetchSlavesAddresses(ZKWatcher zkw)
Get the list of all the region servers from the specified peer
|
static ReplicationPeers |
ReplicationFactory.getReplicationPeers(ZKWatcher zk,
org.apache.hadoop.conf.Configuration conf,
Abortable abortable) |
static ReplicationPeers |
ReplicationFactory.getReplicationPeers(ZKWatcher zk,
org.apache.hadoop.conf.Configuration conf,
ReplicationQueuesClient queuesClient,
Abortable abortable) |
static ReplicationTracker |
ReplicationFactory.getReplicationTracker(ZKWatcher zookeeper,
ReplicationPeers replicationPeers,
org.apache.hadoop.conf.Configuration conf,
Abortable abortable,
Stoppable stopper) |
void |
ReplicationQueuesArguments.setZk(ZKWatcher zk) |
Constructor and Description |
---|
OtherRegionServerWatcher(ZKWatcher watcher)
Construct a ZooKeeper event listener.
|
PeerConfigTracker(String peerConfigNode,
ZKWatcher watcher,
Abortable abortable) |
PeerStateTracker(String peerStateZNode,
ZKWatcher watcher,
Abortable abortable) |
PeersWatcher(ZKWatcher watcher)
Construct a ZooKeeper event listener.
|
ReplicationPeersZKImpl(ZKWatcher zk,
org.apache.hadoop.conf.Configuration conf,
ReplicationQueuesClient queuesClient,
Abortable abortable) |
ReplicationPeerZKImpl(ZKWatcher zkWatcher,
org.apache.hadoop.conf.Configuration conf,
String id,
ReplicationPeerConfig peerConfig,
Abortable abortable)
Constructor that takes all the objects required to communicate with the specified peer, except
for the region server addresses.
|
ReplicationQueuesArguments(org.apache.hadoop.conf.Configuration conf,
Abortable abort,
ZKWatcher zk) |
ReplicationQueuesClientArguments(org.apache.hadoop.conf.Configuration conf,
Abortable abort,
ZKWatcher zk) |
ReplicationQueuesClientZKImpl(ZKWatcher zk,
org.apache.hadoop.conf.Configuration conf,
Abortable abortable) |
ReplicationQueuesZKImpl(ZKWatcher zk,
org.apache.hadoop.conf.Configuration conf,
Abortable abortable) |
ReplicationStateZKBase(ZKWatcher zookeeper,
org.apache.hadoop.conf.Configuration conf,
Abortable abortable) |
ReplicationTrackerZKImpl(ZKWatcher zookeeper,
ReplicationPeers replicationPeers,
org.apache.hadoop.conf.Configuration conf,
Abortable abortable,
Stoppable stopper) |
Modifier and Type | Field and Description |
---|---|
private ZKWatcher |
ReplicationHFileCleaner.zkw |
private ZKWatcher |
ReplicationLogCleaner.zkw |
Modifier and Type | Method and Description |
---|---|
private void |
ReplicationHFileCleaner.initReplicationQueuesClient(org.apache.hadoop.conf.Configuration conf,
ZKWatcher zk) |
void |
ReplicationHFileCleaner.setConf(org.apache.hadoop.conf.Configuration conf,
ZKWatcher zk) |
void |
ReplicationLogCleaner.setConf(org.apache.hadoop.conf.Configuration conf,
ZKWatcher zk) |
void |
ReplicationLogCleaner.setConf(org.apache.hadoop.conf.Configuration conf,
ZKWatcher zk,
ReplicationQueuesClient replicationQueuesClient) |
Constructor and Description |
---|
ReplicationPeerConfigUpgrader(ZKWatcher zookeeper,
org.apache.hadoop.conf.Configuration conf,
Abortable abortable) |
Modifier and Type | Field and Description |
---|---|
(package private) ZKWatcher |
ReplicationSyncUp.DummyServer.zkw |
Modifier and Type | Method and Description |
---|---|
ZKWatcher |
ReplicationSyncUp.DummyServer.getZooKeeper() |
Modifier and Type | Method and Description |
---|---|
String |
DumpReplicationQueues.dumpQueues(ClusterConnection connection,
ZKWatcher zkw,
Set<String> peerIds,
boolean hdfs) |
Constructor and Description |
---|
DummyServer(ZKWatcher zkw) |
Modifier and Type | Field and Description |
---|---|
private ZKWatcher |
RSGroupInfoManagerImpl.watcher |
Modifier and Type | Field and Description |
---|---|
private static Map<ZKWatcher,TableAuthManager> |
TableAuthManager.managerMap |
Modifier and Type | Method and Description |
---|---|
static TableAuthManager |
TableAuthManager.getOrCreate(ZKWatcher watcher,
org.apache.hadoop.conf.Configuration conf)
Returns a TableAuthManager from the cache.
|
Constructor and Description |
---|
AccessChecker(org.apache.hadoop.conf.Configuration conf,
ZKWatcher zkw)
Constructor with existing configuration
|
TableAuthManager(ZKWatcher watcher,
org.apache.hadoop.conf.Configuration conf) |
ZKPermissionWatcher(ZKWatcher watcher,
TableAuthManager authManager,
org.apache.hadoop.conf.Configuration conf) |
Constructor and Description |
---|
AuthenticationTokenSecretManager(org.apache.hadoop.conf.Configuration conf,
ZKWatcher zk,
String serverName,
long keyUpdateInterval,
long tokenMaxLifetime)
Create a new secret manager instance for generating keys.
|
LeaderElector(ZKWatcher watcher,
String serverName) |
ZKSecretWatcher(org.apache.hadoop.conf.Configuration conf,
ZKWatcher watcher,
AuthenticationTokenSecretManager secretManager) |
Modifier and Type | Method and Description |
---|---|
static VisibilityLabelsCache |
VisibilityLabelsCache.createAndGet(ZKWatcher watcher,
org.apache.hadoop.conf.Configuration conf)
Creates the singleton instance, if not yet present, and returns the same.
|
Constructor and Description |
---|
VisibilityLabelsCache(ZKWatcher watcher,
org.apache.hadoop.conf.Configuration conf) |
ZKVisibilityLabelWatcher(ZKWatcher watcher,
VisibilityLabelsCache labelsCache,
org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Field and Description |
---|---|
private ZKWatcher |
HBaseFsck.zkw |
Modifier and Type | Method and Description |
---|---|
private ZKWatcher |
HBaseFsck.createZooKeeperWatcher() |
Modifier and Type | Method and Description |
---|---|
private static org.apache.hadoop.hbase.shaded.protobuf.generated.ZooKeeperProtos.DeprecatedTableState.State |
ZKDataMigrator.getTableState(ZKWatcher zkw,
TableName tableName)
Deprecated.
Since 2.0.0. To be removed in hbase-3.0.0.
|
static Map<TableName,TableState.State> |
ZKDataMigrator.queryForTableStates(ZKWatcher zkw)
Deprecated.
Since 2.0.0. To be removed in hbase-3.0.0.
|
Constructor and Description |
---|
ReplicationChecker(org.apache.hadoop.conf.Configuration conf,
ZKWatcher zkw,
ClusterConnection connection,
HbckErrorReporter errorReporter) |
Modifier and Type | Field and Description |
---|---|
protected ZKWatcher |
ZKListener.watcher |
private ZKWatcher |
ZKClusterId.watcher |
Modifier and Type | Method and Description |
---|---|
ZKWatcher |
ZKListener.getWatcher() |
Modifier and Type | Method and Description |
---|---|
private static void |
ZKUtil.appendHFileRefsZNodes(ZKWatcher zkw,
String hFileRefsZNode,
StringBuilder sb) |
private static void |
ZKUtil.appendPeerState(ZKWatcher zkw,
String znodeToProcess,
StringBuilder sb) |
private static void |
ZKUtil.appendPeersZnodes(ZKWatcher zkw,
String peersZnode,
StringBuilder sb) |
private static void |
ZKUtil.appendRSZnodes(ZKWatcher zkw,
String znode,
StringBuilder sb) |
static void |
ZKUtil.asyncCreate(ZKWatcher zkw,
String znode,
byte[] data,
org.apache.zookeeper.AsyncCallback.StringCallback cb,
Object ctx)
Async creates the specified node with the specified data.
|
ServerName |
MetaTableLocator.blockUntilAvailable(ZKWatcher zkw,
int replicaId,
long timeout)
Wait until the meta region is available and is not in transition.
|
ServerName |
MetaTableLocator.blockUntilAvailable(ZKWatcher zkw,
long timeout)
Wait until the meta region is available and is not in transition.
|
List<ServerName> |
MetaTableLocator.blockUntilAvailable(ZKWatcher zkw,
long timeout,
org.apache.hadoop.conf.Configuration conf)
Wait until the primary meta region is available.
|
static int |
ZKUtil.checkExists(ZKWatcher zkw,
String znode)
Check if the specified node exists.
|
private static ArrayList<org.apache.zookeeper.data.ACL> |
ZKUtil.createACL(ZKWatcher zkw,
String node) |
static ArrayList<org.apache.zookeeper.data.ACL> |
ZKUtil.createACL(ZKWatcher zkw,
String node,
boolean isSecureZooKeeper) |
static void |
ZKUtil.createAndFailSilent(ZKWatcher zkw,
String znode)
Creates the specified node, iff the node does not exist.
|
static void |
ZKUtil.createAndFailSilent(ZKWatcher zkw,
String znode,
byte[] data)
Creates the specified node containing specified data, iff the node does not exist.
|
private static void |
ZKUtil.createAndFailSilent(ZKWatcher zkw,
ZKUtil.ZKUtilOp.CreateAndFailSilent cafs) |
static int |
ZKUtil.createAndWatch(ZKWatcher zkw,
String znode,
byte[] data)
Creates the specified node with the specified data and watches it.
|
static boolean |
ZKUtil.createEphemeralNodeAndWatch(ZKWatcher zkw,
String znode,
byte[] data)
Set the specified znode to be an ephemeral node carrying the specified
data.
|
static boolean |
ZKUtil.createNodeIfNotExistsAndWatch(ZKWatcher zkw,
String znode,
byte[] data)
Creates the specified znode to be a persistent node carrying the specified
data.
|
static String |
ZKUtil.createNodeIfNotExistsNoWatch(ZKWatcher zkw,
String znode,
byte[] data,
org.apache.zookeeper.CreateMode createMode)
Creates the specified znode with the specified data but does not watch it.
|
static void |
ZKUtil.createSetData(ZKWatcher zkw,
String znode,
byte[] data)
Set data into node creating node if it doesn't yet exist.
|
static void |
ZKUtil.createWithParents(ZKWatcher zkw,
String znode)
Creates the specified node and all parent nodes required for it to exist.
|
static void |
ZKUtil.createWithParents(ZKWatcher zkw,
String znode,
byte[] data)
Creates the specified node and all parent nodes required for it to exist.
|
static void |
ZKUtil.deleteChildrenRecursively(ZKWatcher zkw,
String node)
Delete all the children of the specified node but not the node itself.
|
static void |
ZKUtil.deleteChildrenRecursivelyMultiOrSequential(ZKWatcher zkw,
boolean runSequentialOnMultiFailure,
String... pathRoots)
Delete all the children of the specified node but not the node itself.
|
static boolean |
MasterAddressTracker.deleteIfEquals(ZKWatcher zkw,
String content)
delete the master znode if its content is same as the parameter
|
void |
MetaTableLocator.deleteMetaLocation(ZKWatcher zookeeper)
Deletes the location of
hbase:meta in ZooKeeper. |
void |
MetaTableLocator.deleteMetaLocation(ZKWatcher zookeeper,
int replicaId) |
static void |
ZKUtil.deleteNode(ZKWatcher zkw,
String node)
Delete the specified node.
|
static boolean |
ZKUtil.deleteNode(ZKWatcher zkw,
String node,
int version)
Delete the specified node with the specified version.
|
static void |
ZKUtil.deleteNodeFailSilent(ZKWatcher zkw,
String node)
Deletes the specified node.
|
private static void |
ZKUtil.deleteNodeFailSilent(ZKWatcher zkw,
ZKUtil.ZKUtilOp.DeleteNodeFailSilent dnfs) |
static void |
ZKUtil.deleteNodeRecursively(ZKWatcher zkw,
String node)
Delete the specified node and all of it's children.
|
static void |
ZKUtil.deleteNodeRecursivelyMultiOrSequential(ZKWatcher zkw,
boolean runSequentialOnMultiFailure,
String... pathRoots)
Delete the specified node and its children.
|
static String |
ZKUtil.dump(ZKWatcher zkw) |
static List<ZKUtil.NodeAndData> |
ZKUtil.getChildDataAndWatchForNewChildren(ZKWatcher zkw,
String baseNode)
Deprecated.
Unused
|
static byte[] |
ZKUtil.getData(ZKWatcher zkw,
String znode)
Get znode data.
|
static byte[] |
ZKUtil.getDataAndWatch(ZKWatcher zkw,
String znode)
Get the data at the specified znode and set a watch.
|
static byte[] |
ZKUtil.getDataAndWatch(ZKWatcher zkw,
String znode,
org.apache.zookeeper.data.Stat stat)
Get the data at the specified znode and set a watch.
|
private static byte[] |
ZKUtil.getDataInternal(ZKWatcher zkw,
String znode,
org.apache.zookeeper.data.Stat stat,
boolean watcherSet) |
static byte[] |
ZKUtil.getDataNoWatch(ZKWatcher zkw,
String znode,
org.apache.zookeeper.data.Stat stat)
Get the data at the specified znode without setting a watch.
|
static String |
ZKSplitLog.getEncodedNodeName(ZKWatcher zkw,
String filename)
Gets the full path node name for the log file being split.
|
static ServerName |
MasterAddressTracker.getMasterAddress(ZKWatcher zkw)
Get master address.
|
static int |
MasterAddressTracker.getMasterInfoPort(ZKWatcher zkw)
Get master info port.
|
ServerName |
MetaTableLocator.getMetaRegionLocation(ZKWatcher zkw)
Gets the meta region location, if available.
|
ServerName |
MetaTableLocator.getMetaRegionLocation(ZKWatcher zkw,
int replicaId)
Gets the meta region location, if available.
|
List<RegionInfo> |
MetaTableLocator.getMetaRegions(ZKWatcher zkw)
Gets the meta regions for the given path with the default replica ID.
|
List<RegionInfo> |
MetaTableLocator.getMetaRegions(ZKWatcher zkw,
int replicaId)
Gets the meta regions for the given path and replica ID.
|
List<Pair<RegionInfo,ServerName>> |
MetaTableLocator.getMetaRegionsAndLocations(ZKWatcher zkw) |
List<Pair<RegionInfo,ServerName>> |
MetaTableLocator.getMetaRegionsAndLocations(ZKWatcher zkw,
int replicaId)
Gets the meta regions and their locations for the given path and replica ID.
|
static RegionState |
MetaTableLocator.getMetaRegionState(ZKWatcher zkw)
Load the meta region state from the meta server ZNode.
|
static RegionState |
MetaTableLocator.getMetaRegionState(ZKWatcher zkw,
int replicaId)
Load the meta region state from the meta server ZNode.
|
private org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface |
MetaTableLocator.getMetaServerConnection(ClusterConnection connection,
ZKWatcher zkw,
long timeout,
int replicaId)
Gets a connection to the server hosting meta, as reported by ZooKeeper, waiting up to the
specified timeout for availability.
|
static int |
ZKUtil.getNumberOfChildren(ZKWatcher zkw,
String znode)
Get the number of children of the specified node.
|
static String |
ZKUtil.getReplicationZnodesDump(ZKWatcher zkw)
Returns a string with replication znodes and position of the replication log
|
private static void |
ZKUtil.getReplicationZnodesDump(ZKWatcher zkw,
StringBuilder sb)
Appends replication znodes to the passed StringBuilder.
|
static String |
ZKSplitLog.getRescanNode(ZKWatcher zkw) |
static UUID |
ZKClusterId.getUUIDForCluster(ZKWatcher zkw)
Get the UUID for the provided ZK watcher.
|
boolean |
MetaTableLocator.isLocationAvailable(ZKWatcher zkw)
Checks if the meta region location is available.
|
static boolean |
ZKSplitLog.isRescanNode(ZKWatcher zkw,
String path)
Checks if the given path represents a rescan node.
|
static List<String> |
ZKUtil.listChildrenAndWatchForNewChildren(ZKWatcher zkw,
String znode)
Lists the children znodes of the specified znode.
|
static List<String> |
ZKUtil.listChildrenAndWatchThem(ZKWatcher 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.
|
private static List<String> |
ZKUtil.listChildrenBFSAndWatchThem(ZKWatcher zkw,
String znode)
BFS Traversal of all the children under path, with the entries in the list,
in the same order as that of the traversal.
|
private static List<String> |
ZKUtil.listChildrenBFSNoWatch(ZKWatcher zkw,
String znode)
BFS Traversal of all the children under path, with the entries in the list,
in the same order as that of the traversal.
|
static List<String> |
ZKUtil.listChildrenNoWatch(ZKWatcher zkw,
String znode)
Lists the children of the specified znode without setting any watches.
|
private static void |
ZKUtil.logRetrievedMsg(ZKWatcher zkw,
String znode,
byte[] data,
boolean watcherSet) |
static void |
ZKUtil.logZKTree(ZKWatcher zkw,
String root)
Recursively print the current state of ZK (non-transactional)
|
private static void |
ZKUtil.logZKTree(ZKWatcher zkw,
String root,
String prefix)
Helper method to print the current state of the ZK tree.
|
static void |
ZKUtil.multiOrSequential(ZKWatcher zkw,
List<ZKUtil.ZKUtilOp> ops,
boolean runSequentialOnMultiFailure)
Use ZooKeeper's multi-update functionality.
|
static boolean |
ZKUtil.nodeHasChildren(ZKWatcher zkw,
String znode)
Checks if the specified znode has any children.
|
private static void |
ZKUtil.processSequentially(ZKWatcher zkw,
List<ZKUtil.ZKUtilOp> ops) |
static String |
ZKClusterId.readClusterIdZNode(ZKWatcher watcher) |
private static void |
ZKAclReset.resetAcls(ZKWatcher zkw,
String znode,
boolean eraseAcls) |
static void |
ZKClusterId.setClusterId(ZKWatcher watcher,
ClusterId id) |
static void |
ZKUtil.setData(ZKWatcher zkw,
String znode,
byte[] data)
Sets the data of the existing znode to be the specified data.
|
static boolean |
ZKUtil.setData(ZKWatcher zkw,
String znode,
byte[] data,
int expectedVersion)
Sets the data of the existing znode to be the specified data.
|
private static void |
ZKUtil.setData(ZKWatcher zkw,
ZKUtil.ZKUtilOp.SetData setData) |
static boolean |
MasterAddressTracker.setMasterAddress(ZKWatcher zkw,
String znode,
ServerName master,
int infoPort)
Set master address into the
master znode or into the backup
subdirectory of backup masters; switch off the passed in znode
path. |
static void |
MetaTableLocator.setMetaLocation(ZKWatcher zookeeper,
ServerName serverName,
int replicaId,
RegionState.State state)
Sets the location of
hbase:meta in ZooKeeper to the specified server address. |
static void |
MetaTableLocator.setMetaLocation(ZKWatcher zookeeper,
ServerName serverName,
RegionState.State state)
Sets the location of
hbase:meta in ZooKeeper to the
specified server address. |
static boolean |
ZKUtil.setWatchIfNodeExists(ZKWatcher zkw,
String znode)
Watch the specified znode, but only if exists.
|
private static org.apache.zookeeper.Op |
ZKUtil.toZooKeeperOp(ZKWatcher zkw,
ZKUtil.ZKUtilOp op)
Convert from ZKUtilOp to ZKOp
|
static void |
ZKUtil.updateExistingNodeData(ZKWatcher zkw,
String znode,
byte[] data,
int expectedVersion)
Deprecated.
Unused
|
boolean |
MetaTableLocator.verifyMetaRegionLocation(ClusterConnection hConnection,
ZKWatcher zkw,
long timeout)
Verify
hbase:meta is deployed and accessible. |
boolean |
MetaTableLocator.verifyMetaRegionLocation(ClusterConnection connection,
ZKWatcher zkw,
long timeout,
int replicaId)
Verify
hbase:meta is deployed and accessible. |
void |
MetaTableLocator.waitMetaRegionLocation(ZKWatcher zkw)
Waits indefinitely for availability of
hbase:meta . |
ServerName |
MetaTableLocator.waitMetaRegionLocation(ZKWatcher zkw,
int replicaId,
long timeout)
Gets the meta region location, if available, and waits for up to the specified timeout if not
immediately available.
|
ServerName |
MetaTableLocator.waitMetaRegionLocation(ZKWatcher zkw,
long timeout)
Gets the meta region location, if available, and waits for up to the
specified timeout if not immediately available.
|
static boolean |
ZKUtil.watchAndCheckExists(ZKWatcher zkw,
String znode)
Watch the specified znode for delete/create/change events.
|
Constructor and Description |
---|
ClusterStatusTracker(ZKWatcher watcher,
Abortable abortable)
Creates a cluster status tracker.
|
DeletionListener(ZKWatcher zkWatcher,
String pathToWatch,
CountDownLatch deletedLatch)
Create a new instance of the deletion watcher.
|
LoadBalancerTracker(ZKWatcher watcher,
Abortable abortable) |
MasterAddressTracker(ZKWatcher watcher,
Abortable abortable)
Construct a master address listener with the specified
zookeeper reference. |
MasterMaintenanceModeTracker(ZKWatcher watcher) |
RegionNormalizerTracker(ZKWatcher watcher,
Abortable abortable) |
ZKClusterId(ZKWatcher watcher,
Abortable abortable) |
ZKLeaderManager(ZKWatcher watcher,
String leaderZNode,
byte[] identifier,
Stoppable candidate)
Deprecated.
|
ZKListener(ZKWatcher watcher)
Construct a ZooKeeper event listener.
|
ZKNodeTracker(ZKWatcher watcher,
String node,
Abortable abortable)
Constructs a new ZK node tracker.
|
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.