我试图计算hbase表中的行数。可以用scanner实现,但这是一个庞大的过程。我想使用rowcounter从hbase表中获取行号。有什么方法可以在java代码中使用它吗。是否有任何可用的示例或代码段。通过使用以下命令,直接使用rowcounter非常简单:-
/hbase org.apache.hadoop.hbase.mapreduce.RowCounter [TABLE_NAME]
请提供任何代码段,以便在java代码中使用相同的代码段。谢谢
iqjalb3h1#
你可以在这里找到上面的源代码。要获得行计数,我们必须扫描hbase表。别无选择。但是,我们处理扫描的方式会有所不同。上面的map reduce rowcounter是在hbase中获取行计数的最快方法。由于map reduce是并行工作的,然后计数,所以我们得到的结果很快。你也可以自己做,通过查看上面的源代码,从中删除不需要的东西。在这里,您可以找到有关为map reduce和hbase之间的交互提供的api的信息
1条答案
按热度按时间iqjalb3h1#
你可以在这里找到上面的源代码。
要获得行计数,我们必须扫描hbase表。别无选择。但是,我们处理扫描的方式会有所不同。上面的map reduce rowcounter是在hbase中获取行计数的最快方法。由于map reduce是并行工作的,然后计数,所以我们得到的结果很快。
你也可以自己做,通过查看上面的源代码,从中删除不需要的东西。
在这里,您可以找到有关为map reduce和hbase之间的交互提供的api的信息