Permalink
Browse files

Add explicit parallelism to the Choose2 step

  • Loading branch information...
1 parent f196f54 commit f888d933e36d52ffcf62c7debf1095e6b9d00640 @jwills jwills committed Nov 14, 2011
Showing with 1 addition and 1 deletion.
  1. +1 −1 src/main/pig/step1_join_drugs_reactions.pig
@@ -119,7 +119,7 @@ drugs1_reacs = FOREACH filtered_drugs_reacs_demos GENERATE flatten(drugs.name) a
* record before taking the cross product with the reactions and demographic fields.
*/
drugs2_reacs = FOREACH filtered_drugs_reacs_demos GENERATE flatten(Choose2(drugs.name)) as (d1, d2),
- flatten(reacs.code) as reac, flatten(selected_demos);
+ flatten(reacs.code) as reac, flatten(selected_demos) PARALLEL 10;
/**
* The following statements compute aggregate counts of reported records, grouped by various

0 comments on commit f888d93

Please sign in to comment.