tuple conversions


2 Answer(s)


Hi Sirajuddin,

Use the following correct command:

A = load '/user/cloudera/sqoop/nyse/project/pig' using PigStorage(',') AS (X:chararray,Y:int);
B = GROUP A BY X;
C = FOREACH B GENERATE group, SUM (A.Y);
DUMP C;

Expected Output:

(GPI,460)
(GPJ,4600)

Hope this helps.

Thanks

 


thanks! works!