|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.hadoop.hbase.zookeeper.ZKTable
public class ZKTable
Helper class for table state tracking for use by AssignmentManager
.
Reads, caches and sets state up in zookeeper. If multiple read/write
clients, will make for confusion. Read-only clients other than
AssignmentManager interested in learning table state can use the
read-only utility methods isEnabledTable(ZooKeeperWatcher, String)
and isDisabledTable(ZooKeeperWatcher, String)
.
To save on trips to the zookeeper ensemble, internally we cache table state.
Nested Class Summary | |
---|---|
static class |
ZKTable.TableState
States a Table can be in. |
Constructor Summary | |
---|---|
ZKTable(ZooKeeperWatcher zkw)
|
Method Summary | |
---|---|
static Set<String> |
getDisabledOrDisablingTables(ZooKeeperWatcher zkw)
Gets a list of all the tables set as disabled in zookeeper. |
Set<String> |
getDisabledTables()
Gets a list of all the tables set as disabled in zookeeper. |
static Set<String> |
getDisabledTables(ZooKeeperWatcher zkw)
Gets a list of all the tables set as disabled in zookeeper. |
boolean |
isDisabledOrEnablingTable(String tableName)
|
boolean |
isDisabledTable(String tableName)
|
static boolean |
isDisabledTable(ZooKeeperWatcher zkw,
String tableName)
Go to zookeeper and see if state of table is ZKTable.TableState.DISABLED . |
boolean |
isDisablingOrDisabledTable(String tableName)
|
static boolean |
isDisablingOrDisabledTable(ZooKeeperWatcher zkw,
String tableName)
Go to zookeeper and see if state of table is ZKTable.TableState.DISABLING
of ZKTable.TableState.DISABLED . |
boolean |
isDisablingTable(String tableName)
|
boolean |
isEnabledOrDisablingTable(String tableName)
|
boolean |
isEnabledTable(String tableName)
|
static boolean |
isEnabledTable(ZooKeeperWatcher zkw,
String tableName)
Go to zookeeper and see if state of table is ZKTable.TableState.ENABLED . |
boolean |
isEnablingTable(String tableName)
|
void |
setDisabledTable(String tableName)
Sets the specified table as DISABLED in zookeeper. |
void |
setDisablingTable(String tableName)
Sets the specified table as DISABLING in zookeeper. |
void |
setEnabledTable(String tableName)
Enables the table in zookeeper. |
void |
setEnablingTable(String tableName)
Sets the specified table as ENABLING in zookeeper. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public ZKTable(ZooKeeperWatcher zkw) throws org.apache.zookeeper.KeeperException
org.apache.zookeeper.KeeperException
Method Detail |
---|
public void setDisabledTable(String tableName) throws org.apache.zookeeper.KeeperException
tableName
-
org.apache.zookeeper.KeeperException
- unexpected zookeeper exceptionpublic void setDisablingTable(String tableName) throws org.apache.zookeeper.KeeperException
tableName
-
org.apache.zookeeper.KeeperException
- unexpected zookeeper exceptionpublic void setEnablingTable(String tableName) throws org.apache.zookeeper.KeeperException
tableName
-
org.apache.zookeeper.KeeperException
- unexpected zookeeper exceptionpublic boolean isDisabledTable(String tableName)
public static boolean isDisabledTable(ZooKeeperWatcher zkw, String tableName) throws org.apache.zookeeper.KeeperException
ZKTable.TableState.DISABLED
.
This method does not use cache as isDisabledTable(String)
does.
This method is for clients other than AssignmentManager
zkw
- tableName
-
org.apache.zookeeper.KeeperException
public boolean isDisablingTable(String tableName)
public boolean isEnablingTable(String tableName)
public boolean isEnabledTable(String tableName)
public static boolean isEnabledTable(ZooKeeperWatcher zkw, String tableName) throws org.apache.zookeeper.KeeperException
ZKTable.TableState.ENABLED
.
This method does not use cache as isEnabledTable(String)
does.
This method is for clients other than AssignmentManager
zkw
- tableName
-
org.apache.zookeeper.KeeperException
public boolean isDisablingOrDisabledTable(String tableName)
public static boolean isDisablingOrDisabledTable(ZooKeeperWatcher zkw, String tableName) throws org.apache.zookeeper.KeeperException
ZKTable.TableState.DISABLING
of ZKTable.TableState.DISABLED
.
This method does not use cache as isEnabledTable(String)
does.
This method is for clients other than AssignmentManager
.
zkw
- tableName
-
org.apache.zookeeper.KeeperException
public boolean isEnabledOrDisablingTable(String tableName)
public boolean isDisabledOrEnablingTable(String tableName)
public void setEnabledTable(String tableName) throws org.apache.zookeeper.KeeperException
tableName
-
org.apache.zookeeper.KeeperException
- unexpected zookeeper exceptionpublic Set<String> getDisabledTables()
public static Set<String> getDisabledTables(ZooKeeperWatcher zkw) throws org.apache.zookeeper.KeeperException
org.apache.zookeeper.KeeperException
public static Set<String> getDisabledOrDisablingTables(ZooKeeperWatcher zkw) throws org.apache.zookeeper.KeeperException
org.apache.zookeeper.KeeperException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |