hbase删除多行&范围删除

客官°小女子只卖身不卖艺 2022-07-12 02:26 525阅读 0赞

有时候会有这样的需求，需要删除指定某些行的数据。但是笔者看《[Hbase][]权威指南》好像没有Delete的filter（过滤器），所以想了一下如果实现删除指定行的方法

1.  如果知道要删除某些行的行键，那么很简单，用List<Delete>就可以完成这个功能
2.  如果要删除的行在表中是连续的，也就是删除指定范围的行，但是你还不知道这个范围内所有的行键，比如一个表中行键11-19的行，但是表中只有11,13,16。这时可以采用的方法是用Scan先读出范围内的行键，用Scan方法就可以使用Filter，其中有一个Filter是KeyOnlyFilter，因为我们只需要Key
    
    **\[java\]** [ view plain][view plain] [ copy][view plain] [ print][view plain] [?][view plain]
    
    1.  Scan sc = new Scan();  
    2.  Filter fil = new KeyOnlyFilter();  
    3.  sc.setStartRow(startRow);  
    4.  sc.setStopRow(stopRow);  
    
      
    
3.  上面提到了Filter，所以我们可以通过用Scan和Filter来读取指定Key然后再Delete
    
    **\[java\]** [ view plain][view plain] [ copy][view plain] [ print][view plain] [?][view plain]
    
    1.  Scan scan=new Scan();  
    2.  Filter filter=new RowFilter(CompareFilter.CompareOp.EQUAL,  
    3.          new RegexStringComparator(pyramidName));  
    4.  scan.setFilter(filter);  
    5.  ResultScanner resultScanner=tileTable.getScanner(scan);  
    6.  List<Delete> deletes=new ArrayList<Delete>();  
    7.  for(Result result:resultScanner)\{  
    8.      byte\[\] row=result.getRow();  
    9.      Delete deleteTile=new Delete(row);  
    10.     deletes.add(deleteTile);  
    11. \}  
    12. tileTable.delete(deletes);

PS：第三种方法会在集群中传送很多无用的数据，无形中增加了网络的带宽。但是这也是没有办法的事情。以上代码都没经过[测试][Link 1]，大体是这个意思

PSS：如果谁有更好的方法，希望能和他说一声

转自：[转载][Link 2]

[Hbase]: http://lib.csdn.net/base/hbase
[view plain]: http://blog.csdn.net/qiuchenl/article/details/8697498#
[Link 1]: http://lib.csdn.net/base/softwaretest
[Link 2]: http://blog.csdn.net/qiuchenl/article/details/8697498