Constructor Detail

• ZKTableStateManager

  public ZKTableStateManager(ZooKeeperWatcher zkw)
                      throws org.apache.zookeeper.KeeperException,
                             InterruptedException

  Throws:

  org.apache.zookeeper.KeeperException

  InterruptedException

Method Detail

• setTableState

  public void setTableState(TableName tableName,
                   org.apache.hadoop.hbase.protobuf.generated.ZooKeeperProtos.Table.State state)
                     throws CoordinatedStateException

  Sets table state in ZK. Sets no watches. Sets the table into desired state. Fails silently if the table is already in this state.

  Specified by:

  setTableState in interface TableStateManager

  Parameters:

  tableName - table to process

  state - new state of this table

  Throws:

  CoordinatedStateException - if error happened when trying to set table state

• setTableStateIfInStates

  public boolean setTableStateIfInStates(TableName tableName,
                                org.apache.hadoop.hbase.protobuf.generated.ZooKeeperProtos.Table.State newState,
                                org.apache.hadoop.hbase.protobuf.generated.ZooKeeperProtos.Table.State... states)
                                  throws CoordinatedStateException

  Checks and sets table state in ZK. Sets no watches. Sets the specified table into the newState, but only if the table is already in one of the possibleCurrentStates (otherwise no operation is performed).

  Specified by:

  setTableStateIfInStates in interface TableStateManager

  Parameters:

  tableName - table to process

  newState - new state for the table

  states - table should be in one of these states for the operation to be performed

  Returns:

  true if operation succeeded, false otherwise

  Throws:

  CoordinatedStateException - if error happened while performing operation

• setTableStateIfNotInStates

  public boolean setTableStateIfNotInStates(TableName tableName,
                                   org.apache.hadoop.hbase.protobuf.generated.ZooKeeperProtos.Table.State newState,
                                   org.apache.hadoop.hbase.protobuf.generated.ZooKeeperProtos.Table.State... states)
                                     throws CoordinatedStateException

  Checks and sets table state in ZK. Sets no watches. Sets the specified table into the newState, but only if the table is NOT in one of the possibleCurrentStates (otherwise no operation is performed).

  Specified by:

  setTableStateIfNotInStates in interface TableStateManager

  Parameters:

  tableName - table to process

  newState - new state for the table

  states - table should NOT be in one of these states for the operation to be performed

  Returns:

  true if operation succeeded, false otherwise

  Throws:

  CoordinatedStateException - if error happened while performing operation

• isTableState

  public boolean isTableState(TableName tableName,
                     org.apache.hadoop.hbase.protobuf.generated.ZooKeeperProtos.Table.State... states)

  Checks if table is marked in specified state in ZK (using cache only).

  Specified by:

  isTableState in interface TableStateManager

  Returns:

  true if the table is in any one of the listed states, false otherwise.

• isTableState

  public boolean isTableState(TableName tableName,
                     boolean checkSource,
                     org.apache.hadoop.hbase.protobuf.generated.ZooKeeperProtos.Table.State... states)

  Checks if table is marked in specified state in ZK.

  Specified by:

  isTableState in interface TableStateManager

  Returns:

  true if the table is in any one of the listed states, false otherwise.

• setDeletedTable

  public void setDeletedTable(TableName tableName)
                       throws CoordinatedStateException

  Deletes the table in zookeeper. Fails silently if the table is not currently disabled in zookeeper. Sets no watches. Mark table as deleted. Fails silently if the table is not currently marked as disabled.

  Specified by:

  setDeletedTable in interface TableStateManager

  Parameters:

  tableName - table to be deleted

  Throws:

  CoordinatedStateException - if error happened while performing operation

• isTablePresent

  public boolean isTablePresent(TableName tableName)

  check if table is present.

  Specified by:

  isTablePresent in interface TableStateManager

  Parameters:

  tableName - table we're working on

  Returns:

  true if the table is present

• getTablesInStates

  public Set<TableName> getTablesInStates(org.apache.hadoop.hbase.protobuf.generated.ZooKeeperProtos.Table.State... states)
                                   throws InterruptedIOException,
                                          CoordinatedStateException

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

  Specified by:

  getTablesInStates in interface TableStateManager

  Returns:

  Set of disabling tables, empty Set if none

  Throws:

  CoordinatedStateException - if error happened in underlying coordination engine

  InterruptedIOException

• checkAndRemoveTableState

  public void checkAndRemoveTableState(TableName tableName,
                              org.apache.hadoop.hbase.protobuf.generated.ZooKeeperProtos.Table.State states,
                              boolean deletePermanentState)
                                throws CoordinatedStateException

  If the table is found in the given state the in-memory state is removed. This helps in cases where CreateTable is to be retried by the client in case of failures. If deletePermanentState is true - the flag kept permanently is also reset.

  Specified by:

  checkAndRemoveTableState in interface TableStateManager

  Parameters:

  tableName - table we're working on

  states - if table isn't in any one of these states, operation aborts

  deletePermanentState - if true, reset the permanent flag

  Throws:

  CoordinatedStateException - if error happened in underlying coordination engine