在pig中使用多种条件的过滤柱

mzsu5hc0 于 2021-06-21 发布在 Pig

关注(0)|答案(1)|浏览(333)

我需要编写一个pig脚本，在该脚本中，我将查找几列的平均值，并只获取所有列值都大于计算平均值的行。我的剧本是：

i2 = GROUP i1 all;
i3 = FOREACH i2 GENERATE AVG(i1.user_followers_count) AS avg_user_followers_count, AVG(i1.avl_user_follower_following_ratio) AS avg_avl_user_follower_following_ratio, AVG(i1.user_total_liked) AS avg_user_total_liked, AVG(i1.user_total_posts) AS avg_user_total_posts, AVG(i1.user_total_public_lists) AS avg_user_total_public_lists, AVG(i1.avl_user_total_retweets) AS avg_avl_user_total_retweets, AVG(i1.avl_user_total_likes) AS avl_user_total_likes, AVG(i1.avl_user_total_replies) AS avg_avl_user_total_replies, AVG(i1.avl_user_engagements) AS avl_avl_user_engagements, AVG(i1.user_reply_to_reply_count) AS avg_user_reply_to_reply_count;

top_inf = FILTER i1 BY (i1.user_followers_count > i3.avg_user_followers_count, i1.avl_user_total_retweets > i3. avg_avl_user_total_retweets, i1.avl_user_total_likes > i3.avg_avl_user_total_retweets);

但这会引发一个错误：

ERROR 1200: <file user.pig, line 70, column 103>  mismatched input '>' expecting RIGHT_PAREN

在多个条件下过滤行的正确方法是什么？

apache-pig

来源：https://stackoverflow.com/questions/40598443/filter-columns-using-multiple-conditions-in-pig

1条答案

按热度按时间

iyr7buue1#

使用和分隔条件

top_inf = FILTER i1 BY (i1.user_followers_count > i3.avg_user_followers_count) 
                   AND (i1.avl_user_total_retweets > i3.avg_avl_user_total_retweets) 
                   AND (i1.avl_user_total_likes > i3.avg_avl_user_total_retweets);

赞(0）回复(0）举报 2021-06-21

我来回答

在pig中使用多种条件的过滤柱

1条答案

相关问题

热门标签

最新问答