The transaction sorting job could have been made map-only, and another mapreduce job follows, so it made sense to combine them. It would have been possible to use a ChainMapper approach, but it seemed simpler to fold the functionality into the following mapper (ParallelFPGrowthMapper). The attached patch does just that.
|Status||Open [ 1 ]||Patch Available [ 10002 ]|
|Assignee||Robin Anil [ robinanil ]|
|Status||Patch Available [ 10002 ]||Resolved [ 5 ]|
|Resolution||Fixed [ 1 ]|
|Fix Version/s||0.6 [ 12316364 ]|
|Status||Resolved [ 5 ]||Closed [ 6 ]|