[發(fā)明專利]HBase二級索引表的查詢方法和裝置

有效

• 申請?zhí)枺?/td>: 201410483879.X
• 申請日: 2014-09-19
• 公開（公告）號: CN104217011B
• 公開（公告）日: 2017-08-25
• 發(fā)明（設(shè)計(jì)）人: 劉璧怡;郭美思;吳楠
• 申請（專利權(quán)）人: 浪潮（北京）電子信息產(chǎn)業(yè)有限公司
• 主分類號: G06F17/30
• 分類號: G06F17/30
• 代理公司: 北京安信方達(dá)知識產(chǎn)權(quán)代理有限公司11262
• 代理人: 王丹,李丹

1.一種HBase二級索引表的查詢方法，其特征在于，包括：

判斷HBase源表是否有對應(yīng)的二級索引表，通過所述二級索引表查詢HBase表的列中屬性值；

如果沒有，根據(jù)HBase源表中的列族信息、列信息、列屬性值及HBase源表中對應(yīng)的Rowkey，利用revertrow函數(shù)和Map函數(shù)創(chuàng)建HBase源表對應(yīng)的二級索引表的Rowkey和屬性值，并同步HBase源表的數(shù)據(jù)到對應(yīng)的二級索引表的Rowkey和屬性值中；

如果有，同步HBase源表的插入數(shù)據(jù)操作或刪除數(shù)據(jù)操作到對應(yīng)的二級索引表中；

其中，所述根據(jù)HBase源表中的列族信息、列信息、列屬性值及HBase源表中對應(yīng)的Rowkey，利用revertrow函數(shù)和Map函數(shù)創(chuàng)建HBase源表對應(yīng)的二級索引表的Rowkey和屬性值，并同步HBase源表的數(shù)據(jù)到對應(yīng)的二級索引表的Rowkey和屬性值中，包括：

利用revertrow函數(shù)，根據(jù)HBase源表中的列族信息、列信息、列屬性值及HBase源表中對應(yīng)的Rowkey，設(shè)置二級索引表的Rowkey；

利用Map函數(shù)，根據(jù)ImmutableBytesWritable key參數(shù)和Result value參數(shù)，提取HBase源表中的Rowkey及value值，遍歷每個(gè)KeyValue獲取相應(yīng)二級索引表中的Rowkey，并根據(jù)HBase源表的Rowkey和列屬性值設(shè)置二級索引表的屬性值；

在Map函數(shù)中調(diào)用revertrow函數(shù)，將revertrow函數(shù)的返回值Rowkey保存，并根據(jù)返回值Rowkey新建Put對象，為新建的Put對象添加相應(yīng)的屬性值；

用ImmutableBytesWritable對象封裝，用Context.write存儲(chǔ)結(jié)果。

2.根據(jù)權(quán)利要求1所述的HBase二級索引表的查詢方法，其特征在于，所述通過所述二級索引表查詢HBase表的列中屬性值，包括：

通過所述二級索引表查詢HBase表的列中屬性值的全部記錄。

3.根據(jù)權(quán)利要求1所述的HBase二級索引表的查詢方法，其特征在于，所述同步HBase源表的插入數(shù)據(jù)操作或刪除數(shù)據(jù)操作到對應(yīng)的二級索引表中，包括：

在Put函數(shù)或Delete函數(shù)中增加HBase源表對應(yīng)的二級索引表的名稱的參數(shù)；

在對HBase源表進(jìn)行插入數(shù)據(jù)操作或刪除數(shù)據(jù)操作時(shí)，提取插入或刪除數(shù)據(jù)的Rowkey及value值，根據(jù)提取的Rowkey及Value值設(shè)置二級索引表的Rowkey及Value值；

根據(jù)HBase源表對應(yīng)的二級索引表的名稱的參數(shù)，將設(shè)置的二級索引表的Rowkey及Value值進(jìn)行插入操作或者刪除操作。

4.一種HBase二級索引表的查詢裝置，其特征在于，包括：

判斷模塊，用于判斷HBase源表是否有對應(yīng)的二級索引表，通過所述二級索引表查詢HBase表的列中屬性值；

創(chuàng)建模塊，用于根據(jù)HBase源表中的列族信息、列信息、列屬性值及HBase源表中對應(yīng)的Rowkey，利用revertrow函數(shù)和Map函數(shù)創(chuàng)建HBase源表對應(yīng)的二級索引表的Rowkey和屬性值；

其中，所述創(chuàng)建模塊，根據(jù)HBase源表中的列族信息、列信息、列屬性值及HBase源表中對應(yīng)的Rowkey，利用revertrow函數(shù)和Map函數(shù)創(chuàng)建HBase源表對應(yīng)的二級索引表的Rowkey和屬性值指：利用revertrow函數(shù)，根據(jù)HBase源表中的列族信息、列信息、列屬性值及HBase源表中對應(yīng)的Rowkey，設(shè)置二級索引表的Rowkey；利用Map函數(shù)，根據(jù)ImmutableBytesWritable key參數(shù)和Result value參數(shù)，提取HBase源表中的Rowkey及value值，遍歷每個(gè)KeyValue獲取相應(yīng)二級索引表中的Rowkey，并根據(jù)HBase源表的Rowkey和列屬性值設(shè)置二級索引表的屬性值；在Map函數(shù)中調(diào)用revertrow函數(shù)，將revertrow函數(shù)的返回值Rowkey保存，并根據(jù)返回值Rowkey新建Put對象，為新建的Put對象添加相應(yīng)的屬性值；用ImmutableBytesWritable對象封裝，用Context.write存儲(chǔ)結(jié)果；

同步模塊，用于同步HBase源表的數(shù)據(jù)到對應(yīng)的二級索引表中；同步HBase源表的插入數(shù)據(jù)操作或刪除數(shù)據(jù)操作到對應(yīng)的二級索引表中。