REDUCERから複数のテーブルに出力を書き込む

Question

HBaseの複数のテーブルに出力を書き込むことはできますか？私は別のブログ記事を見ましたが、道を見つけることができませんでした。たとえMultiTableOutputFormatを使っていました。

私はこれを参照： Write to multiple tables in HBASE

しかしcontext.writeコールのためにAPI署名を把握することはできませんが。

減速コード：

public class MyReducer extends TableReducer<Text, Result, Put> { 

    private static final Logger logger = Logger.getLogger(MyReducer.class); 

    @SuppressWarnings("deprecation") 
    @Override 
    protected void reduce(Text key, Iterable<Result> data, Context context) throws IOException, InterruptedException { 
     logger.info("Working on ---> " + key.toString()); 
     for (Result res : data) { 
      Put put = new Put(res.getRow()); 
      KeyValue[] raw = res.raw(); 
      for (KeyValue kv : raw) { 
       put.add(kv); 
      } 

      context.write(obj, put); 
      **// I dont know how to give table name here.** 

     } 
    } 
} 

Answer 1

テーブル名を識別するために、あなたはcontext.write(key, put)方法をキーとしてテーブル名を渡す必要があります。

ImmutableBytesWritable key = new ImmutableBytesWritable(Bytes.toBytes("tableName")); 
context.write(key, put); 

をしかし、あなたは大量のデータをロードする場合MapReduceジョブを介してすぐにMultiTableHFileOutputFormatを使用するのが面白いかもしれません。

hbase org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles /tmp/multiTableJobResult hbaseTable 

あなたが記事にMultiTableHFileOutputFormat詳細を読むことができます：：http://tech.adroll.com/blog/data/2014/07/15/multi-table-bulk-import.html