一、介紹

Put、Delete與Get物件都是Row的子類，從該繼承關係中我們就可以瞭解到Get、Delete與Pu物件本身就只能進行單行的操作，HBase客戶端還提供了一套能夠進行全表掃描的API，方便使用者能夠快速對整張表進行掃描，以獲取想要的結果---scan

二、流程介紹

全表掃描是一種不需要行鍵值的操作，因此初始化時不需要指定行鍵值，因此就產生了不同的使用方法

1、不進行Scan物件建立的全表掃描

在該過程中，Htable物件會在掃描請求傳送前隱式的建立一個scan物件，然後傳遞給Hbase伺服器叢集。

public void scanWithoutInit(String tableName,String family)
	{
		Configuration conf=init();
		try {
			HBaseAdmin admin=new HBaseAdmin(conf);
			if(!admin.tableExists(tableName))
			{
				System.err.println("the table "+tableName+" is not exist");
				admin.close();
				System.exit(1);
			}
			//建立表連線
			HTable table=new HTable(conf, tableName);
			//獲取全表掃描
			ResultScanner resultScanner=table.getScanner(Bytes.toBytes(family));
			//對結果進行顯示
			Iterator<Result> results=resultScanner.iterator();
			while(results.hasNext())
			{
				Result result=results.next();
				for(KeyValue kv:result.raw())
				{
					System.out.println(Bytes.toString(kv.getRow()));
					System.out.println(Bytes.toString(kv.getFamily()));
					System.out.println(Bytes.toString(kv.getQualifier()));
					System.out.println(Bytes.toString(kv.getValue()));
				}
			}
		} catch (Exception e) {
			// TODO: handle exception
			e.printStackTrace();
		}
	}
 

getScanner()方法時，如果不輸入指定的scan物件，則需要輸入相應的列簇或者列。因此在不進行scan物件建立的掃描中，需要明確指出列簇或者列，如果需要掃描多個列簇時，該方法就無法起到作用了。

2、進行初始化的全表掃描

初始化一個scan物件，然後對該物件進行相應的配置過，通過 getScanner(Scan scan) 函式進行全表掃描。

public void scanWithInit(String tableName)
	{
		Configuration conf=init();
		try {
			HBaseAdmin admin=new HBaseAdmin(conf);
			if(!admin.tableExists(tableName))
			{
				System.err.println("the table "+tableName+" is not exist");
				admin.close();
				System.exit(1);
			}
			//建立掃描類
			Scan scan=new Scan();
			scan.setStartRow(Bytes.toBytes("row-1"));
			scan.setStopRow(Bytes.toBytes("row-9"));
			//建立表連線
			HTable table=new HTable(conf, tableName);
			ResultScanner rs=table.getScanner(scan);
			Result result;
			while((result=rs.next())!=null)
			{
				KeyValue[] kvs=result.raw();
				for(KeyValue kv:kvs)
				{
					System.out.println(Bytes.toString(kv.getRow()));
					System.out.println(Bytes.toString(kv.getFamily()));
					System.out.println(Bytes.toString(kv.getQualifier()));
					System.out.println(Bytes.toString(kv.getValue()));
				}
			}
			rs.close();
			table.close();
		} catch (Exception e) {
			// TODO: handle exception
			e.printStackTrace();
		}
	}
 

3、資料遍歷與顯示ScannerResult

通過上述兩種方法可以傳送對一張表是遍歷請求，當傳送後，伺服器會相應的啟動全表掃面程式，從而準備向客戶端返回相應的資料。因此根據客戶端的遍歷需要對資料盡心請求，然後將請求的結果進行返回，客戶端拿到後進行展示

（1）next()的單行返回資料的方法

ResultScanner rs=table.getScanner(Bytes.toBytes(family));
//進項單行獲取演示
Result result=null;
while((result=rs.next())!=null)
{
	KeyValue[] kvs=result.raw();
	for(KeyValue kv:kvs)
	{
		System.out.println(Bytes.toString(kv.getRow()));
		System.out.println(Bytes.toString(kv.getFamily()));
		System.out.println(Bytes.toString(kv.getQualifier()));
		System.out.println(Bytes.toString(kv.getValue()));
	}
}
rs.close();
 

