Hbase的java接口
2015-05-30 16:28
330 查看
public class HbaseDemo { private Configuration conf = null; @Before public void init(){ conf = HBaseConfiguration.create(); conf.set("hbase.zookeeper.quorum", "hadoop01,hadoop02,hadoop03"); } @Test public void testDrop() throws Exception{ HBaseAdmin admin = new HBaseAdmin(conf); admin.disableTable("account"); admin.deleteTable("account"); admin.close(); } @Test public void testPut() throws Exception{ HTable table = new HTable(conf, "user"); Put put = new Put(Bytes.toBytes("rk0003")); put.add(Bytes.toBytes("info"), Bytes.toBytes("name"), Bytes.toBytes("liuyan")); table.put(put); table.close(); } @Test public void testGet() throws Exception{ HTable table = new HTable(conf, "user"); Get get = new Get(Bytes.toBytes("rk0001")); get.setMaxVersions(5); Result result = table.get(get); for(KeyValue kv : result.list()){ String family = new String(kv.getFamily()); String qualifier = new String(kv.getQualifier()); String value = new String(kv.getValue()); System.out.println("family: " + ", qualifier: " + qualifier + ", value: " + value); } table.close(); } @Test public void testScan() throws Exception{ HTablePool pool = new HTablePool(conf, 10); HTableInterface table = pool.getTable("user"); Scan scan = new Scan(Bytes.toBytes("rk0001"), Bytes.toBytes("rk0002")); scan.addFamily(Bytes.toBytes("info")); ResultScanner scanner = table.getScanner(scan); for(Result r : scanner){ byte[] value = r.getValue(Bytes.toBytes("info"), Bytes.toBytes("name")); System.out.println(new String(value)); } pool.close(); } @Test public void testDel() throws Exception{ HTable table = new HTable(conf, "user"); Delete del = new Delete(Bytes.toBytes("rk0001")); del.deleteColumn(Bytes.toBytes("data"), Bytes.toBytes("pic")); table.delete(del); table.close(); } }
相关文章推荐
- java几种排序算法的实现及简单分析
- Java编程思想之-反证法
- java实现快速排序的方法
- 新手用STS(Spring Tool Suite)和Maven构建一个SpringMVC项目
- 【精神哥讲Crash】第二期:java.lang.NoSuchMethodError
- java多线程系列----------- 基本概念释疑
- 异常集
- Java基础之集合框架详解(一)
- Java代码 希尔排序
- java使用归并删除法删除二叉树中节点的方法
- mybatis与spring的整合(使用接口实现crud)
- Struts2框架提供的结果类型
- Java获得指定区间数的方法
- java-导出excel并解决乱码问题
- Java开发环境配置
- java 基础学习-04 线程学习案例
- java中的异常详解
- <tx:method/> 有关的设置
- Java套接字socket的使用
- 《Java虚拟机原理图解》 1.1、class文件基本组织结构