最新educoder平台HBase开发：表的扫描与扫描的缓存和批量处理.docx

《最新educoder平台HBase开发：表的扫描与扫描的缓存和批量处理.docx》由会员上传分享，免费在线阅读，更多相关内容在教育资源-天天文库。

1、精品资料educoder平台HBase开发：表的扫描与扫描的缓存和批量处理........................................精品资料第1关：批量处理packagestep1;importjava.util.ArrayList;importjava.util.List;importorg.apache.hadoop.conf.Configuration;importorg.apache.hadoop.hbase.Cell;importorg.apache.hadoop.hbase.CellUtil;im

2、portorg.apache.hadoop.hbase.HBaseConfiguration;importorg.apache.hadoop.hbase.TableName;importorg.apache.hadoop.hbase.client.*;importorg.apache.hadoop.hbase.client.coprocessor.Batch;importorg.apache.hadoop.hbase.util.Bytes;publicclassTask{publicObject[]batchOp(Stringta

3、blename)throwsException{/*********Begin*********/Configurationconf=HBaseConfiguration.create();........................................精品资料Connectionconn=ConnectionFactory.createConnection(conf);Tabletable=conn.getTable(TableName.valueOf(tablename));Listrows=newA

4、rrayList<>();//删除操作Deletedelete=newDelete(Bytes.toBytes("row1"));Deletedelete2=newDelete(Bytes.toBytes("row2"));rows.add(delete);rows.add(delete2);//获取操作Getget=newGet(Bytes.toBytes("row3"));Getget2=newGet(Bytes.toBytes("row10"));rows.add(get);rows.add(get2);//定义结果数组长度

5、Object[]results=newObject[rows.size()];........................................精品资料table.batch(rows,results);//这是一个同步的操作，批量操作的结果将会在操作之后放在results中//delete和put操作的结果为NONE即没有结果returnresults;/*********End*********/}}命令行：启动下Hadoop和hbase第2关：扫描表中所有的数据packagestep2;importorg.ap

6、ache.hadoop.conf.Configuration;importorg.apache.hadoop.hbase.Cell;importorg.apache.hadoop.hbase.CellUtil;importorg.apache.hadoop.hbase.HBaseConfiguration;importorg.apache.hadoop.hbase.TableName;importorg.apache.hadoop.hbase.client.*;publicclassTask{publicvoidscanTable

7、(Stringtablename)throwsException{........................................精品资料/*********Begin*********/Configurationconf=HBaseConfiguration.create();Connectionconn=ConnectionFactory.createConnection(conf);Tabletable=conn.getTable(TableName.valueOf(tablename));Scanscan=

8、newScan();ResultScannerscanner=table.getScanner(scan);for(Resultresult:scanner){for(Cellcell:result.listCells()){System.out.