[發明專利]并發查詢HBase表的方法和裝置

在審

• 申請號: 201410483073.0
• 申請日: 2014-09-19
• 公開（公告）號: CN104239530A
• 公開（公告）日: 2014-12-24
• 發明（設計）人: 劉璧怡;郭美思;吳楠
• 申請（專利權）人: 浪潮（北京）電子信息產業有限公司
• 主分類號: G06F17/30
• 分類號: G06F17/30
• 代理公司: 北京安信方達知識產權代理有限公司 11262
• 代理人: 王丹;李丹

1.一種并發查詢HBase表的方法，其特征在于，包括：

設置查詢HBase服務端程序；

設置并發查詢程序；

采用并發查詢程序調用查詢HBase服務端程序，并發查詢HBase表。

2.根據權利要求1所述的并發查詢HBase表的方法，其特征在于，所述設置查詢HBase服務端程序，包括：

實例化HTablePool對象，根據實例化的HTablePool對象獲取HTable實例；

根據Hbase客戶端的需求，在獲取的HTable實例中設置查詢屬性；

設置通過getScanner查詢HBase表中的記錄。

3.根據權利要求2所述的并發查詢HBase表的方法，其特征在于，在所述實例化HTablePool對象，根據實例化的HTablePool對象獲取HTable實例之前，還包括：

構建HTablePool對象池，HTablePool維護固定數量的HTable實例，通過HTablePoo的PoolMap存放HTable實例。

4.根據權利要求2或3所述的并發查詢HBase表的方法，其特征在于，所述根據Hbase客戶端的需求，在獲取的HTable實例中設置查詢屬性，包括：

根據Hbase客戶端的需求，在獲取的HTable實例中設置開始Key及截止Key。

5.根據權利要求4所述的并發查詢HBase表的方法，其特征在于，所述根據Hbase客戶端的需求，在獲取的HTable實例中設置查詢屬性，還包括：

根據Hbase客戶端的需求，設置HTable實例中的Caching參數、Batch參數和CacheBlocks參數。

6.根據權利要求5所述的并發查詢HBase表的方法，其特征在于，所述設置通過getScanner查詢HBase表中的記錄之后，還包括：

如果通過getScanner查詢的查詢結果與Hbase客戶端的需求有差別，則根據通過RowKey及value值設置Hbase客戶端需求的查詢輸出格式。

7.根據權利要求1所述的并發查詢HBase表的方法，其特征在于，所述設置并發查詢程序，包括：

通過java?concurrent中的時間閘設置并發查詢程序。

8.根據權利要求1所述的并發查詢HBase表的方法，其特征在于，所述采用并發查詢程序調用查詢HBase服務端程序，并發查詢HBase表，包括：

并發查詢程序調用查詢HBase服務端程序，將并發訪問任務分發到集群中的節點中，每個節點并發執行對HBase表的查詢。

9.根據權利要求1所述的并發查詢HBase表的方法，其特征在于，還包括：

通過查詢日志，對并發查詢的結果狀態進行記錄，其中，通過error、failed、success狀態進行記錄，error表示查詢出錯，failed表示查詢失敗，success表示查詢成功；

當并發查詢中所有的查詢都是success狀態時，并發查詢HBase表成功，在查詢成功時，記錄并發查詢HBase表的平均時間。

10.一種并發查詢HBase表的裝置，其特征在于，包括：

第一設置單元，用于設置查詢HBase服務端程序；

第二設置單元，用于設置并發查詢程序；

調用單元，用于采用并發查詢程序調用查詢HBase服務端程序，并發查詢HBase表。

11.根據權利要求10所述的并發查詢HBase表的裝置，其特征在于，還包括：

記錄單元，用于通過查詢日志，對并發查詢的結果狀態進行記錄，并在查詢成功時，記錄并發查詢HBase表的平均時間。