Package com.r4tings.recommender.data.normalize

Class MinMaxNormalizer

    • Nested Class Summary

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

        org.apache.spark.internal.Logging.SparkShellLoggingFilter

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      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)  
      java.lang.Double getLower()  
      java.lang.Double getUpper()  
      org.apache.spark.ml.param.DoubleParam lower()  
      protected MinMaxNormalizer self()  
      MinMaxNormalizer setLower​(java.lang.Double value)  
      MinMaxNormalizer setUpper​(java.lang.Double value)  
      org.apache.spark.ml.param.DoubleParam upper()  

      • 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

      • MinMaxNormalizer

        public MinMaxNormalizer()

    • Method Detail

      • 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<MinMaxNormalizer>

      • 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<MinMaxNormalizer>

      • lower

        public org.apache.spark.ml.param.DoubleParam lower()

      • upper

        public org.apache.spark.ml.param.DoubleParam upper()

      • getLower

        public java.lang.Double getLower()

      • getUpper

        public java.lang.Double getUpper()