1. 程式人生 > >hbase的api操作之scan

hbase的api操作之scan

ann value art println col ase cache set 掃描器

掃描器緩存
----------------
面向行級別的。
@Test
public void getScanCache() throws IOException {

Configuration conf = HBaseConfiguration.create();
Connection conn = ConnectionFactory.createConnection(conf);
TableName tname = TableName.valueOf("ns1:t1");
Scan scan = new Scan();

scan.setCaching(5000);
Table t = conn.getTable(tname);
ResultScanner rs = t.getScanner(scan);
long start = System.currentTimeMillis() ;
Iterator<Result> it = rs.iterator();
while(it.hasNext()){
Result r = it.next();
System.out.println(r.getColumnLatestCell(Bytes.toBytes("f1"), Bytes.toBytes("name")));
}
System.out.println(System.currentTimeMillis() - start);
}
批量掃描是面向列級別
--------------------
控制每次next()服務器端返回的列的個數。
scan.setBatch(5); //每次next返回5列。

hbase的api操作之scan