tweaks

mattb · Mar 20, 2012 · a20cfbb · a20cfbb
1 parent 358b8fb
commit a20cfbb
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/foursquare-twitter/pig/sf-checkins-active-users.pig b/foursquare-twitter/pig/sf-checkins-active-users.pig
@@ -5,4 +5,5 @@ SF = FILTER B BY lat > 37.604031 AND lat < 37.832371 AND lng > -123.013657 AND l
 PEOPLE = GROUP SF BY nick;
 PEOPLE_COUNTED = FOREACH PEOPLE GENERATE COUNT(SF) AS c, group, SF;
 ACTIVE = FILTER PEOPLE_COUNTED BY c >= 5;
-STORE ACTIVE INTO 's3://mattb-4sq/active-sf';
+RESULT = FOREACH ACTIVE GENERATE group,FLATTEN(SF);
+STORE RESULT INTO 's3://mattb-4sq/active-sf';