org.apache.spark.mllib.fpm

Class AssociationRules

Object

org.apache.spark.mllib.fpm.AssociationRules

All Implemented Interfaces:

java.io.Serializable, Logging

public class AssociationRules
extends Object
implements Logging, scala.Serializable

Generates association rules from a RDD[FreqItemset[Item}. This method only generates association rules which have a single item as the consequent.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AssociationRules.Rule<Item> An association rule between sets of items.

Constructor Summary

Constructors

Constructor and Description
AssociationRules() Constructs a default instance with default parameters {minConfidence = 0.8}.

Method Summary

Modifier and Type	Method and Description
<Item> JavaRDD<AssociationRules.Rule<Item>>	run(JavaRDD<FPGrowth.FreqItemset<Item>> freqItemsets) Java-friendly version of run.
<Item> RDD<AssociationRules.Rule<Item>>	run(RDD<FPGrowth.FreqItemset<Item>> freqItemsets, scala.reflect.ClassTag<Item> evidence$1) Computes the association rules with confidence above minConfidence.
<Item> RDD<AssociationRules.Rule<Item>>	run(RDD<FPGrowth.FreqItemset<Item>> freqItemsets, scala.collection.Map<Item,Object> itemSupport, scala.reflect.ClassTag<Item> evidence$2) Computes the association rules with confidence above minConfidence.
AssociationRules	setMinConfidence(double minConfidence) Sets the minimal confidence (default: 0.8).

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.spark.internal.Logging

initializeLogging, initializeLogIfNecessary, initializeLogIfNecessary, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning

Constructor Detail

AssociationRules

public AssociationRules()

Constructs a default instance with default parameters {minConfidence = 0.8}.

Method Detail

setMinConfidence

public AssociationRules setMinConfidence(double minConfidence)

Sets the minimal confidence (default: 0.8).

Parameters:

minConfidence - (undocumented)

Returns:

(undocumented)

run

public <Item> RDD<AssociationRules.Rule<Item>> run(RDD<FPGrowth.FreqItemset<Item>> freqItemsets,
                                                   scala.reflect.ClassTag<Item> evidence$1)

Computes the association rules with confidence above minConfidence.

Parameters:

freqItemsets - frequent itemset model obtained from FPGrowth

evidence$1 - (undocumented)

Returns:

a RDD[Rule[Item} containing the association rules.

run

public <Item> RDD<AssociationRules.Rule<Item>> run(RDD<FPGrowth.FreqItemset<Item>> freqItemsets,
                                                   scala.collection.Map<Item,Object> itemSupport,
                                                   scala.reflect.ClassTag<Item> evidence$2)

Computes the association rules with confidence above minConfidence.

Parameters:

freqItemsets - frequent itemset model obtained from FPGrowth

itemSupport - map containing an item and its support

evidence$2 - (undocumented)

Returns:

a RDD[Rule[Item} containing the association rules. The rules will be able to compute also the lift metric.

run

public <Item> JavaRDD<AssociationRules.Rule<Item>> run(JavaRDD<FPGrowth.FreqItemset<Item>> freqItemsets)

Java-friendly version of run.

Parameters:

freqItemsets - (undocumented)

Returns:

(undocumented)