java操作hbase框架

在Java中操作HBase可以使用HBase Java API或者使用第三方的HBase框架。下面介绍一下如何使用HBase Java API进行操作。

1. 创建HBase配置对象

Configuration conf = HBaseConfiguration.create();
conf.set("hbase.zookeeper.quorum", "localhost"); // 设置Zookeeper地址
conf.set("hbase.zookeeper.property.clientPort", "2181"); // 设置Zookeeper端口

2. 创建HBase连接对象

Connection conn = ConnectionFactory.createConnection(conf);

3. 获取表对象

TableName tableName = TableName.valueOf("mytable");
Table table = conn.getTable(tableName);

4. 插入数据

Put put = new Put(Bytes.toBytes("row1"));
put.addColumn(Bytes.toBytes("cf"), Bytes.toBytes("col1"), Bytes.toBytes("value1"));
table.put(put);

5. 查询数据

Get get = new Get(Bytes.toBytes("row1"));
Result result = table.get(get);
byte[] value = result.getValue(Bytes.toBytes("cf"), Bytes.toBytes("col1"));
System.out.println(Bytes.toString(value));

6. 删除数据

Delete delete = new Delete(Bytes.toBytes("row1"));
delete.addColumn(Bytes.toBytes("cf"), Bytes.toBytes("col1"));
table.delete(delete);

7. 关闭连接

table.close();
conn.close();

以上是基本的HBase操作，还有其他更复杂的操作可以参考HBase Java API文档。