hbase java怎样插入

在HBase中，使用Java API插入数据需要遵循以下步骤：

1. 添加HBase依赖

首先，确保你的项目中已经添加了HBase的Java依赖。如果你使用的是Maven，可以在pom.xml文件中添加以下依赖：

<dependency>
    <groupId>org.apache.hbase</groupId>
    <artifactId>hbase-client</artifactId>
    <version>2.4.9</version>
</dependency>

2. 创建HBase连接

要连接到HBase集群，需要创建一个Connection对象。你需要提供Zookeeper的地址和端口号。以下是一个示例：

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.Connection;
import org.apache.hadoop.hbase.ConnectionFactory;

Configuration config = HBaseConfiguration.create();
config.set("hbase.zookeeper.quorum", "localhost");
config.set("hbase.zookeeper.property.clientPort", "2181");

Connection connection = ConnectionFactory.createConnection(config);

3. 获取表

在插入数据之前，需要获取一个Table对象。假设我们要向名为my_table的表中插入数据，可以使用以下代码获取表：

import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.Table;

Table table = connection.getTable(TableName.valueOf("my_table"));

4. 插入数据

要插入数据，需要创建一个Put对象，并设置要插入的行键、列族、列限定符和值。然后，使用Table.put()方法将数据插入表中。以下是一个示例：

import org.apache.hadoop.hbase.Cell;
import org.apache.hadoop.hbase.Put;
import org.apache.hadoop.hbase.client.Table;

Put put = new Put("row1".getBytes());
put.addColumn("cf1".getBytes(), "column1".getBytes(), "value1".getBytes());
put.addColumn("cf2".getBytes(), "column2".getBytes(), "value2".getBytes());

table.put(put);

5. 关闭资源

在完成数据插入后，需要关闭Table和Connection对象以释放资源。以下是一个示例：

table.close();
connection.close();

将以上代码整合在一起，完整的示例如下：

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.Connection;
import org.apache.hadoop.hbase.ConnectionFactory;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Table;

public class HBaseInsertExample {
    public static void main(String[] args) throws Exception {
        Configuration config = HBaseConfiguration.create();
        config.set("hbase.zookeeper.quorum", "localhost");
        config.set("hbase.zookeeper.property.clientPort", "2181");

        Connection connection = ConnectionFactory.createConnection(config);
        Table table = connection.getTable(TableName.valueOf("my_table"));

        Put put = new Put("row1".getBytes());
        put.addColumn("cf1".getBytes(), "column1".getBytes(), "value1".getBytes());
        put.addColumn("cf2".getBytes(), "column2".getBytes(), "value2".getBytes());

        table.put(put);

        table.close();
        connection.close();
    }
}

这个示例将向名为my_table的表中插入一行数据，行键为row1，列族为cf1和cf2，列限定符和值分别为column1、value1、column2和value2。