Review Board 1.7.22


HBASE-5509 MR based copier for copying HFiles (trunk version)

Review Request #4218 - Created March 7, 2012 and updated

Lars Hofhansl
trunk
Reviewers
hbase
hbase
This is Facebooks SnaphotMR for backup/restore. Thanks Karthik!

I made the following changes:
1. API changes for trunk.
2. Also copies and patches .tableinfo files as needed.
3. ImportTable can proceed even while HBase is down (HDFS needs to be up obviously). Regions will assigned upon HBase startup.
4. A ZK quorum can be optionally provided to assign imported regions right away (needed in trunk).
5. Some safety checks to verify the backup directory provided for import is in fact a backup directory (otherwise in some case adjacent directories were overwritten with temporary files).

Manual only so far.
http://svn.apache.org/repos/asf/hbase/trunk/src/main/java/org/apache/hadoop/hbase/ipc/HRegionInterface.java
Revision 1301687 New Change
[20] 26 lines
[+20]
27
import org.apache.hadoop.classification.InterfaceStability;
27
import org.apache.hadoop.classification.InterfaceStability;
28
import org.apache.hadoop.hbase.Abortable;
28
import org.apache.hadoop.hbase.Abortable;
29
import org.apache.hadoop.hbase.HRegionInfo;
29
import org.apache.hadoop.hbase.HRegionInfo;
30
import org.apache.hadoop.hbase.HServerInfo;
30
import org.apache.hadoop.hbase.HServerInfo;
31
import org.apache.hadoop.hbase.NotServingRegionException;
31
import org.apache.hadoop.hbase.NotServingRegionException;

    
   
32
import org.apache.hadoop.hbase.ServerName;
32
import org.apache.hadoop.hbase.Stoppable;
33
import org.apache.hadoop.hbase.Stoppable;
33
import org.apache.hadoop.hbase.client.Append;
34
import org.apache.hadoop.hbase.client.Append;
34
import org.apache.hadoop.hbase.client.RowMutations;
35
import org.apache.hadoop.hbase.client.RowMutations;
35
import org.apache.hadoop.hbase.client.Delete;
36
import org.apache.hadoop.hbase.client.Delete;
36
import org.apache.hadoop.hbase.client.Get;
37
import org.apache.hadoop.hbase.client.Get;
[+20] [20] 332 lines
[+20] [+] public void unlockRow(final byte [] regionName, final long lockId)
369
  /**
370
  /**
370
   * Method used when a master is taking the place of another failed one.
371
   * Method used when a master is taking the place of another failed one.
371
   * @return This servers {@link HServerInfo}; it has RegionServer POV on the
372
   * @return This servers {@link HServerInfo}; it has RegionServer POV on the
372
   * hostname which may not agree w/ how the Master sees this server.
373
   * hostname which may not agree w/ how the Master sees this server.
373
   * @throws IOException e
374
   * @throws IOException e
374
   * @deprecated
375
   * @deprecated use {@link #getServerName()} instead
375
   */
376
   */
376
  public HServerInfo getHServerInfo() throws IOException;
377
  public HServerInfo getHServerInfo() throws IOException;
377

    
   
378

   
378
  /**
379
  /**

    
   
380
   * @return This server's {@link ServerName}

    
   
381
   */

    
   
382
  public ServerName getServerName();

    
   
383

   

    
   
384
  /**
379
   * Method used for doing multiple actions(Deletes, Gets and Puts) in one call
385
   * Method used for doing multiple actions(Deletes, Gets and Puts) in one call
380
   * @param multi
386
   * @param multi
381
   * @return MultiResult
387
   * @return MultiResult
382
   * @throws IOException
388
   * @throws IOException
383
   */
389
   */
[+20] [20] 247 lines
http://svn.apache.org/repos/asf/hbase/trunk/src/main/java/org/apache/hadoop/hbase/util/FSTableDescriptors.java
Revision 1301687 New Change
 
  1. http://svn.apache.org/repos/asf/hbase/trunk/src/main/java/org/apache/hadoop/hbase/ipc/HRegionInterface.java: Loading...
  2. http://svn.apache.org/repos/asf/hbase/trunk/src/main/java/org/apache/hadoop/hbase/util/FSTableDescriptors.java: Loading...