HBase Java代码中的行数

问题描述 投票:-1回答:1

我正在尝试使用Java记录数百万条记录的Hbase表中的行数

                // ResultScanner scanner = table.getScanner(s);
                int count = 0;


                for (Result result = scanner.next(); (result != null); result = scanner
                        .next()) {
                    count =count + 1;


                }
                // System.out.println("%%%%%%%%%%%%" + count);

但是这给了错误,因为>

java.net.SocketTimeoutException: callTimeout=60000, callDuration=60146:
at org.apache.hadoop.hbase.client.RpcRetryingCallerImpl.callWithRetries(RpcRetryingCallerImpl.java:159)
    at org.apache.hadoop.hbase.client.ResultBoundedCompletionService$QueueingFuture.run(ResultBoundedCompletionService.java:80)

    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)

请帮忙,我想获取Java代码表中记录的总数,我已经尝试过使用计数器,但是它没有帮助,这是我可以触发查询以获取结果的一种方法。>

我正在尝试使用Java //获得具有数百万条记录的Hbase表中的行数// // ResultScanner Scanner = table.getScanner(s ;; int count = 0; ...

java hbase
1个回答
0
投票

添加了这些喜欢的内容并奏效了

FilterList allFilters = new FilterList();
                allFilters.addFilter(new FirstKeyOnlyFilter());
                allFilters.addFilter(new KeyOnlyFilter());
© www.soinside.com 2019 - 2024. All rights reserved.