赞
踩
HBase提供了一个Java的客户端库,通过JavaAPi可以更方便的操作Hbase表。
1、创建Hbase连接池
- private Configuration myConfig;
- private HConnection hconn;
- private String userName = "users";
-
- @Before
- public void before() throws Exception {
- myConfig = HBaseConfiguration.create();
- myConfig.set("hbase.zookeeper.quorum", "10.10.2.66");
- hconn = HConnectionManager.createConnection(myConfig);
- }
HBase表的行有一个唯一标识符,叫行键(rowKey)。其他部分用来存储Hbase表里的数据,但行键是第一重要的
- @Test
- public void insert() throws Exception {
- HTableInterface usersTable = hconn.getTable(userName);
- Put p = new Put(Bytes.toBytes("TheRealMT"));
- p.add(Bytes.toBytes("info"), Bytes.toBytes("name"), Bytes.toBytes("Mark Twain"));
- p.add(Bytes.toBytes("info"), Bytes.toBytes("email"),
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。