在groupby之后查询单个字段

hpcdzsge 于 2021-06-04 发布在 Hadoop

关注(0)|答案(1)|浏览(360)

我有亲戚

A = 
(John,19,SF)
(Mary,20,NY)
(Bill,23,SF)
(Joe,25,SF)

架构为（姓名、年龄、城市）

B = foreach (group A by city) 
{
   sorted = ORDER A BY age;
   info = LIMIT sorted 10;
   GENERATE group, info.name;
}

pig抱怨generate group info.name的“scalar在输出中有多行”；
分组后如何查询包中的单个字段？
谢谢。

1条答案

对我来说，上面的代码正在工作，输出为'dump b；'是
（纽约，{（玛丽）}）（旧金山，{（约翰），（比尔），（乔）}）
至于在groupby之后查询单个字段，您必须以与现在相同的方式引用alias.fieldname。