java - 用 Pig Latin 计算平均值

Question

考虑一个数据文件:

4, 8, 2
5, 2, 5
3, 1, 7

我想计算每列的平均值。最简单的方法是什么？
如果我有 20 列，是否有一个循环，这样我就不必手动计算每一列？

Answer 1

你能试试这个吗？

A = LOAD 'input.txt' USING PigStorage(',') AS(a,b,c);
B = FOREACH A GENERATE AVG(TOBAG(*));
DUMP B;

输出:

(4.666666666666667)
(4.0)
(3.6666666666666665)

更新:每列的平均值

A = LOAD 'input.txt' USING PigStorage(',') AS(a,b,c);
B = GROUP A ALL;
C = FOREACH B GENERATE AVG(A.a),AVG(A.b),AVG(A.c);
DUMP C;

输出:

(4.0,3.6666666666666665,4.666666666666667)