HBase分布式列式数据库原理与代码实例讲解

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;
 
import java.io.IOException;
 
public class HBaseExample {
    public static void main(String[] args) throws IOException {
        // 配置HBase
        Configuration config = HBaseConfiguration.create();
        config.set("hbase.zookeeper.quorum", "zookeeper节点");
        config.set("hbase.zookeeper.property.clientPort", "2181");
 
        // 建立连接
        try (Connection connection = ConnectionFactory.createConnection(config);
             // 指定表名
             Table table = connection.getTable(TableName.valueOf("表名"))) {
 
            // 创建一个Put对象，指定要插入的行
            Put put = new Put(Bytes.toBytes("行键"));
            // 添加列（列族:列限定符，值）
            put.addColumn(Bytes.toBytes("列族"), Bytes.toBytes("列限定符"), Bytes.toBytes("值"));
 
            // 执行插入操作
            table.put(put);
        }
        System.out.println("数据已插入到HBase表中");
    }
}

这段代码展示了如何使用Java客户端连接HBase，并向指定的表中插入一条记录。需要注意的是，代码中的"zookeeper节点"和"表名"需要替换成实际的Zookeeper集群地址和目标HBase表名。