寂寞不孤单 2016-02-26 02:10 采纳率: 16.7%
浏览 1640

求mapreduce大神,看我这代码跑出来怎么没有结果?

public static class Map extends Mapper {
Text mk = new Text();

    public void map(Object key, Text value, Context context)
            throws IOException, InterruptedException {
        try {
            String[] line = value.toString().split("\t");
            while (line != null) {
                String one = line[0] + "\t" + line[1] + "\t" + line[2];
                String qm = line[3];
                String tg = line[4] + "\t" + line[5];
                System.out.println(one + "\t" + tg);
                if (qm.contains("*")) {
                    String[] two = qm.split("*");
                    for (String sign : two) {
                        mk.set(one + "\t" + sign + "\t" + tg);
                    }
                } else {
                    mk.set(one + "\t" + qm + "\t" + tg);
                }
                context.write(mk, NullWritable.get());

            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

看看哪里出错,改一下
原文件实例数据
00022 000CE34D03F8B551F2346D19D8379B33 2013-10-09 [大天开]*[开天] F 车主
00022 000CE34D03F6B551F9904D19D8379B33 2013-10-09 [大天开]*[开天] X 新老用户
想要的到的数据
00022 000CE34D03F8B551F2346D19D8379B33 2013-10-09 [大天开] F 车主
00022 000CE34D03F8B551F2346D19D8379B33 2013-10-09 [开天] F 车主
00022 000CE34D03F6B551F9904D19D8379B33 2013-10-09 [大天开] X 新老用户
00022 000CE34D03F6B551F9904D19D8379B33 2013-10-09 [开天] X 新老用户

  • 写回答

1条回答

  • 大海中的一片叶 2016-02-26 09:46
    关注

    空格分割符不是\t \s 多个空格\s+

    评论

报告相同问题?

悬赏问题

  • ¥15 执行 virtuoso 命令后,界面没有,cadence 启动不起来
  • ¥50 comfyui下连接animatediff节点生成视频质量非常差的原因
  • ¥20 有关区间dp的问题求解
  • ¥15 多电路系统共用电源的串扰问题
  • ¥15 slam rangenet++配置
  • ¥15 有没有研究水声通信方面的帮我改俩matlab代码
  • ¥15 ubuntu子系统密码忘记
  • ¥15 保护模式-系统加载-段寄存器
  • ¥15 电脑桌面设定一个区域禁止鼠标操作
  • ¥15 求NPF226060磁芯的详细资料