有时很奇怪 2017-08-28 12:15 采纳率: 10%
浏览 1174

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 2017-08-28 15:55
    关注
    评论

报告相同问题?

悬赏问题

  • ¥15 sqlite 附加(attach database)加密数据库时,返回26是什么原因呢?
  • ¥88 找成都本地经验丰富懂小程序开发的技术大咖
  • ¥15 如何处理复杂数据表格的除法运算
  • ¥15 如何用stc8h1k08的片子做485数据透传的功能?(关键词-串口)
  • ¥15 有兄弟姐妹会用word插图功能制作类似citespace的图片吗?
  • ¥200 uniapp长期运行卡死问题解决
  • ¥15 请教:如何用postman调用本地虚拟机区块链接上的合约?
  • ¥15 为什么使用javacv转封装rtsp为rtmp时出现如下问题:[h264 @ 000000004faf7500]no frame?
  • ¥15 乘性高斯噪声在深度学习网络中的应用
  • ¥15 关于docker部署flink集成hadoop的yarn,请教个问题 flink启动yarn-session.sh连不上hadoop,这个整了好几天一直不行,求帮忙看一下怎么解决