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?
非常感谢!
暂无答案!
目前还没有任何答案,快来回答吧!