问一个关于spark的一个统计求和问题,大神帮帮我

大乘期 发布于 2016/05/30 12:03
阅读 97
收藏 1

问一个关于spark的一个统计求和问题,大神帮帮我,请往下看

我的文本就是这样子,然后我要做的就是求和,看这里个

我的方法 很简单,然后用reduce统计,为什么结果不一样呢?

为什么值只能是20呢,应该是55才对呀,请问我哪里错了...请大神教教我...

补充一下,有大神教我,这么做,但是怎么转换数据呢?我要的是 求和....


结果是不对的,但是不是我要的呀,我要的 是Integer的相加,而这里是String的拼接...结果应该是55才对呀,请大神教教我...

加载中
0
小小机枪-哒哒哒
小小机枪-哒哒哒

new Function<String,String[]>(){

    String[] call(String s)

    return s.split(",");

}

0
大乘期
大乘期

引用来自“oscben”的评论

new Function<String,String[]>(){

    String[] call(String s)

    return s.split(",");

}

这种我也试过了,就是也不行,因为我知道,既然有",",那么要切割,切割之后,不能进行reduce呀...
0
小小机枪-哒哒哒
小小机枪-哒哒哒

引用来自“oscben”的评论

new Function<String,String[]>(){

    String[] call(String s)

    return s.split(",");

}

引用来自“yinfeng88”的评论

这种我也试过了,就是也不行,因为我知道,既然有",",那么要切割,切割之后,不能进行reduce呀...
sorry啊,我们将来可能会用spark 我自学了一点 也没学通呢
返回顶部
顶部