blob: 64a95775698edc04d5212c0aef7e19ff3611bfb1 [file] [log] [blame]
in = LOAD '$INFILE' USING AvroStorage();
grouped = GROUP in BY (value1.thing);
flattened = FOREACH grouped GENERATE flatten(in) as (key: chararray,value1: (thing: chararray,count: int),value2: (thing: chararray,count: int));
RMF $OUTFILE;
STORE flattened INTO '$OUTFILE' USING AvroStorage();