3
我试图截断HBase的表用简单的Java代码:截断HBase的表与Java在Hadoop中2.7.1
HBaseAdmin hbaseAdmin = new HBaseAdmin(new HadoopConfig());
,但我得到 “java.lang.reflect.InvocationTargetException”。 我看到HBaseAdmin构造函数已被弃用。
它用Hadoop 2.2.0
我试图截断HBase的表用简单的Java代码:截断HBase的表与Java在Hadoop中2.7.1
HBaseAdmin hbaseAdmin = new HBaseAdmin(new HadoopConfig());
,但我得到 “java.lang.reflect.InvocationTargetException”。 我看到HBaseAdmin构造函数已被弃用。
它用Hadoop 2.2.0
得手,这是解决方案:
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());
}
找到下面的代码片段截断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();
希望这有助于!
谢谢!现在我没有得到Invocation异常,但是“org.apache.hadoop.hbase.TableNotDisabledException”。 – EliranA
我在截断之前禁用了表并成功了。我会寻找一种方法来做到这一点,而不用自己禁用它。 – EliranA