@InterfaceAudience.Public @InterfaceStability.Stable public class IdentityTableMap extends MapReduceBase implements TableMap<ImmutableBytesWritable,Result>
Constructor and Description |
---|
IdentityTableMap()
constructor
|
Modifier and Type | Method and Description |
---|---|
static void |
initJob(java.lang.String table,
java.lang.String columns,
java.lang.Class<? extends TableMap> mapper,
JobConf job)
Use this before submitting a TableMap job.
|
void |
map(ImmutableBytesWritable key,
Result value,
<any> output,
Reporter reporter)
Pass the key, value to reduce
|
public static void initJob(java.lang.String table, java.lang.String columns, java.lang.Class<? extends TableMap> mapper, JobConf job)
table
- table namecolumns
- columns to scanmapper
- mapper classjob
- job configurationpublic void map(ImmutableBytesWritable key, Result value, <any> output, Reporter reporter) throws java.io.IOException
key
- value
- output
- reporter
- java.io.IOException