【Hbase代码笔记】Put

记录HBase 进行一个Put的过程。

1. Client端通过HTable发起Put操作

2. Htable的flushCommits方法使用服务端的连接 来处理提交。和Hadoop Cilent的提交是完全一样的思路

Htable在通过自身的writeBuffer缓存后,会刷新提交

3. Htable 通过HConnection(其实是TableServers类型) 类型的connection发起提交。在Hbase构造时候

4. TableServers类的processBatchOfRows

5,TableServers类中用callable的方式,调用HRegionInterface接口的put方法。

6 TableServers中的HRegionInterface字段server其实一个代理类

6. 请求被提交到服务端的HRegionServer,RegionServer先对应的Region提交数据

7. 在regione中,获取每一个Family,向每个family提交put

8. 请求被提交到服务端的HRegionServer,RegionServer先对应的Region提交数据

9.

10

 

@TODO? 只是把代码调用堆在这里,需要至少做到和之前整理Hadoop代码一样的品质。

Htable在通过自身的writeBuffer缓存后,会刷新提交

原创文章。为了维护文章的版本一致、最新、可追溯,转载请注明: 转载自idouba

本文链接地址: 【Hbase代码笔记】Put


, , ,

No comments yet.

发表评论