org.apache.spark.mllib.fpm

Class AssociationRules

java.lang.Object

org.apache.spark.mllib.fpm.AssociationRules

All Implemented Interfaces:

java.io.Serializable

public class AssociationRules
extends java.lang.Object
implements scala.Serializable

:: Experimental ::

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> :: Experimental ::

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
protected static void	initializeLogIfNecessary(boolean isInterpreter)
protected static boolean	isTraceEnabled()
protected static org.slf4j.Logger	log()
protected static void	logDebug(scala.Function0<java.lang.String> msg)
protected static void	logDebug(scala.Function0<java.lang.String> msg, java.lang.Throwable throwable)
protected static void	logError(scala.Function0<java.lang.String> msg)
protected static void	logError(scala.Function0<java.lang.String> msg, java.lang.Throwable throwable)
protected static void	logInfo(scala.Function0<java.lang.String> msg)
protected static void	logInfo(scala.Function0<java.lang.String> msg, java.lang.Throwable throwable)
protected static java.lang.String	logName()
protected static void	logTrace(scala.Function0<java.lang.String> msg)
protected static void	logTrace(scala.Function0<java.lang.String> msg, java.lang.Throwable throwable)
protected static void	logWarning(scala.Function0<java.lang.String> msg)
protected static void	logWarning(scala.Function0<java.lang.String> msg, java.lang.Throwable throwable)
<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.
AssociationRules	setMinConfidence(double minConfidence) Sets the minimal confidence (default: 0.8).

Methods inherited from class java.lang.Object

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

Constructor Detail

AssociationRules

public AssociationRules()

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

Method Detail

logName

protected static java.lang.String logName()

log

protected static org.slf4j.Logger log()

logInfo

protected static void logInfo(scala.Function0<java.lang.String> msg)

logDebug

protected static void logDebug(scala.Function0<java.lang.String> msg)

logTrace

protected static void logTrace(scala.Function0<java.lang.String> msg)

logWarning

protected static void logWarning(scala.Function0<java.lang.String> msg)

logError

protected static void logError(scala.Function0<java.lang.String> msg)

logInfo

protected static void logInfo(scala.Function0<java.lang.String> msg,
           java.lang.Throwable throwable)

logDebug

protected static void logDebug(scala.Function0<java.lang.String> msg,
            java.lang.Throwable throwable)

logTrace

protected static void logTrace(scala.Function0<java.lang.String> msg,
            java.lang.Throwable throwable)

logWarning

protected static void logWarning(scala.Function0<java.lang.String> msg,
              java.lang.Throwable throwable)

logError

protected static void logError(scala.Function0<java.lang.String> msg,
            java.lang.Throwable throwable)

isTraceEnabled

protected static boolean isTraceEnabled()

initializeLogIfNecessary

protected static void initializeLogIfNecessary(boolean isInterpreter)

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 Set[Rule[Item] containing the association rules.

run

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

Java-friendly version of run.