Constructor Detail

• IdentityTableMap

  public IdentityTableMap()

  constructor

Method Detail

• initJob

  public static void initJob(String table,
             String columns,
             Class<? extends TableMap> mapper,
             org.apache.hadoop.mapred.JobConf job)

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

  Parameters:

  table - table name

  columns - columns to scan

  mapper - mapper class

  job - job configuration

• map

  public void map(ImmutableBytesWritable key,
         Result value,
         org.apache.hadoop.mapred.OutputCollector<ImmutableBytesWritable,Result> output,
         org.apache.hadoop.mapred.Reporter reporter)
           throws IOException

  Pass the key, value to reduce

  Specified by:

  map in interface org.apache.hadoop.mapred.Mapper<ImmutableBytesWritable,Result,ImmutableBytesWritable,Result>

  Parameters:

  key -

  value -

  output -

  reporter -

  Throws:

  IOException