扫二维码与项目经理沟通
我们在微信上24小时期待你的声音
解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流
小编给大家分享一下特殊的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。
请注意我标出来的部分,看起来很容易理解,分别是取列族、列、值。
可是事情的真相却不是这样的,看下面这个图:
好吧,我们再看一下源码:
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> maps = r.getNoVersionMap();for (byte[] fKey : maps.keySet()){ NavigableMap 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用法”这篇文章的所有内容,感谢各位的阅读!相信大家都有了一定的了解,希望分享的内容对大家有所帮助,如果还想学习更多知识,欢迎关注创新互联行业资讯频道!
我们在微信上24小时期待你的声音
解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流