91超碰碰碰碰久久久久久综合_超碰av人澡人澡人澡人澡人掠_国产黄大片在线观看画质优化_txt小说免费全本

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

特殊的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

广西| 嘉兴市| 襄汾县| 平江县| 楚雄市| 中阳县| 沙坪坝区| 邵阳市| 上蔡县| 阳城县| 新津县| 隆尧县| 麦盖提县| 安义县| 和政县| 会宁县| 罗田县| 凌海市| 民乐县| 兖州市| 介休市| 中卫市| 南郑县| 富民县| 田林县| 孝义市| 罗源县| 天峻县| 讷河市| 广元市| 方山县| 鄂伦春自治旗| 浮梁县| 肇东市| 昌邑市| 隆林| 隆子县| 德保县| 河北省| 阿勒泰市| 柘城县|