Constructor Detail

• IdentityTableMapper

  public IdentityTableMapper()

Method Detail

• initJob

  public static void initJob(String table,
             Scan scan,
             Class<? extends TableMapper> mapper,
             org.apache.hadoop.mapreduce.Job job)
                      throws IOException

  Use this before submitting a TableMap job. It will appropriately set up the job.

  Parameters:

  table - The table name.

  scan - The scan with the columns to scan.

  mapper - The mapper class.

  job - The job configuration.

  Throws:

  IOException - When setting up the job fails.

• map

  public void map(ImmutableBytesWritable key,
         Result value,
         org.apache.hadoop.mapreduce.Mapper.Context context)
           throws IOException,
                  InterruptedException

  Pass the key, value to reduce.

  Overrides:

  map in class org.apache.hadoop.mapreduce.Mapper<ImmutableBytesWritable,Result,ImmutableBytesWritable,Result>

  Parameters:

  key - The current key.

  value - The current value.

  context - The current context.

  Throws:

  IOException - When writing the record fails.

  InterruptedException - When the job is aborted.