MapReduce之TableMapper类

1.源码

package org.apache.hadoop.hbase.mapreduce; 
 
import org.apache.hadoop.hbase.classification.InterfaceAudience; 
import org.apache.hadoop.hbase.classification.InterfaceStability; 
import org.apache.hadoop.hbase.client.Result; 
import org.apache.hadoop.hbase.io.ImmutableBytesWritable; 
import org.apache.hadoop.mapreduce.Mapper; 
 
@param <KEYOUT>  The type of the key. 
@param <VALUEOUT>  The type of the value. 
@see org.apache.hadoop.mapreduce.Mapper 
 
@InterfaceAudience.Public 
@InterfaceStability.Stable 
public abstract class TableMapper<KEYOUT, VALUEOUT> 
extends Mapper<ImmutableBytesWritable, Result, KEYOUT, VALUEOUT> {
   
     
} 

二.简介

2.1 参数简介

Extends the base Mapper class to add the required input key and value classes.
TableMapper继承自Mapper类。但是Mapper类有四个输入泛型，为何这里的TableMapper只有两个呢？通过源码，可以看到TableMapper的KEYIN，VALUEIN分别设置为ImmutabelBytesWriteable和Result类型，所以只需要实现KEYOUT，VALUEOUT即可。

2.2 这里的TableMapper类完全是为了从HBase中读取数据而设置的，也就是说，这个TableMapper是专为HBase定义的抽象类。

三.示例

实战程序详见我的 电信大数据项目