champ individuel de requête après groupe par

Question

I ont une relation

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

Le schéma est (nom, âge, ville)

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

Pig se plaint que « Scalar a plus d'une ligne de la sortie "pour le groupe GENERATE, info.name; Comment interroger un champ individuel dans le sac après le groupe par?

Merci.

Answer 1

Pour moi, le code ci-dessus fonctionne et la sortie pour 'Dump B'; est

(NY, {(Mary)}) (SF, {(John), (Bill), (Joe)})

En ce qui concerne l'interrogation champ individuel après groupe par est concerné, vous allez Vous devez vous référer de la même manière que vous le faites maintenant, Alias.fieldName.