HBase - Java 客户端限制扫描结果说明?
HBase - Java Client Limit Scan Results Explanation?
有没有办法在执行数据扫描时限制顺序数据的总行数?
备注:
- 我总共处理了 500,000 行
- 我已经尝试了 setMaxResultSize 和 setMaxResultsPerColumnFamily。这被证明是无效的(当两者都设置为较低的数字或 setMaxResultSize 较大时似乎确实有一些行为。这两个函数之间有什么关系?)
- 我已经设置了 PageFilter(大小为 10),该行为显示了 5 个不同的序列数据集,每组 10 个。
- 实际上,我通过将 PageFilter 大小和 setMaxResultSize 设置为相等来实现它的 sudo-working。当我更改其中任何一个时,它都符合 PageFilter。如果我使 setMaxResultSize 显着变大,它也会跳转到 PageFilter 大小的另一个大子集。
- HBase 版本为 1.1.1
有人可以更好地解释这里发生的事情以及如何获得我想要的结果吗?
您可以使用 hbase shell 或 hbase java 客户端。
1- hbase shell:使用此命令并将结果通过管道传输到文件并执行 "wc -l ..."
计数'table_name',1
2- java hbase 客户端 api
long count=0;
String row="";
for (Result res : scanner)
{
for (Cell cell : res.listCells())
{
row = new String(CellUtil.cloneRow(cell));
if(!row.equals(""))
count++;
}
}
有没有办法在执行数据扫描时限制顺序数据的总行数?
备注:
- 我总共处理了 500,000 行
- 我已经尝试了 setMaxResultSize 和 setMaxResultsPerColumnFamily。这被证明是无效的(当两者都设置为较低的数字或 setMaxResultSize 较大时似乎确实有一些行为。这两个函数之间有什么关系?)
- 我已经设置了 PageFilter(大小为 10),该行为显示了 5 个不同的序列数据集,每组 10 个。
- 实际上,我通过将 PageFilter 大小和 setMaxResultSize 设置为相等来实现它的 sudo-working。当我更改其中任何一个时,它都符合 PageFilter。如果我使 setMaxResultSize 显着变大,它也会跳转到 PageFilter 大小的另一个大子集。
- HBase 版本为 1.1.1
有人可以更好地解释这里发生的事情以及如何获得我想要的结果吗?
您可以使用 hbase shell 或 hbase java 客户端。
1- hbase shell:使用此命令并将结果通过管道传输到文件并执行 "wc -l ..."
计数'table_name',1
2- java hbase 客户端 api
long count=0;
String row="";
for (Result res : scanner)
{
for (Cell cell : res.listCells())
{
row = new String(CellUtil.cloneRow(cell));
if(!row.equals(""))
count++;
}
}