hadoop mapreduce json对象,其成员为.txt

djmepvbi  于 2021-05-27  发布在  Hadoop
关注(0)|答案(0)|浏览(289)

hadoop新手。。。
我在写一个mapreduce算法。作为输入,我得到了一个包含成员的json。输入一个成员可以投票的歌曲。我需要一首歌在狂欢中获得多少选票的总和 ("rave_id") 投票可以是+1或-1,由 "preference" 布尔值:真=+1,假=-1。
我需要mapreduce的输出是 .txt 此格式的文件。

"rave_ID_X" "song_ID_1" "Count_1"
"rave_ID_X" "song_ID_2" "Count_1"
"rave_ID_x" "song_ID_3" "Count_1"

如何迭代输入json对象的所有成员?我的第一个想法是使用“rave\u id”+“song\u id”作为键,使用preference boolean作为值?
然后在 reduce 方法我可以使用这个逻辑来减少布尔投票计数。

int sum = 0;
        for ( String val: values){
            if (val == "true"){
                sum +=1;
            }
            else if (val == "false"){
                sum -=1;
            }
        }

但是,我怎样才能在 .txt 文件,而不是json?
非常感谢!

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题