sql - 将SQL查询转换为Pig查询

Question

我正在Hadoop中使用Pig，并且需要将以下SQL代码转换为PigLatin:

SELECT lo_discount, COUNT(lo_extendedprice)
FROM lineorder
GROUP BY lo_discount;

加载 lineorder表后，到目前为止，这是我得到的，但是不幸的是，它不起作用:

data = FOREACH lineorder GENERATE lo_discount, lo_extendedprice;
dataG = GROUP data BY lo_discount;
ans0 = FOREACH dataG GENERATE dataG.lo_discount, COUNT(dataG.lo_extendedprice);

谁能帮我怎么做？谢谢!

Answer 1

将最后一个 pig 语句修改为

ans0 = FOREACH dataG GENERATE group, COUNT(data);