Grouping by time
Thursday, February 24, 2011
12:40 PM
Now we group behavior by time: 
buzzes = GROUP cluster2 BY time; 
Now our schema is 
buzzes: (group:long, cluster2:{(time:long, user:chararray)})
Let's count the number of distinct users:
buzz2 = FOREACH buzzes GENERATE group as time, COUNT(cluster2) as hits; 
Now our schema is:
buzz2: (time:long, hits:int);
Finally, we filter for lotsa hits: 
buzz3 = FILTER buzz2 BY hits>1000;
And report those times: 
DUMP buzz3; 