Field Detail

• LOG

  private static final org.apache.commons.logging.Log LOG

• nsStateCache

  private ConcurrentMap<String,NamespaceTableAndRegionInfo> nsStateCache

• master

  private MasterServices master

• initialized

  private volatile boolean initialized

Constructor Detail

• NamespaceStateManager

  public NamespaceStateManager(MasterServices masterServices,
                       ZooKeeperWatcher zkw)

Method Detail

• start

  public void start()
             throws IOException

  Starts the NamespaceStateManager. The boot strap of cache is done in the post master start hook of the NamespaceAuditor class.

  Throws:

  IOException - Signals that an I/O exception has occurred.

• getState

  public NamespaceTableAndRegionInfo getState(String name)

  Gets an instance of NamespaceTableAndRegionInfo associated with namespace.

  Parameters:

  The - name of the namespace

  Returns:

  An instance of NamespaceTableAndRegionInfo.

• checkAndUpdateNamespaceRegionCount

  boolean checkAndUpdateNamespaceRegionCount(TableName name,
                                           byte[] regionName,
                                           int incr)
                                       throws IOException

  Check if adding a region violates namespace quota, if not update namespace cache.

  Parameters:

  TableName -

  regionName -

  incr -

  Returns:

  true, if region can be added to table.

  Throws:

  IOException - Signals that an I/O exception has occurred.

• checkAndUpdateNamespaceRegionCount

  void checkAndUpdateNamespaceRegionCount(TableName name,
                                        int incr)
                                    throws IOException

  Check and update region count for an existing table. To handle scenarios like restore snapshot

  Parameters:

  TableName - name of the table for region count needs to be checked and updated

  incr - count of regions

  Throws:

  QuotaExceededException - if quota exceeds for the number of regions allowed in a namespace

  IOException - Signals that an I/O exception has occurred.

• getNamespaceDescriptor

  private NamespaceDescriptor getNamespaceDescriptor(String namespaceAsString)

• checkAndUpdateNamespaceTableCount

  void checkAndUpdateNamespaceTableCount(TableName table,
                                       int numRegions)
                                   throws IOException

  Throws:

  IOException

• addNamespace

  NamespaceTableAndRegionInfo addNamespace(String namespace)

• deleteNamespace

  void deleteNamespace(String namespace)

  Delete the namespace state.

  Parameters:

  An - instance of NamespaceTableAndRegionInfo

• addTable

  private void addTable(TableName tableName,
              int regionCount)
                 throws IOException

  Throws:

  IOException

• removeTable

  void removeTable(TableName tableName)

• initialize

  private void initialize()
                   throws IOException

  Initialize namespace state cache by scanning meta table.

  Throws:

  IOException

• isInitialized

  boolean isInitialized()

• removeRegionFromTable

  public void removeRegionFromTable(HRegionInfo hri)
                             throws IOException

  Throws:

  IOException

• nodeCreated

  public void nodeCreated(String path)

  Description copied from class: ZooKeeperListener
  Called when a new node has been created.

  Overrides:

  nodeCreated in class ZooKeeperListener

  Parameters:

  path - full path of the new node

• nodeChildrenChanged

  public void nodeChildrenChanged(String path)

  Description copied from class: ZooKeeperListener
  Called when an existing node has a child node added or removed.

  Overrides:

  nodeChildrenChanged in class ZooKeeperListener

  Parameters:

  path - full path of the node whose children have changed

• checkSplittingOrMergingNode

  private void checkSplittingOrMergingNode(String path)