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();