@@ -485,8 +485,8 @@ class ALS(@Since("1.4.0") override val uid: String) extends Estimator[ALSModel]
485485 alpha = $(alpha), nonnegative = $(nonnegative),
486486 intermediateRDDStorageLevel = StorageLevel .fromString($(intermediateStorageLevel)),
487487 finalRDDStorageLevel = StorageLevel .fromString($(finalStorageLevel)),
488- threshold = $(threshold), checkpointInterval = $(checkpointInterval),
489- seed = $(seed))
488+ checkpointInterval = $(checkpointInterval),
489+ seed = $(seed), threshold = $(threshold) )
490490 val userDF = userFactors.toDF(" id" , " features" )
491491 val itemDF = itemFactors.toDF(" id" , " features" )
492492 val model = new ALSModel (uid, $(rank), userDF, itemDF).setParent(this )
@@ -721,9 +721,9 @@ object ALS extends DefaultParamsReadable[ALS] with Logging {
721721 nonnegative : Boolean = false ,
722722 intermediateRDDStorageLevel : StorageLevel = StorageLevel .MEMORY_AND_DISK ,
723723 finalRDDStorageLevel : StorageLevel = StorageLevel .MEMORY_AND_DISK ,
724- threshold : Int = 1024 ,
725724 checkpointInterval : Int = 10 ,
726- seed : Long = 0L )(
725+ seed : Long = 0L ,
726+ threshold : Int = 1024 )(
727727 implicit ord : Ordering [ID ]): (RDD [(ID , Array [Float ])], RDD [(ID , Array [Float ])]) = {
728728 require(intermediateRDDStorageLevel != StorageLevel .NONE ,
729729 " ALS is not designed to run without persisting intermediate RDDs." )
0 commit comments