0
我想弄清楚下面的问题。阿帕奇猪不同和计数
有多少女性用户提供了至少一个等级4.我认为我的连接和过滤器是正确的,但我无法弄清楚计数部分已经尝试了以下的众多版本。
a = load '/user/pig/movie' AS (userid:int, movieid:int, rating:int, timestamp:chararray);
b = load '/user/pig/reviewer' using PigStorage('|') AS (userid:int, age:int, gender:chararray, occupation:chararray, zip:chararray);
a1 = filter a by rating == 4;
b1 = filter b by gender == 'F';
c = join a1 by userid, b1 by userid;
d = FOREACH c GENERATE COUNT(DISTINCT(userid));
dump d;
谢谢我试过,我得到一个错误 - 无法使用导入来解决DISTINCT。 –