mapreduce实现apriori算法

最近看了几篇用mapreduce实现apriori算法的论文，在理论上懂，但具体要编程实现就不会了。不知道如何组织多个mapreduce作业，以及在这些mapreduce作业间，数据如何流动（既有原始事物数据集，又有前一个mapreduce作业生成的第K层频繁集作为下一个mapreduce作业的输入），请大神好人帮帮忙。