訪問MapReduce作業(yè)中的其他HBase表

訪問MapReduce作業(yè)中的其他HBase表

盡管當(dāng)前框架允許一個(gè) HBase 表作為 MapReduce 作業(yè)的輸入，其他的HBase表可以作為查找表來(lái)訪問，等等，在 MapReduce 作業(yè)中，通過在 Mapper 的 setup 方法中創(chuàng)建一個(gè) Table 實(shí)例。

public class MyMapper extends TableMapper<Text, LongWritable> {
  private Table myOtherTable;

  public void setup(Context context) {
    // In here create a Connection to the cluster and save it or use the Connection
    // from the existing table
    myOtherTable = connection.getTable("myOtherTable");
  }

  public void map(ImmutableBytesWritable row, Result value, Context context) throws IOException, InterruptedException {
    // process Result...
    // use 'myOtherTable' for lookups
  }