Package com.r4tings.recommender.model.measures.similarity

Class RatingSimilarityMeasurer<T extends RatingSimilarityMeasurer<T>>

java.lang.Object

org.apache.spark.ml.PipelineStage

org.apache.spark.ml.Transformer

com.r4tings.recommender.common.ml.AbstractRatingTransformer

com.r4tings.recommender.model.measures.similarity.RatingSimilarityMeasurer<T>

All Implemented Interfaces:

GroupCol, OutputCol, RatingCol, Verbose, java.io.Serializable, org.apache.spark.internal.Logging, org.apache.spark.ml.param.Params, org.apache.spark.ml.util.Identifiable, scala.Serializable

Direct Known Subclasses:

CosineSimilarityMeasurer, EuclideanSimilarityMeasurer, ExtendedJaccardSimilarityMeasurer, JaccardSimilarityMeasurer, ManhattanSimilarityMeasurer, PearsonSimilarityMeasurer, SimpleMatchingSimilarityMeasurer

public abstract class RatingSimilarityMeasurer<T extends RatingSimilarityMeasurer<T>>
extends AbstractRatingTransformer
implements GroupCol

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.spark.internal.Logging

org.apache.spark.internal.Logging.SparkShellLoggingFilter

Constructor Summary

Constructors

Constructor	Description
RatingSimilarityMeasurer(java.lang.String prefix)

Method Summary

Modifier and Type	Method	Description
protected org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>	compute(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> ratingDS, org.apache.spark.sql.Column outputColumn)
protected abstract org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>	execute(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> ratingDS)
Group	getGroup()
java.lang.String	getGroupCol()
java.lang.Object[]	getIds()
java.lang.Boolean	getImputeZero()
org.apache.spark.ml.param.Param<Group>	group()
org.apache.spark.ml.param.Param<java.lang.Object[]>	ids()
org.apache.spark.ml.param.BooleanParam	imputeZero()
protected abstract T	self()
T	setGroup(Group value)
T	setGroupCol(java.lang.String value)
T	setIds(java.lang.Object... value)
T	setImputeZero(java.lang.Boolean value)
T	setItemCol(java.lang.String value)
T	setOutputCol(java.lang.String value)
T	setRatingCol(java.lang.String value)
T	setUserCol(java.lang.String value)
T	setVerbose(java.lang.Boolean value)
org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>	transform(org.apache.spark.sql.Dataset<?> ratings)

Methods inherited from class com.r4tings.recommender.common.ml.AbstractRatingTransformer

copy, getItemCol, getOutputCol, getRatingCol, getUserCol, getVerbose, itemCol, outputCol, ratingCol, transformSchema, uid, userCol, verbose

Methods inherited from class org.apache.spark.ml.Transformer

transform, transform, transform

Methods inherited from class org.apache.spark.ml.PipelineStage

$, clear, copyValues, copyValues$default$2, defaultCopy, defaultParamMap, explainParam, explainParams, extractParamMap, extractParamMap, get, getDefault, getOrDefault, getParam, hasDefault, hasParam, initializeForcefully, initializeLogIfNecessary, initializeLogIfNecessary, initializeLogIfNecessary$default$2, isDefined, isSet, isTraceEnabled, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning, onParamChange, org$apache$spark$internal$Logging$$log_, org$apache$spark$internal$Logging$$log__$eq, org$apache$spark$ml$param$Params$_setter_$defaultParamMap_$eq, org$apache$spark$ml$param$Params$_setter_$paramMap_$eq, paramMap, params, set, set, set, setDefault, setDefault, toString, transformSchema

Methods inherited from class java.lang.Object

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

Constructor Detail

RatingSimilarityMeasurer

public RatingSimilarityMeasurer(java.lang.String prefix)

Method Detail

transform

public final org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> transform(org.apache.spark.sql.Dataset<?> ratings)

Specified by:

transform in class org.apache.spark.ml.Transformer

group

public org.apache.spark.ml.param.Param<Group> group()

Specified by:

group in interface GroupCol

imputeZero

public org.apache.spark.ml.param.BooleanParam imputeZero()

ids

public org.apache.spark.ml.param.Param<java.lang.Object[]> ids()

getGroup

public Group getGroup()

Specified by:

getGroup in interface GroupCol

getGroupCol

public java.lang.String getGroupCol()

Specified by:

getGroupCol in interface GroupCol

getImputeZero

public java.lang.Boolean getImputeZero()

getIds

public java.lang.Object[] getIds()

setVerbose

public T setVerbose(java.lang.Boolean value)

Specified by:

setVerbose in interface Verbose

setOutputCol

public T setOutputCol(java.lang.String value)

Specified by:

setOutputCol in interface OutputCol

setUserCol

public T setUserCol(java.lang.String value)

Specified by:

setUserCol in interface RatingCol

setItemCol

public T setItemCol(java.lang.String value)

Specified by:

setItemCol in interface RatingCol

setRatingCol

public T setRatingCol(java.lang.String value)

Specified by:

setRatingCol in interface RatingCol

setGroup

public T setGroup(Group value)

Specified by:

setGroup in interface GroupCol

setGroupCol

public T setGroupCol(java.lang.String value)

Specified by:

setGroupCol in interface GroupCol

setImputeZero

public T setImputeZero(java.lang.Boolean value)

setIds

public T setIds(java.lang.Object... value)

compute

protected org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> compute(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> ratingDS,
                                                                         org.apache.spark.sql.Column outputColumn)

self

protected abstract T self()

execute

protected abstract org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> execute(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> ratingDS)