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。