mapreduce，hbase和掃描

Question

我有一個擴展TableMapper類的MapReduce作業。我使用TableMapperReduceUtil initTableMapperJob來設置可以正常工作的初始掃描。基於從掃描中檢索到的rowkey我想在我的MapReduce Map方法中的同一張表上運行Get（使用行初始掃描行中的值）。如何從Map方法內訪問Hbase連接到同一個表？

Answer 1

也許你可以創建這樣一個新的連接：

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

但我認爲在你的情況下，它會更容易使用Spark on HBase