public class IdentityTableMapper extends TableMapper<ImmutableBytesWritable,Result>
Constructor and Description |
---|
IdentityTableMapper() |
Modifier and Type | Method and Description |
---|---|
static void |
initJob(java.lang.String table,
Scan scan,
java.lang.Class<? extends TableMapper> mapper,
Job job)
Use this before submitting a TableMap job.
|
void |
map(ImmutableBytesWritable key,
Result value,
Context context)
Pass the key, value to reduce.
|
public static void initJob(java.lang.String table, Scan scan, java.lang.Class<? extends TableMapper> mapper, Job job) throws java.io.IOException
table
- The table name.scan
- The scan with the columns to scan.mapper
- The mapper class.job
- The job configuration.java.io.IOException
- When setting up the job fails.public void map(ImmutableBytesWritable key, Result value, Context context) throws java.io.IOException, java.lang.InterruptedException
key
- The current key.value
- The current value.context
- The current context.java.io.IOException
- When writing the record fails.java.lang.InterruptedException
- When the job is aborted.