使用java检索hbase中的任意三个随机限定符

1dkrff03 于 2021-06-02 发布在 Hadoop

关注(0)|答案(1)|浏览(307)

我的hbase表如下所示：

hbase(main):040:0> scan 'TEST' 
ROW               COLUMN+CELL                                                                                                
4                 column=data:108, timestamp=1399972960190, value=-240.0                                                     
4                 column=data:112, timestamp=1399972960138, value=-160.0                                                     
4                 column=data:12, timestamp=1399972922979, value=2                                                           
4                 column=data:120, timestamp=1399972960124, value=-152.0                                                     
4                 column=data:144, timestamp=1399972960171, value=-240.0                                                     
4                 column=data:148, timestamp=1399972960152, value=-240.0                                                     
4                 column=data:16, timestamp=1399972909606, value=9                                                           
4                 column=data:8, timestamp=1399972917978, value=6

所有4s都是row id和108112,12。。。是限定符。我想从这个表测试中随机抽取三个限定符。
我可以获取所有限定符，但不能随机获取三个限定符。java中是否有任何shell命令或api可以实现这一点？

Java hadoop hbase mapreduce bigdata

来源：https://stackoverflow.com/questions/23627847/retrieve-any-three-random-qualifier-in-hbase-using-java

1条答案

按热度按时间

pprl5pva1#

如果只是获取前三行，请使用scan shell命令并将limit设置为3：

hbase(main):001:0> scan 'demo', {LIMIT => 3}

如果您希望使用JavaAPI来实现，请在resultscanner上设置一个循环，该循环在第三次迭代后中断。简单易用。

public static void main(String[] args) throws IOException {

        Configuration conf = HBaseConfiguration.create();
        HTable table = new HTable(conf, "demo");
        Scan s = new Scan();
        ResultScanner rs = table.getScanner(s);
        int check = 0;
        for(Result r : rs){
            if(++check > 3)
                break;              
            for (KeyValue kv : r.raw()){                    
                System.out.println("Qualifier : " + Bytes.toString(kv.getQualifier()));
            }                           
        }
        rs.close();
        table.close();
    }
}

如果您希望获得3个随机行，请使用上述方法的randomrowfilter。
hth公司

赞(0）回复(0）举报 2021-06-03

我来回答

使用java检索hbase中的任意三个随机限定符

1条答案

相关问题

热门标签

最新问答