0

ご縁があります

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 の出力に複数の行がある」と不平を言います。

グループ化後にバッグ内の個々のフィールドを照会する方法は?

ありがとう。

4

1 に答える 1

0

私にとって、上記のコードは機能しており、「Dump B;」の出力です。は

(NY,{(メアリー)}) (SF,{(ジョン),(ビル),(ジョー)})

グループ化後の個々のフィールドのクエリに関する限り、現在行っているのと同じ方法で Alias.fieldName を参照する必要があります。

于 2013-04-03T05:36:40.453 に答える