mapreduce、hbase 和扫描

Question

我有一个扩展 TableMapper 的 MapReduce 作业 class。我使用 TableMapperReduceUtil initTableMapperJob 来设置工作正常的初始扫描。基于从 Scan 中检索到的行键，我想在我的 MapReduce Map 方法中运行在相同的 table 上获取一个 Get（使用作为初始 Scan 行中的值的 rowkey）。如何从 Map 方法中访问与相同 table 的 Hbase 连接？

Answer 1

也许您可以通过这种方式创建新连接：

Configuration config = context.getConfiguration();
Connection conn = ConnectionFactory.createConnection(config);

但我认为你的情况会更容易使用 Spark on HBase

mapreduce、hbase 和扫描

mapreduce, hbase and scan

java

hbase

mapreduce