org.apache.hadoop.hbase.mapred

Class IdentityTableMap

java.lang.Object

MapReduceBase

org.apache.hadoop.hbase.mapred.IdentityTableMap

All Implemented Interfaces:

TableMap<ImmutableBytesWritable,Result>

@InterfaceAudience.Public
 @InterfaceStability.Stable
public class IdentityTableMap
extends MapReduceBase
implements TableMap<ImmutableBytesWritable,Result>

Pass the given key and record as-is to reduce

Constructor Summary

Constructors

Constructor and Description
IdentityTableMap() constructor

Method Summary

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

IdentityTableMap

public IdentityTableMap()

constructor

Method Detail

initJob

public 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. 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,
                <any> output,
                Reporter reporter)
         throws java.io.IOException

Pass the key, value to reduce

Parameters:

key -

value -

output -

reporter -

Throws:

java.io.IOException