;
associationRules:生成的可信度大于minConfidence的关联规则,同样是DataFrame格式;
transform;
from pyspark.ml.fpm import FPGrowth...spark.createDataFrame([
(0, [1, 2, 5]),
(1, [1, 2, 3, 5]),
(2, [1, 2])
], ["id", "items"])
fpGrowth...= FPGrowth(itemsCol="items", minSupport=0.5, minConfidence=0.6)
model = fpGrowth.fit(df)
# Display