@InterfaceAudience.Private public class ZKTableStateClientSideReader extends Object
| 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. |
public static boolean isDisabledTable(ZooKeeperWatcher zkw, TableName tableName) throws org.apache.zookeeper.KeeperException, InterruptedException
ZooKeeperProtos.Table.State#DISABLED.
This method does not use cache.
This method is for clients other than AssignmentManagerzkw - ZooKeeperWatcher instance to usetableName - table we're checkingorg.apache.zookeeper.KeeperExceptionInterruptedExceptionpublic static boolean isEnabledTable(ZooKeeperWatcher zkw, TableName tableName) throws org.apache.zookeeper.KeeperException, InterruptedException
ZooKeeperProtos.Table.State#ENABLED.
This method does not use cache.
This method is for clients other than AssignmentManagerzkw - ZooKeeperWatcher instance to usetableName - table we're checkingorg.apache.zookeeper.KeeperExceptionInterruptedExceptionpublic static boolean isDisablingOrDisabledTable(ZooKeeperWatcher zkw, TableName tableName) throws org.apache.zookeeper.KeeperException, InterruptedException
ZooKeeperProtos.Table.State#DISABLING
of ZooKeeperProtos.Table.State#DISABLED.
This method does not use cache.
This method is for clients other than AssignmentManager.zkw - ZooKeeperWatcher instance to usetableName - table we're checkingorg.apache.zookeeper.KeeperExceptionInterruptedExceptionpublic static Set<TableName> getDisabledTables(ZooKeeperWatcher zkw) throws org.apache.zookeeper.KeeperException, InterruptedException
org.apache.zookeeper.KeeperExceptionInterruptedExceptionpublic static Set<TableName> getDisabledOrDisablingTables(ZooKeeperWatcher zkw) throws org.apache.zookeeper.KeeperException, InterruptedException
org.apache.zookeeper.KeeperExceptionInterruptedExceptionpublic static Set<TableName> getEnablingTables(ZooKeeperWatcher zkw) throws org.apache.zookeeper.KeeperException, InterruptedException
zkw - ZooKeeperWatcher instance to useorg.apache.zookeeper.KeeperExceptionInterruptedExceptionCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.