文档首页 > > 开发指南> HBase应用开发> 开发程序> 读MOB数据

读MOB数据

分享
更新时间: 2019/12/11 GMT+08:00

功能简介

HBase MOB数据读出与普通HBase数据的读出没有什么区别,对客户来说是透明的。为了使用HBase MOB功能需要在“hbase-site.xml”中添加HBase MOB相关的配置项,具体请参阅https://hbase.apache.org/book.html#hbase_mob,除此之外还需要在指定column family上开启MOB功能。

代码样例

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

public void testMOBDataRead() {
    LOG.info("Entering testMOBDataRead.");
    ResultScanner scanner = null;
    Table table = null;
    Admin admin = null;
    try {

        // get table object representing table tableName
        table = conn.getTable(tableName);
        admin = conn.getAdmin();
        admin.flush(table.getName());
        Scan scan = new Scan();
        // get table scanner
        scanner = table.getScanner(scan);
        for (Result result : scanner) {
            byte[] value = result.getValue(Bytes.toBytes("mobcf"), Bytes.toBytes("cf1"));
            String string = Bytes.toString(value);
            LOG.info("value:" + string);
        }
        LOG.info("MOB data read successfully.");
    } catch (Exception e) {
        LOG.error("MOB data read failed ", e);
    } finally {
        if (scanner != null) {
            scanner.close();
        }
        if (table != null) {
            try {
                // Close table object
                table.close();
            } catch (IOException e) {
                LOG.error("Close table failed ", e);
            }
        }
        if (admin != null) {
            try {
                // Close the Admin object.
                admin.close();
            } catch (IOException e) {
                LOG.error("Close admin failed ", e);
            }
        }
    }
    LOG.info("Exiting testMOBDataRead.");
}
分享:

    相关文档

    相关产品

文档是否有解决您的问题?

提交成功!

非常感谢您的反馈,我们会继续努力做到更好!

反馈提交失败,请稍后再试!

*必选

请至少选择或填写一项反馈信息

字符长度不能超过200

提交反馈 取消

如您有其它疑问,您也可以通过华为云社区问答频道来与我们联系探讨

跳转到云社区