/*
MapReduce程序中的map方法的输入来自于多个表的时候,
getRow()方法返回的是哪个表的KeyRow ?
*/
public class MyMap extends TableMapper {
@Override
protected void map(ImmutableBytesWritable mapInputKey, Result mapInputValues,
Mapper.Context context)
throws IOException, InterruptedException {
//mapInputValues来自于多个表:TableA、TableB、TableC......
String rowKey = new String(mapInputValues.getRow());//此处的row key是哪个表的?为什么?
//code......
}
}