Package com.r4tings.recommender.data.normalize

Class ZScoreNormalizer

java.lang.Object

org.apache.spark.ml.PipelineStage

org.apache.spark.ml.Transformer

com.r4tings.recommender.common.ml.AbstractRatingTransformer

com.r4tings.recommender.data.normalize.RatingNormalizer<ZScoreNormalizer>

com.r4tings.recommender.data.normalize.ZScoreNormalizer

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

public class ZScoreNormalizer
extends RatingNormalizer<ZScoreNormalizer>

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
ZScoreNormalizer()

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)
protected org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>	compute(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> ratingDS, java.lang.String groupCol)
protected ZScoreNormalizer	self()
ZScoreNormalizer	setGroup(Group value)
ZScoreNormalizer	setGroupCol(java.lang.String value)
ZScoreNormalizer	setVerbose(java.lang.Boolean value)

Methods inherited from class com.r4tings.recommender.data.normalize.RatingNormalizer

getGroup, getGroupCol, getOutputCol, group, scale, setItemCol, setOutputCol, setRatingCol, setUserCol, transform

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

copy, getItemCol, 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

ZScoreNormalizer

public ZScoreNormalizer()

Method Detail

self

protected ZScoreNormalizer self()

Specified by:

self in class RatingNormalizer<ZScoreNormalizer>

compute

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

Specified by:

compute in class RatingNormalizer<ZScoreNormalizer>

compute

protected org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> compute(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> ratingDS,
                                                                         java.lang.String groupCol)

Specified by:

compute in class RatingNormalizer<ZScoreNormalizer>

setGroup

public ZScoreNormalizer setGroup(Group value)

Specified by:

setGroup in interface GroupCol

Overrides:

setGroup in class RatingNormalizer<ZScoreNormalizer>

setGroupCol

public ZScoreNormalizer setGroupCol(java.lang.String value)

Specified by:

setGroupCol in interface GroupCol

Overrides:

setGroupCol in class RatingNormalizer<ZScoreNormalizer>

setVerbose

public ZScoreNormalizer setVerbose(java.lang.Boolean value)

Specified by:

setVerbose in interface Verbose

Overrides:

setVerbose in class RatingNormalizer<ZScoreNormalizer>