mapreduce、hbase and scan

Question

私は、TableMapperクラスを拡張するMapReduceジョブを持っています。私はTableMapperReduceUtil initTableMapperJobを使用して、うまく動作する初期スキャンを設定します。スキャンから取得したローキーに基づいて、私のMapReduce Mapメソッド内の同じテーブルでGet（最初のスキャン行の値である行キーを使用）を実行します。 Mapメソッドから同じテーブルへのHbase接続にアクセスするにはどうすればよいですか？

Answer 1

は、おそらくあなたは、このように新しい接続を作成することができます

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

をしかし、私はそれを使用するように簡単になりますあなたのケースで考えるSpark on HBase