通过Hbase的Java API接口插入一条数据
时间: 2023-12-08 10:03:28 浏览: 128
好的,下面是通过 HBase 的 Java API 接口插入一条数据的示例代码:
首先需要创建一个 HBase 的 Configuration 对象,并设置 HBase 的 ZooKeeper 地址:
```
Configuration config = HBaseConfiguration.create();
config.set("hbase.zookeeper.quorum", "zk1,zk2,zk3");
```
然后创建一个 HBase 的表连接对象:
```
Connection conn = ConnectionFactory.createConnection(config);
```
接下来获取表对象:
```
TableName tableName = TableName.valueOf("mytable");
Table table = conn.getTable(tableName);
```
然后创建一个 Put 对象,设置行键和列值:
```
Put put = new Put(Bytes.toBytes("row1"));
put.addColumn(Bytes.toBytes("cf"), Bytes.toBytes("col1"), Bytes.toBytes("value1"));
```
最后将 Put 对象插入到表中:
```
table.put(put);
```
完整的示例代码如下:
```
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Table;
import org.apache.hadoop.hbase.util.Bytes;
public class HBaseInsertExample {
public static void main(String[] args) throws Exception {
Configuration config = HBaseConfiguration.create();
config.set("hbase.zookeeper.quorum", "zk1,zk2,zk3");
Connection conn = ConnectionFactory.createConnection(config);
TableName tableName = TableName.valueOf("mytable");
Table table = conn.getTable(tableName);
Put put = new Put(Bytes.toBytes("row1"));
put.addColumn(Bytes.toBytes("cf"), Bytes.toBytes("col1"), Bytes.toBytes("value1"));
table.put(put);
table.close();
conn.close();
}
}
```
注意:需要将代码中的 zk1、zk2、zk3 替换为实际的 ZooKeeper 地址。
阅读全文