hadoop - 分组后查询单个字段

Question

我有关系

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 组 info.name 的“Scalar 在输出中有不止一行”；

分组后如何查询包中的单个字段？

谢谢。

Answer 1

对我来说，上面的代码正在运行，并且输出为 'Dump B;' 是

（纽约，{（玛丽）}）（SF，{（约翰），（比尔），（乔）}）

至于在 group by 之后查询单个字段，您必须以与现在相同的方式引用 Alias.fieldName。