zl程序教程

您现在的位置是:首页 >  数据库

当前栏目

hbase-1.2.1之scan、batch操作的源码学习详解编程语言

HBase源码学习编程语言 详解 操作 1.2 Batch
2023-06-13 09:20:40 时间

hbase-1.2.1之scan、batch操作的源码学习详解编程语言

Scan操作:

1、  实例化Configuration类

Configuration conf = HbaseConfiguration.create();

同Get操作。

2、  实例化HTable类

HTable hTable = new HTable(conf,tableName);

同Get操作。

3、  实例化Scan类

Scan scan = new Scan();

4、  添加列族和列

Scan.addColumn(Bytes.toBytes(“personal”),Bytes.toBytes(“name”));

Scan.addColumn(Bytes.toBytes(“personal”),Bytes.toBytes(“city”));

5、  得到Scan的结果集

ResultScanner scanner =table.getScanner(scan);

因为扫描操作不会通过一次RPC请求返回所有匹配的行,而是以行为单位进行返回。在每调用ResultScanner.next()的时候,都会生成一个单独的RPC请求。

源码:在HTable中的756行—776行,将在HTable的构造函数中创建的连接connection传给了scan。

6、  从ResultScanner中遍历result结果。

For(Result result = scanner.next();result!= null; result = Scanner.next());

7、  Scanner.close();

**************************************************************************************************************************************************************************

批量操作:batch:

在HTable类中的883行有batch(finalList ? Extends Row actions,final Object[] results)方法。

在该batch方法中,在第885行的multiAp.submitAll中,会走到AsyncProcess中:即

submitAll

groupAndSendMultiAction(actions,1);(560行)

— RegionLocationslocs = findAllLocationsOrFail(action,true);(868行)

— loc =connection.locateRegion(tableName…);(951行)。

即对actions列表中的每一个action,都会利用connection去定位对应的region的location。但是此处用到的connection为实例化HTable时创建的连接。

原创文章,作者:ItWorker,如若转载,请注明出处:https://blog.ytso.com/13739.html

c