code: def test_fpgrowth(self):
      data = [
          ["a", "b", "c"],
          ["a", "b", "d", "e"],
          ["a", "c", "e"],
          ["a", "c", "f"],
      ]
      rdd = self.sc.parallelize(data, 2)
      model1 = FPGrowth.train(rdd, 0.6, 2)
      # use default data partition number when numPartitions is not specified
      model2 = FPGrowth.train(rdd, 0.6)
      self.assertEqual(
          sorted(model1.freqItemsets().collect()),
          sorted(model2.freqItemsets().collect()),
      )
  
imports: import os
  import tempfile
  from shutil import rmtree
  import unittest
  from numpy import array, array_equal
  from py4j.protocol import Py4JJavaError
  from pyspark.mllib.fpm import FPGrowth
  from pyspark.mllib.recommendation import Rating
  from pyspark.mllib.regression import LabeledPoint
  from pyspark.serializers import CPickleSerializer
  from pyspark.testing.mllibutils import MLlibTestCase
  from pyspark.testing.utils import eventually
label_desc: Use image node_id 1 for calling the FPGrowthTest obj's underlying member method code with example usage: obj.test_fpgrowth() without return types