温馨提示×

温馨提示×

您好,登录后才能下订单哦!

密码登录×
登录注册×
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》

特殊的HBase API用法

发布时间:2021-12-08 14:30:43 来源:亿速云 阅读:140 作者:小新 栏目:云计算

小编给大家分享一下特殊的HBase API用法,相信大部分人都还不怎么了解,因此分享这篇文章给大家参考一下,希望大家阅读完这篇文章后大有收获,下面让我们一起去了解一下吧!

直接上代码:

Connection conn = ConnectionFactory.createConnection(conf);
TableName tn = TableName.valueOf(strTN);
Table table = conn.getTable(tn);
RowFilter logFileTableFilter = new RowFilter(CompareFilter.CompareOp.EQUAL, new SubstringComparator("0UAV0020109000574633450"));
Scan s = new Scan();
s.setFilter(logFileTableFilter);
ResultScanner ss = table.getScanner(s);for (Result r : ss) {for (Cell cell : r.listCells()) {
        KeyValue kv = (KeyValue) cell;
        System.out.print(new String(Arrays.copyOfRange(kv.getFamilyArray(), kv.getFamilyOffset(), kv.getFamilyOffset() + kv.getFamilyLength())) + " ");
        System.out.print(new String(Arrays.copyOfRange(kv.getQualifierArray(), kv.getQualifierOffset(), kv.getQualifierOffset() + kv.getQualifierLength())) + " ");
        System.out.println(new String(Arrays.copyOfRange(kv.getValueArray(), kv.getValueOffset(), kv.getValueOffset() + kv.getValueLength())) + " ");
    }
}

前面部分都很正常,2层循环,第一层是循环result,简单理解就是循环row,第二层循环每一个field。

请注意我标出来的部分,看起来很容易理解,分别是取列族、列、值。

可是事情的真相却不是这样的,看下面这个图:

特殊的HBase API用法

好吧,我们再看一下源码:

public byte[] getFamilyArray() {return this.bytes;
}
public byte[] getQualifierArray() {return this.bytes;
}
public byte[] getValueArray() {return this.bytes;
}

这tmd不是一样的东西嘛?

好吧,奇葩就奇葩吧,关键是不好用,大概意思就是给你一个byte数组,关于这个field的所有数据都在这个数组里面,然后告诉你列族、列、值等等各种东西的offset和length,让你自己去把东西抠出来。每次取值要是都得这么做,那不得疯掉~~~

Arrays.copyOfRange(kv.getValueArray(), kv.getValueOffset(), kv.getValueOffset() + kv.getValueLength())

看看下面这段代码,还是有正常点的api的,这才符合人类习惯嘛~~~~~~

for (Result r : ss) {
    NavigableMap<byte[], NavigableMap<byte[], byte[]>> maps = r.getNoVersionMap();for (byte[] fKey : maps.keySet()){
        NavigableMap<byte[], byte[]> map = maps.get(fKey);for (byte[] key : map.keySet()){
            System.out.print(new String(fKey) + ":");
            System.out.print(new String(key) + " ");
            System.out.println(new String(map.get(key)));
        }
    }
}

以上是“特殊的HBase API用法”这篇文章的所有内容,感谢各位的阅读!相信大家都有了一定的了解,希望分享的内容对大家有所帮助,如果还想学习更多知识,欢迎关注亿速云行业资讯频道!

向AI问一下细节

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

AI