HBase Java API示例代码及常见解决方案和技术问答

本文介绍了HBase（分布式数据库）的Java API示例代码，包括创建表、插入数据、查询数据和删除表等操作。另外，还提供了一些常见的解决方案和技术问答，帮助读者更好地理解和应用HBase。

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;
import org.apache.hadoop.hbase.client.Delete;
import org.apache.hadoop.hbase.client.Get;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.Table;
import org.apache.hadoop.hbase.util.Bytes;

public class HBaseExample {
    public static void main(String[] args) throws Exception {
        // 配置HBase连接
        Configuration conf = HBaseConfiguration.create();
        conf.set("hbase.zookeeper.quorum", "localhost");
        conf.set("hbase.zookeeper.property.clientPort", "2181");
        Connection connection = ConnectionFactory.createConnection(conf);

        // 获取表对象
        Table table = connection.getTable(TableName.valueOf("mytable"));

        // 插入数据
        Put put = new Put(Bytes.toBytes("row1"));
        put.addColumn(Bytes.toBytes("mycf"), Bytes.toBytes("col1"), Bytes.toBytes("value1"));
        table.put(put);

        // 查询数据
        Get get = new Get(Bytes.toBytes("row1"));
        Result result = table.get(get);
        byte[] value = result.getValue(Bytes.toBytes("mycf"), Bytes.toBytes("col1"));
        System.out.println(Bytes.toString(value)); // 输出：value1

        // 删除表
        Delete delete = new Delete(Bytes.toBytes("row1"));
        table.delete(delete);

        // 关闭连接
        table.close();
        connection.close();
    }
}

免责申明：文章和图片全部来源于公开网络，如有侵权，请通知删除 server@dude6.com