2 perfectwangandy PerfectWangAndy 于 2017.08.28 20:15 提问

MapReduce程序中的map方法怎么写?

/*
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......
}

}


2个回答

devmiao
devmiao   Ds   Rxr 2017.08.28 23:55
huang931027
huang931027   2017.08.29 09:14

map的思想就是把很多的数据进行一个拆分。方便最后进行reduce ,不知道你要做什么样的东西,但是建议,先把思想搞清楚这样方便写代码

Csdn user default icon
上传中...
上传图片
插入图片