MapReduce服务 MRS-使用Get读取HBase数据:代码样例

时间:2025-02-12 14:58:43

代码样例

以下代码片段在com.huawei.bigdata.hbase.examples包的“HBaseExample”类的testGet方法中。

样例代码获取方式请参考获取 MRS 应用开发样例工程

代码样例:

public void testGet() {     LOG .info("Entering testGet.");    // Specify the column family name.    byte[] familyName = Bytes.toBytes("info");    // Specify the column name.    byte[][] qualifier = {Bytes.toBytes("name"), Bytes.toBytes("address")};    // Specify RowKey.    byte[] rowKey = Bytes.toBytes("012005000201");    Table table = null;    try {        // Create the Configuration instance.        table = conn.getTable(tableName);        // Instantiate a Get object.        Get get = new Get(rowKey);        // Set the column family name and column name.        get.addColumn(familyName, qualifier[0]);        get.addColumn(familyName, qualifier[1]);        // Submit a get request.        Result result = table.get(get);        // Print query results.        for (Cell cell : result.rawCells()) {            LOG.info(Bytes.toString(CellUtil.cloneRow(cell)) + ":"                + Bytes.toString(CellUtil.cloneFamily(cell)) + ","                + Bytes.toString(CellUtil.cloneQualifier(cell)) + ","                + Bytes.toString(CellUtil.cloneValue(cell)));        }        LOG.info("Get data successfully.");    } catch (IOException e) {        LOG.error("Get data failed ", e);    } finally {        if (table != null) {            try {                // Close the HTable object.                table.close();            } catch (IOException e) {                LOG.error("Close table failed ", e);            }        }    }    LOG.info("Exiting testGet.");}
support.huaweicloud.com/devg-mrs/mrs_06_0023.html