将 SQL 查询转换为 Pig 查询

Question

我在 Hadoop 中使用 Pig 工作，需要将以下 SQL 代码转换为 PigLatin：

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

加载 lineorder table 后，这是我目前得到的结果，但不幸的是它不起作用：

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);

将 SQL 查询转换为 Pig 查询

Convert SQL query to Pig query

sql

hadoop

apache-pig