Initial filtering
Thursday, February 24, 2011
12:24 PM
Our schema is now
posts: (time:long, user:chararray, topic:chararray, opinion:chararray)
let's concentrate on the negative posts:
hates = FILTER posts BY topic=='Honda' and opinion=='negative';
and let's remove those fields, because we don't need them now:
hate2 = FOREACH hates GENERATE time, user; 
Our schema is now
posts: (time:long, user:chararray)