基于Spark的并行频繁模式挖掘算法

Parallel frequence pattern mining algorithm based on Spark

在大数据环境下Apriori频繁模式挖掘算法在数据处理过程具有预先设定最小阈值、时间复杂度高等缺陷,为此采用多阶段挖掘策略实现并行化频繁模式挖掘算法PTFP-Apriori。首先将预处理数据以模式树的形式存储,通过最为频繁的k个模式得到最优阈值。然后根据该值删除预期不能成长为频繁的模式以降低计算规模,并利用弹性分布式数据集RDD完成统计项集支持度计数、候选项集生成的工作。实验分析表明相比于传统的频繁模式挖掘算法,该算法具有更高的效率以及可扩展性。

Under the environment of big data, the frequent pattern mining algorithm Apriori has some defects, includingpresetting minimum threshold and high time complexity when in data processing process. Therefore, the multistage miningstrategy is adopted to realize the parallel frequent pattern mining algorithm(PTFP-Apriori). Firstly, the preprocessed datais stored in a pattern tree, and the optimal threshold is got by the most frequent K model. Subsequently, according to thethreshold, the frequent pattern that can’t grow up to be frequent patterns could be removed to reduce the computing scale.The RDD is used to accomplish the task of itemsets support counting and candidate itemsets generating. The experimentalresults show that the algorithm has higher effectivity and scalability than the traditional algorithm.