org.apache.hadoop.hbase.zookeeper

Class ZKTableStateClientSideReader

java.lang.Object

org.apache.hadoop.hbase.zookeeper.ZKTableStateClientSideReader

@InterfaceAudience.Private
public class ZKTableStateClientSideReader
extends Object

Non-instantiable class that provides helper functions to learn about HBase table state for code running on client side (hence, not having access to consensus context). Doesn't cache any table state, just goes directly to ZooKeeper. TODO: decouple this class from ZooKeeper.

Method Summary

Modifier and Type	Method and Description
static Set<TableName>	getDisabledOrDisablingTables(ZooKeeperWatcher zkw) Gets a list of all the tables set as disabled in zookeeper.
static Set<TableName>	getDisabledTables(ZooKeeperWatcher zkw) Gets a list of all the tables set as disabled in zookeeper.
static Set<TableName>	getEnablingTables(ZooKeeperWatcher zkw) Gets a list of all the tables set as enabling in zookeeper.
static boolean	isDisabledTable(ZooKeeperWatcher zkw, TableName tableName) Go to zookeeper and see if state of table is ZooKeeperProtos.Table.State#DISABLED.
static boolean	isDisablingOrDisabledTable(ZooKeeperWatcher zkw, TableName tableName) Go to zookeeper and see if state of table is ZooKeeperProtos.Table.State#DISABLING of ZooKeeperProtos.Table.State#DISABLED.
static boolean	isEnabledTable(ZooKeeperWatcher zkw, TableName tableName) Go to zookeeper and see if state of table is ZooKeeperProtos.Table.State#ENABLED.

Methods inherited from class java.lang.Object

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

Method Detail

isDisabledTable

public static boolean isDisabledTable(ZooKeeperWatcher zkw,
                                      TableName tableName)
                               throws KeeperException,
                                      InterruptedException

Go to zookeeper and see if state of table is ZooKeeperProtos.Table.State#DISABLED. This method does not use cache. This method is for clients other than AssignmentManager

Parameters:

zkw - ZooKeeperWatcher instance to use

tableName - table we're checking

Returns:

True if table is enabled.

Throws:

KeeperException

InterruptedException

isEnabledTable

public static boolean isEnabledTable(ZooKeeperWatcher zkw,
                                     TableName tableName)
                              throws KeeperException,
                                     InterruptedException

Go to zookeeper and see if state of table is ZooKeeperProtos.Table.State#ENABLED. This method does not use cache. This method is for clients other than AssignmentManager

Parameters:

zkw - ZooKeeperWatcher instance to use

tableName - table we're checking

Returns:

True if table is enabled.

Throws:

KeeperException

InterruptedException

isDisablingOrDisabledTable

public static boolean isDisablingOrDisabledTable(ZooKeeperWatcher zkw,
                                                 TableName tableName)
                                          throws KeeperException,
                                                 InterruptedException

Go to zookeeper and see if state of table is ZooKeeperProtos.Table.State#DISABLING of ZooKeeperProtos.Table.State#DISABLED. This method does not use cache. This method is for clients other than AssignmentManager.

Parameters:

zkw - ZooKeeperWatcher instance to use

tableName - table we're checking

Returns:

True if table is enabled.

Throws:

KeeperException

InterruptedException

getDisabledTables

public static Set<TableName> getDisabledTables(ZooKeeperWatcher zkw)
                                        throws KeeperException,
                                               InterruptedException

Gets a list of all the tables set as disabled in zookeeper.

Returns:

Set of disabled tables, empty Set if none

Throws:

KeeperException

InterruptedException

getDisabledOrDisablingTables

public static Set<TableName> getDisabledOrDisablingTables(ZooKeeperWatcher zkw)
                                                   throws KeeperException,
                                                          InterruptedException

Gets a list of all the tables set as disabled in zookeeper.

Returns:

Set of disabled tables, empty Set if none

Throws:

KeeperException

InterruptedException

getEnablingTables

public static Set<TableName> getEnablingTables(ZooKeeperWatcher zkw)
                                        throws KeeperException,
                                               InterruptedException

Gets a list of all the tables set as enabling in zookeeper.

Parameters:

zkw - ZooKeeperWatcher instance to use

Returns:

Set of enabling tables, empty Set if none

Throws:

KeeperException

InterruptedException