小編給大家分享一下特殊的HBase API用法，相信大部分人都還不怎么了解，因此分享這篇文章給大家參考一下，希望大家閱讀完這篇文章后大有收獲，下面讓我們一起去了解一下吧！

創(chuàng)新互聯(lián)是一家集網(wǎng)站建設(shè),蓋州企業(yè)網(wǎng)站建設(shè),蓋州品牌網(wǎng)站建設(shè),網(wǎng)站定制,蓋州網(wǎng)站建設(shè)報價,網(wǎng)絡(luò)營銷,網(wǎng)絡(luò)優(yōu)化,蓋州網(wǎng)站推廣為一體的創(chuàng)新建站企業(yè)，幫助傳統(tǒng)企業(yè)提升企業(yè)形象加強企業(yè)競爭力?？沙浞譂M足這一群體相比中小企業(yè)更為豐富、高端、多元的互聯(lián)網(wǎng)需求。同時我們時刻保持專業(yè)、時尚、前沿，時刻以成就客戶成長自我，堅持不斷學(xué)習(xí)、思考、沉淀、凈化自己，讓我們?yōu)楦嗟钠髽I(yè)打造出實用型網(wǎng)站。

直接上代碼：

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層循環(huán)，第一層是循環(huán)result，簡單理解就是循環(huán)row，第二層循環(huán)每一個field。

請注意我標(biāo)出來的部分，看起來很容易理解，分別是取列族、列、值。

可是事情的真相卻不是這樣的，看下面這個圖：

好吧，我們再看一下源碼：

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

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

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

這tmd不是一樣的東西嘛？

好吧，奇葩就奇葩吧，關(guān)鍵是不好用，大概意思就是給你一個byte數(shù)組，關(guān)于這個field的所有數(shù)據(jù)都在這個數(shù)組里面，然后告訴你列族、列、值等等各種東西的offset和length，讓你自己去把東西摳出來。每次取值要是都得這么做，那不得瘋掉~~~

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

看看下面這段代碼，還是有正常點的api的，這才符合人類習(xí)慣嘛~~~~~~

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用法”這篇文章的所有內(nèi)容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內(nèi)容對大家有所幫助，如果還想學(xué)習(xí)更多知識，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道！