org.apache.hadoop.hbase.zookeeper

Class ClusterStatusTracker

java.lang.Object

org.apache.hadoop.hbase.zookeeper.ZooKeeperListener

org.apache.hadoop.hbase.zookeeper.ZooKeeperNodeTracker

org.apache.hadoop.hbase.zookeeper.ClusterStatusTracker

@InterfaceAudience.Private
public class ClusterStatusTracker
extends ZooKeeperNodeTracker

Tracker on cluster settings up in zookeeper. This is not related to ClusterStatus. That class is a data structure that holds snapshot of current view on cluster. This class is about tracking cluster attributes up in zookeeper.

Field Summary

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

abortable, node

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

watcher

Constructor Summary

Constructors

Constructor and Description
ClusterStatusTracker(ZooKeeperWatcher watcher, Abortable abortable) Creates a cluster status tracker.

Method Summary

Modifier and Type	Method and Description
boolean	isClusterUp() Checks if cluster is up.
void	setClusterDown() Sets the cluster as down by deleting the znode.
void	setClusterUp() Sets the cluster as up.

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

blockUntilAvailable, blockUntilAvailable, checkIfBaseNodeAvailable, getData, getNode, nodeCreated, nodeDataChanged, nodeDeleted, start, stop, toString

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

getWatcher, nodeChildrenChanged

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterStatusTracker

public ClusterStatusTracker(ZooKeeperWatcher watcher,
                            Abortable abortable)

Creates a cluster status tracker.

After construction, use ZooKeeperNodeTracker.start() to kick off tracking.

Parameters:

watcher -

abortable -

Method Detail

isClusterUp

public boolean isClusterUp()

Checks if cluster is up.

Returns:

true if the cluster up ('shutdown' is its name up in zk) znode exists with data, false if not

setClusterUp

public void setClusterUp()
                  throws KeeperException

Sets the cluster as up.

Throws:

KeeperException - unexpected zk exception

setClusterDown

public void setClusterDown()
                    throws KeeperException

Sets the cluster as down by deleting the znode.

Throws:

KeeperException - unexpected zk exception