next()方法會預設想客戶端請求傳送一行資料請求，剛伺服器端的scan程式接收到請求後會將經需要返回的資料封裝成一個result物件返回給客戶端，因此客戶端可以通過result物件去接受該行資料。接收到的資料則跟Get中的result使用方法是相同的。

（2）next(int n)的多行返回資料的方法

next(int n)：該函式會向伺服器傳送多個請求，以返回多條資料請求。

//一次獲取多個結果（行資料）進行展示
			rs=table.getScanner(Bytes.toBytes(family));
			Result[] results=null;
			while((results=rs.next(2))!=null)
			{
				for(Result r:results)
				{
					KeyValue[] kvs=r.raw();
					for(KeyValue kv:kvs)
					{
						System.out.println(Bytes.toString(kv.getRow()));
						System.out.println(Bytes.toString(kv.getFamily()));
						System.out.println(Bytes.toString(kv.getQualifier()));
						System.out.println(Bytes.toString(kv.getValue()));
					}
				}
			}
			rs.close();

（3）迭代器遍歷

//進行迭代的方式進行輸出
			rs=table.getScanner(Bytes.toBytes(family));
			Iterator<Result> resultIterator=rs.iterator();
			while(resultIterator.hasNext())
			{
				result=resultIterator.next();
				KeyValue[] kvs=result.raw();
				for(KeyValue kv:kvs)
				{
					System.out.println(Bytes.toString(kv.getRow()));
					System.out.println(Bytes.toString(kv.getFamily()));
					System.out.println(Bytes.toString(kv.getQualifier()));
					System.out.println(Bytes.toString(kv.getValue()));
				}
			}
			//關閉表
			rs.close();

因為當用戶傳送一個scan全表掃描後，region伺服器會為全表掃描建立掃描資源，因此長時間啟用全表掃描的話會佔用region伺服器的大量資源，所以在要求在使用完scanner掃描器後儘快釋放掉資源。

rs.close() 會告知服務其掃描器租約已經結束，伺服器就會釋相應的全域性掃描的資源。

三、Scan物件

（1）setStartRow() / setStopRow

設定掃描的開始行與結束行，通過這兩個可以直接確scan在掃描的範圍，通過縮小範圍可以減少掃描到時間，從而提高掃描的效率

（2）addFamily() / addColumn()

通過這兩個函式，可以在列或者列簇上的掃描位置。HBase是面向lie出書的資料庫，而同一個列簇的資料全部存放在同一個位置檔案中。因此如果可以確定掃描那個一列簇時，可以減少掃描的範圍，從而縮短掃描的時間。而在確定到某一個列時也會因為HBase的面向列儲存使得其效率提高。

（3）setMaxVersion() / setMaxVersion(int version)

設定返回的版本數量，預設為返回最新的資料。第一個函式則會返回所有的版本資料，第二個函式可以設定返回的版本數量

（4）setTimeStamp(long max)

返回該時間戳的資料

（5）setTimeRange(long min,long max)

設定返回的時間戳的範圍，只有版本值在該範圍之內的資料才會被返回到客戶端

（6）setFilter(Filter f)

設定過濾器，有時候掃描全表返回的數量過大時，可以通過過濾器將不符合的資料進行過濾，這樣可以減少從伺服器到客戶端的資料傳送，挺高掃描效率。

（7）setCacheBlocks(boole open)

在進行全表掃描過程中，伺服器端提供了一個快取區，該快取區可以將指定的資料量全部放入到記憶體中，這樣可以提高讀取效率。快取區的開啟也可以通過htable客戶端進行開啟。在開發後用戶可以通過 setCache(int n)的方式設定每次快取的數量為多少。通過調整該函式以提高讀取的效率。

四、總結

scan的全表掃描區別於其他三個操作，雖然獲取資料與Get獲取的資料是相同的，其與Get也具有形似的屬性，可以通過修改這些屬性去對資料獲取進行調優，從而使得提高資料獲取的效率。