mapreduce、hbase 和扫描

Question

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

Answer 1

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

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

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