2017-07-18 13 views
0

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

答えて

0

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

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

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

関連する問題