您已经列出了基于这些步骤的逻辑。请参阅下面的script.load data，join on owneruserid，id然后按owneruserid分组。foreach group生成posts的计数。按降序对最终结果排序并获得最顶层的行。

A = LOAD 'Posts.csv' USING PigStorage(',') AS (int id,chararray:post_type,chararray:creationdate,int:score,int:viewcount,int:owneruserid,chararray:title,int:answercount,int:commentcount);
B = LOAD 'Users.csv' USING PigStorage(',') AS (int:id,int:reputation,chararray:displayname,chararray:loc,int:age);
C = JOIN A BY (owneruserid), B BY (id);
D = GROUP C BY A.owneruserid;
E = FOREACH D GENERATE group as userid,B.displayname,COUNT(A.id) as TotalPosts;
F = ORDER E BY TotalPosts DESC;
G = LIMIT 1;