Hbase Cellutil源码

CellUtil是个管理Cell的工具类.主要是一些静态方法.

cloneRow可用于获取rowkey.
返回值为byte数组,所以打印时需要转为String.

 public static byte[] cloneRow(Cell cell){byte[] output = new byte[cell.getRowLength()];copyRowTo(cell, output, 0);return output;}

调用了 copyRowTo方法,cell.getRowArray()就是获取的某个rowkey那整行的最原始的byte信息了.

 public static int copyRowTo(Cell cell, byte[] destination, int destinationOffset) {System.arraycopy(cell.getRowArray(), cell.getRowOffset(), destination, destinationOffset,cell.getRowLength());return destinationOffset + cell.getRowLength();}

比如

 System.out.println(new String(cell.getRowArray()));

结果如下.需要从中提取rowkey的信息.

那么getrowarray又是如何定义的呢?继续追根溯源

 /*** @return the backing array of the entire KeyValue (all KeyValue fields are in a single array)*/@Overridepublic byte[] getRowArray() {return bytes;}

bytes是一个KeyValue类的属性

 // KeyValue core instance fields.protected byte [] bytes = null;  // an immutable byte array that contains the KVprotected int offset = 0;  // offset into bytes buffer KV starts atprotected int length = 0;  // length of the KV starting from offset.

Hbase Cellutil源码相关推荐

Hbase Compaction 源码分析 - CompactSplitThread 线程池选择
目录 CompactSplitThread requestCompactionInternal方法 selectCompaction方法 requestCompaction方法其他相关文章 Hbas ...
Hbase Compaction 源码分析 - RatioBasedCompactionPolicy 策略
目录类的关系图 RatioBasedCompactionPolicy selectCompaction 方法 getCurrentEligibleFiles方法 skipLargeFiles方法 ...
Hbase Compaction 源码分析 - CompactionChecker
其他相关文章 Hbase Compaction 源码分析 - CompactionChecker Hbase Compaction 源码分析 - RatioBasedCompactionPolicy ...
hbase RPCServer源码分析
前置知识: java,nio,多线程看了几天的源码,写一些自己心得,若有错误请指出. RPCServer的作用:负责创建listener,reader,responser,handler来处理cli ...
HBase Replication源码解析之HLog读取
2019独角兽企业重金招聘Python工程师标准>>> 在HRegionServer中两个量和replication相关,如下所示: [java] view plain copy / ...
hadoop源码_HBASE源码导入IDEA并开启DEBUG调试
前言:为了更深入的理解HBase的源码,对源码进行跟踪调试是一个很好的方法.本文详细记录了把社区版的HBase1.2.0源码导入idea中,进行编译调试的过程,以及在整个操作流程中遇到的一些坑. 一. ...
HBase源码分析之HRegion上compact流程分析（三）
在<HBase源码分析之HRegion上compact流程分析(二)>一文中,我们没有讲解真正执行合并的CompactionContext的compact()方法.现在我们来分析下它的具体 ...
hbase源码系列（十二）Get、Scan在服务端是如何处理？
继上一篇讲了Put和Delete之后,这一篇我们讲Get和Scan, 因为我发现这两个操作几乎是一样的过程,就像之前的Put和Delete一样,上一篇我本来只打算写Put的,结果发现Delete也可以 ...
《MapReduce 2.0源码分析与编程实战》一第1章 HBase介绍
本节书摘来异步社区<MapReduce 2.0源码分析与编程实战>一书中的第1章,作者: 王晓华责编: 陈冀康,更多章节内容可以访问云栖社区"异步社区"公众号查看. ...

Hbase Cellutil源码

Hbase Cellutil源码相关推荐

最新文章

热门文章