您的位置:首页 > 其它

利用 HTable创建客户端,并向HBase插入数据

2017-05-31 16:39 357 查看

1,hbase文件结构图



2,创建客户端的方法二:

利用HTable,可进行增删改查操作。

/**
* 利用 HTable创建客户端,并向HBase插入数据
* Created by zhaojy on 2017/5/17.
*/
public class HBaseTest {

private final static String HB_ZK_QUORUM="10.8.177.27,10.8.177.28,10.8.177.29";
private final static String HB_ZK_PORT="2181";

public static void main(String args[])throws Exception{
//创建配置
Configuration conf = HBaseConfiguration.create();
//设置zk地址和端口号
conf.set("hbase.zookeeper.property.clientPort", HB_ZK_PORT);
conf.set("hbase.zookeeper.quorum",HB_ZK_QUORUM);
//实例化一个新的配置
HTable table = new HTable(conf,"testTable");
// 指定一行创建put
Put put = new Put(Bytes.toBytes("row1"));
//像Put中添加名为 colfam1:qul1 的列
put.addColumn(Bytes.toBytes("colfam1"),Bytes.toBytes("qual1"),Bytes.toBytes("val1"));
put.addColumn(Bytes.toBytes("colfam1"),Bytes.toBytes("qual2"),Bytes.toBytes("val2"));
put.addColumn(Bytes.toBytes("colfam1"),Bytes.toBytes("qual3"),Bytes.toBytes("val3"));
//将这一行存储到HBase表中。
table.put(put);
}
}
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签:  hbase
相关文章推荐