2016-02-18 23 views
3

我试图截断HBase的表用简单的Java代码:截断HBase的表与Java在Hadoop中2.7.1

HBaseAdmin hbaseAdmin = new HBaseAdmin(new HadoopConfig()); 

,但我得到 “java.lang.reflect.InvocationTargetException”。 我看到HBaseAdmin构造函数已被弃用。

它用Hadoop 2.2.0

回答

2

得手,这是解决方案:

Admin admin = null; 
    Configuration config = HBaseConfiguration.create(); 

    // Add custom config parameters here 

    Connection connection = ConnectionFactory.createConnection(config); 
    try { 
     admin = connection.getAdmin(); 

     for (String tableName : tableNames) { 
      System.out.print("Truncate table " + tableName); 
      try { 
       if (HBaseHelper.isTableExists(tableName)) { 
        if (admin.isTableDisabled(TableName.valueOf(tableName))) { 
         System.out.print("Table " + tableName + " was disabled. Enabling it..."); 
         admin.enableTable(TableName.valueOf(tableName); 
        } 
        HBaseHelper.truncateTable(tableName); 
       } 
      } 
      catch (IOException e) { 
       System.out.print("Failed to truncate table " + tableName + "\nError Msg: " + e.getMessage()); 
      } 
     } 
    } catch (Exception e){ 
     System.out.print("Could not connect to HBase Admin. Error Msg: " + e.getMessage()); 
    } 
2

找到下面的代码片段截断HBase的表在Java代码中工作得很好,

Configuration config = HBaseConfiguration.create(); 
// Add custom config parameters here 
Connection connection = ConnectionFactory.createConnection(config); 
Admin admin = connection.getAdmin() 
admin.truncateTable(TableName.valueOf("bigtable"); 
admin.close(); 

希望这有助于!

+0

谢谢!现在我没有得到Invocation异常,但是“org.apache.hadoop.hbase.TableNotDisabledException”。 – EliranA

+2

我在截断之前禁用了表并成功了。我会寻找一种方法来做到这一点,而不用自己禁用它。 – EliranA