Scan整個表,遍歷各行資料，如何得到每行資料的列限定符、行鍵和單元值？

hbase中表followlist2 內容（hbase shell）

import java.io.IOException; import java.util.Iterator; import java.util.List; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.HBaseConfiguration; import org.apache.hadoop.hbase.HColumnDescriptor; import org.apache.hadoop.hbase.HTableDescriptor; import org.apache.hadoop.hbase.KeyValue; import org.apache.hadoop.hbase.MasterNotRunningException; import org.apache.hadoop.hbase.ZooKeeperConnectionException; import org.apache.hadoop.hbase.client.Get; import org.apache.hadoop.hbase.client.HBaseAdmin; import org.apache.hadoop.hbase.client.HTableInterface; import org.apache.hadoop.hbase.client.HTablePool; import org.apache.hadoop.hbase.client.Put; import org.apache.hadoop.hbase.client.Result; import org.apache.hadoop.hbase.client.ResultScanner; import org.apache.hadoop.hbase.client.Scan; import org.apache.hadoop.hbase.util.Bytes; @SuppressWarnings("deprecation") public class Follow2 { static Configuration cfg = HBaseConfiguration.create(); @SuppressWarnings({ "resource" }) public static void main(String[] args) throws MasterNotRunningException, ZooKeeperConnectionException, IOException{ String tb = "followlist2"; String cf = "follows"; byte[] bcf = Bytes.toBytes(cf); HBaseAdmin admin = new HBaseAdmin(cfg); HTablePool pool = new HTablePool(); //check Fake關注Real了沒 byte[] real = Bytes.toBytes("TheRealMT"); HTableInterface table=pool.getTable(tb); Get g = new Get(Bytes.toBytes("TheFakeMT")); g.addColumn(bcf, real); Result r = table.get(g); byte[] value = r.getValue(bcf, real); if(value!=null) System.out.println("Exist!"); else{ System.out.println("Don't exist!"); } Scan s = new Scan(); ResultScanner rs =table.getScanner(s); System.out.println("Scan Result: "); for(Result rr:rs){ List<keyvalue> list = rr.list(); for(KeyValue kv:list){ System.out.print("行鍵: "+Bytes.toString(kv.getRow()));//獲取行鍵 System.out.print("\t列族: "+Bytes.toString(kv.getFamily()));//獲取列族 System.out.print("\t列限定符: "+Bytes.toString(kv.getQualifier()));//獲取列限定符 System.out.println("\t單元值: "+Bytes.toInt(kv.getValue()));//獲取單元值 } System.out.println(); } table.close(); } }

執行結果：