测试类
package test1;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HbaseConfiguration;
import org.apache.hadoop.hbase.client.HbaseAdmin;
public class MainHB {
public static void main(String[] args) {
try {
HbaseOp ho = new HbaseOp();
String[] name = new String[2];
String tab = "Tab1";
name[0] = "f1";
name[1] = "f2";
ho.createTable(tab, name);
;
System.out.println("建表成功 OK");
} catch (Exception e) {
e.printStackTrace();
}
try { HbaseOp ho1=new HbaseOp();
ho1.deleteTable("Tab1");
System.out.println("删除成功");
}
catch(Exception e){
e.printStackTrace();
}
}
}
方法类
package test1;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HbaseConfiguration;
import org.apache.hadoop.hbase.HColumnDescriptor;
import org.apache.hadoop.hbase.HTableDescriptor;
import org.apache.hadoop.hbase.client.HbaseAdmin;
public class HbaseOp {
// TODO Auto-generated method stub
Configuration conf=HbaseConfiguration.create();
public void createTable(String strTab,String[] arrCf) throws Exception{
HbaseAdmin admin=new HbaseAdmin(conf);
if(admin.tableExists(strTab)) {
System.out.println("Table"+strTab+"exists.");
}
else {
HTableDescriptor fs=new HTableDescriptor(strTab);
for(String cf:arrCf) {
HColumnDescriptor ff=new HColumnDescriptor(cf);
ff.setTimeToLive(10000);
fs.addFamily(ff);
}
admin.createTable(fs);
}
admin.close();
}
public void deleteTable(String strTab)throws Exception
{
HbaseAdmin admin = new HbaseAdmin(conf);
if (!admin.tableExists(strTab)) {//判断表是否存在
System.out.println(strTab + "不存在");
}
else if(admin.isTableEnabled(strTab)) {//如果表处于disable
admin.disableTable(strTab);
admin.deleteTable(strTab);
System.out.println(strTab + " deleted");
}
else
{
admin.deleteTable(strTab);
System.out.println(strTab + " deleted");
}
admin.close();
}
}



