栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

使用eplicse对hbase进行操作

使用eplicse对hbase进行操作

 

 

 测试类

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();
}


}

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/779573.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号