在hbase表中使用rowcounter

dm7nw8vv  于 2021-06-03  发布在  Hadoop
关注(0)|答案(1)|浏览(459)

我试图计算hbase表中的行数。可以用scanner实现,但这是一个庞大的过程。我想使用rowcounter从hbase表中获取行号。有什么方法可以在java代码中使用它吗。是否有任何可用的示例或代码段。通过使用以下命令,直接使用rowcounter非常简单:-

/hbase org.apache.hadoop.hbase.mapreduce.RowCounter [TABLE_NAME]

请提供任何代码段,以便在java代码中使用相同的代码段。
谢谢

iqjalb3h

iqjalb3h1#

你可以在这里找到上面的源代码。
要获得行计数,我们必须扫描hbase表。别无选择。但是,我们处理扫描的方式会有所不同。上面的map reduce rowcounter是在hbase中获取行计数的最快方法。由于map reduce是并行工作的,然后计数,所以我们得到的结果很快。
你也可以自己做,通过查看上面的源代码,从中删除不需要的东西。
在这里,您可以找到有关为map reduce和hbase之间的交互提供的api的信息

相关问题