Field Detail

• LOG

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

• fileSystemManager

  protected final MasterFileSystem fileSystemManager

• hTableDescriptor

  protected final HTableDescriptor hTableDescriptor

• conf

  protected final org.apache.hadoop.conf.Configuration conf

• assignmentManager

  private final AssignmentManager assignmentManager

• tableLockManager

  private final TableLockManager tableLockManager

• newRegions

  private final HRegionInfo[] newRegions

• tableLock

  private final TableLockManager.TableLock tableLock

• activeUser

  private User activeUser

Constructor Detail

• CreateTableHandler

  public CreateTableHandler(Server server,
                    MasterFileSystem fileSystemManager,
                    HTableDescriptor hTableDescriptor,
                    org.apache.hadoop.conf.Configuration conf,
                    HRegionInfo[] newRegions,
                    MasterServices masterServices)

Method Detail

• prepare

  public CreateTableHandler prepare()
                             throws NotAllMetaRegionsOnlineException,
                                    TableExistsException,
                                    IOException

  Description copied from class: EventHandler
  Event handlers should do all the necessary checks in this method (rather than in the constructor, or in process()) so that the caller, which is mostly executed in the ipc context can fail fast. Process is executed async from the client ipc, so this method gives a quick chance to do some basic checks. Should be called after constructing the EventHandler, and before process().

  Overrides:

  prepare in class EventHandler

  Returns:

  the instance of this class

  Throws:

  NotAllMetaRegionsOnlineException

  TableExistsException

  IOException

• checkAndSetEnablingTable

  static void checkAndSetEnablingTable(AssignmentManager assignmentManager,
                              TableName tableName,
                              boolean skipTableStateCheck)
                                throws IOException

  Throws:

  IOException

• removeEnablingTable

  static void removeEnablingTable(AssignmentManager assignmentManager,
                         TableName tableName)

• toString

  public String toString()

  Overrides:

  toString in class EventHandler

• process

  public void process()

  Description copied from class: EventHandler
  This method is the main processing loop to be implemented by the various subclasses.

  Specified by:

  process in class EventHandler

• completed

  protected void completed(Throwable exception)

  Called after that process() is completed.

  Parameters:

  exception - null if process() is successful or not null if something has failed.

• handleCreateTable

  private void handleCreateTable(TableName tableName)
                          throws IOException,
                                 CoordinatedStateException

  Responsible of table creation (on-disk and META) and assignment. - Create the table directory and descriptor (temp folder) - Create the on-disk regions (temp folder) [If something fails here: we've just some trash in temp] - Move the table from temp to the root directory [If something fails here: we've the table in place but some of the rows required present in META. (hbck needed)] - Add regions to META [If something fails here: we don't have regions assigned: table disabled] - Assign regions to Region Servers [If something fails here: we still have the table in disabled state] - Update ZooKeeper with the enabled state

  Throws:

  IOException

  CoordinatedStateException

• addReplicas

  protected List<HRegionInfo> addReplicas(HTableDescriptor hTableDescriptor,
                              List<HRegionInfo> regions)

  Create any replicas for the regions (the default replicas that was already created is passed to the method)

  Parameters:

  hTableDescriptor -

  regions - default replicas

  Returns:

  the combined list of default and non-default replicas

• releaseTableLock

  private void releaseTableLock()

• handleCreateHdfsRegions

  protected List<HRegionInfo> handleCreateHdfsRegions(org.apache.hadoop.fs.Path tableRootDir,
                                          TableName tableName)
                                               throws IOException

  Create the on-disk structure for the table, and returns the regions info.

  Parameters:

  tableRootDir - directory where the table is being created

  tableName - name of the table under construction

  Returns:

  the list of regions created

  Throws:

  IOException

• addRegionsToMeta

  protected void addRegionsToMeta(List<HRegionInfo> regionInfos,
                      int regionReplication)
                           throws IOException

  Add the specified set of regions to the hbase:meta table.

  Throws:

  IOException