Hadoop+Spark大数据技术 第四次作业 第四章 HBase分布式DB

在Hadoop生态系统中，HBase是一个分布式的、面向列的开源数据库，用于存储非结构化和半结构化的松散数据。以下是一个使用HBase API的基本示例，展示了如何在Java环境中进行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.Get;
import org.apache.hadoop.hbase.client.Delete;
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", "your_zookeeper_quorum");
        config.set("hbase.zookeeper.property.clientPort", "your_client_port");
 
        // 建立连接
        try (Connection connection = ConnectionFactory.createConnection(config);
             Table table = connection.getTable(TableName.valueOf("your_table_name"))) {
 
            // 插入数据
            Put put = new Put(Bytes.toBytes("row1"));
            put.addColumn(Bytes.toBytes("family1"), Bytes.toBytes("qualifier1"), Bytes.toBytes("value1"));
            table.put(put);
 
            // 获取数据
            Get get = new Get(Bytes.toBytes("row1"));
            byte[] value = table.get(get).getValue(Bytes.toBytes("family1"), Bytes.toBytes("qualifier1"));
            System.out.println("获取到的数据: " + Bytes.toString(value));
 
            // 删除数据
            Delete delete = new Delete(Bytes.toBytes("row1"));
            delete.addColumn(Bytes.toBytes("family1"), Bytes.toBytes("qualifier1"));
            table.delete(delete);
        }
    }
}

在这个例子中，我们首先配置了HBase的连接，然后通过Connection和Table对象进行数据的增删改查操作。需要注意的是，你需要替换your_zookeeper_quorum和your_client_port为你的HBase集群的Zookeeper Quorum和端口号，以及your_table_name为你要操作的表名。

这个代码片段展示了如何在Java中使用HBase客户端API进行基本的数据操作。在实际应用中，你可能需要处理更复杂的逻辑，例如异常处理、批量操作、多线程访问等。