hbase之scan的rowkey问题

素颜马尾好姑娘i 2022-01-16 14:53 339阅读 0赞

最近使用到hbase做存储，发现使用scan的时候，返回的rowkey并不是特别友好

例如我insert的rowkey是 xyz\_123\_abc

调用KeyValue的getKeyString方法返回的String为

Java代码 [ ![复制代码][icon_copy.gif]][_icon_copy.gif]  ![收藏代码][icon_star.png]![spinner.gif][]

1.  kv\\x00\\x0Bxyz\_123\_abc\\x02kvobj\\x00\\x00\\x011\\xD7\\xB9\\xDD\\x1B\\x04

kv\x00\x0Bxyz_123_abc\x02kvobj\x00\x00\x011\xD7\xB9\xDD\x1B\x04

可以看到我的rowkey已经被处理过了，不过这个处理只是拼接处理，没有其他译码的过程。

好吧，这下需要考虑如何提取出我的真实的rowkey了，看了下KeyValue中，生成key的算法太繁琐了，直接跳过，debug看下rowkey的返回过程，发现KeyValue对象本身其实是正常的，也就是说KeyValue的toString方法其实有正常的rowkey，ok找到入口点了，直接看toString的方法

Java代码 [ ![复制代码][icon_copy.gif]][_icon_copy.gif]  ![收藏代码][icon_star.png]![spinner.gif][]

1.  public String toString() \{   
2.      if (this.bytes == null || this.bytes.length == 0) \{   
3.        return "empty";   
4.      \}   
5.      return keyToString(this.bytes, this.offset + ROW\_OFFSET, getKeyLength()) +   
6.        "/vlen=" + getValueLength();   
7.    \}

public String toString() {
        if (this.bytes == null || this.bytes.length == 0) {
          return "empty";
        }
        return keyToString(this.bytes, this.offset + ROW_OFFSET, getKeyLength()) +
          "/vlen=" + getValueLength();
      }

接着看keyToString方法，摘取最前面重要的2段

Java代码 [ ![复制代码][icon_copy.gif]][_icon_copy.gif]  ![收藏代码][icon_star.png]![spinner.gif][]

1.  public static String keyToString(final byte \[\] b, final int o, final int l) \{   
2.     if (b == null) return "";   
3.     int rowlength = Bytes.toShort(b, o);   
4.     String row = Bytes.toStringBinary(b, o + Bytes.SIZEOF\_SHORT, rowlength);

public static String keyToString(final byte [] b, final int o, final int l) {
        if (b == null) return "";
        int rowlength = Bytes.toShort(b, o);
        String row = Bytes.toStringBinary(b, o + Bytes.SIZEOF_SHORT, rowlength);

这次终于找到了他的构成方法了，ok 对照KeyValue的API 可以写个util方法来获取真实的rowkey字符串了

Java代码 [ ![复制代码][icon_copy.gif]][_icon_copy.gif]  ![收藏代码][icon_star.png]![spinner.gif][]

1.  public static String getRealRowKey(KeyValue kv) \{   
2.          int rowlength = Bytes.toShort(kv.getBuffer(), kv.getOffset()+KeyValue.ROW\_OFFSET);   
3.          String rowKey = Bytes.toStringBinary(kv.getBuffer(), kv.getOffset()+KeyValue.ROW\_OFFSET + Bytes.SIZEOF\_SHORT, rowlength);   
4.          return rowKey;   
5.      \}

public static String getRealRowKey(KeyValue kv) {
    		int rowlength = Bytes.toShort(kv.getBuffer(), kv.getOffset()+KeyValue.ROW_OFFSET);
    		String rowKey = Bytes.toStringBinary(kv.getBuffer(), kv.getOffset()+KeyValue.ROW_OFFSET + Bytes.SIZEOF_SHORT, rowlength);
    	    return rowKey;
    	}

[icon_copy.gif]: http://dikar.iteye.com/images/icon_copy.gif
[_icon_copy.gif]: http://dikar.iteye.com/blog/1151774#
[icon_star.png]: http://dikar.iteye.com/images/icon_star.png
[spinner.gif]: /images/20220114/db5f30cfeaea4681847201e13fb1c2e1.png