public static void main(String[] args) {



    SparkConf sparkConf = new SparkConf().setAppName("JavaAssociationRulesExample");

    JavaSparkContext sc = new JavaSparkContext(sparkConf);



    JavaRDD<FPGrowth.FreqItemset<String>> freqItemsets = sc.parallelize(Arrays.asList(

      new FreqItemset<String>(new String[] {"a"}, 15L),

      new FreqItemset<String>(new String[] {"b"}, 35L),

      new FreqItemset<String>(new String[] {"a", "b"}, 12L)

    ));



    AssociationRules arules = new AssociationRules()

      .setMinConfidence(0.8);

    JavaRDD<AssociationRules.Rule<String>> results = arules.run(freqItemsets);



    for (AssociationRules.Rule<String> rule : results.collect()) {

      System.out.println(

        rule.javaAntecedent() + " => " + rule.javaConsequent() + ", " + rule.confidence());

    }

  }