在 Pig 中划分的无效现场项目

Question

我正在尝试对 2 列进行除法，这些列是 Pig 中 COUNT 的结果：

a = LOAD 'file.csv' USING PigStorage(',') AS (ID:chararray, Name:chararray, Result:chararray)
b = filter a by =='123';
c = filter a by =='123' and ='Win';
d = foreach (group b by ) generate group as da_id, count(b) as total;
e = foreach (group c by ) generate group as da_id, count(c) as total_wins;
f = join d by da_id, e by da_id;
g = foreach (group f by [=10=]) generate group as da_id, f::total_wins/f::total as ratio;

但是，我得到了错误

Invalid field projection. Projected field [f::total_wins] does not exist in schema

有人可以帮忙吗？

Answer 1

total 和 total_wins 是关系 d 和 e 的一部分 respectively.Use below code

g = foreach (group f by [=10=]) generate group as da_id, e::total_wins/d::total as ratio;