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

initializeForcefully, initializeLogging, initializeLogIfNecessary, initializeLogIfNecessary, isTraceEnabled, 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)