寂寞不孤单 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 HFSS 中的 H 场图与 MATLAB 中绘制的 B1 场 部分对应不上
  • ¥15 如何在scanpy上做差异基因和通路富集?
  • ¥20 关于#硬件工程#的问题,请各位专家解答!
  • ¥15 关于#matlab#的问题:期望的系统闭环传递函数为G(s)=wn^2/s^2+2¢wn+wn^2阻尼系数¢=0.707,使系统具有较小的超调量
  • ¥15 FLUENT如何实现在堆积颗粒的上表面加载高斯热源
  • ¥30 截图中的mathematics程序转换成matlab
  • ¥15 动力学代码报错,维度不匹配
  • ¥15 Power query添加列问题
  • ¥50 Kubernetes&Fission&Eleasticsearch
  • ¥15 報錯:Person is not mapped,如何解決?