我无法使用此脚本：
raw = LOAD 's3://xxxxxxxxx/*' AS (name:chararray, year:float, occurrences:float, books:float);
B = GROUP raw BY name;
C = FOREACH B GENERATE B.name, (SUM(B.occurrences) / SUM(B.books)) AS average;
D = ORDER C BY average DESC;
E = LIMIT D 10;
STORE E INTO 's3://xxxxxx';
1条答案
按热度按时间jckbn6z71#
声明
C不正确，无法访问变量name,occurrences and books使用Relation B. 只能通过relation raw. 你能换一下衣服吗stmt C像这样的？在这里
group参考变量name如果您遇到任何其他问题，请粘贴您的错误日志。