Changed logging behavior

xiliu82 · Jul 10, 2014 · fd31e03 · fd31e03
1 parent 453974e
commit fd31e03
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/mllib/src/main/scala/org/apache/spark/mllib/regression/StreamingRegression.scala b/mllib/src/main/scala/org/apache/spark/mllib/regression/StreamingRegression.scala
@@ -43,10 +43,8 @@ abstract class StreamingRegression[M <: GeneralizedLinearModel, A <: Generalized
   /** The algorithm to use for updating. */
   val algorithm: A
 
-  /** Log the latest model parameters and return the model. */
+  /** Return the latest model. */
   def latest(): M = {
-    logInfo("Latest model: weights, %s".format(model.weights.toString))
-    logInfo("Latest model: intercept, %s".format(model.intercept.toString))
     model
   }
 
@@ -65,7 +63,8 @@ abstract class StreamingRegression[M <: GeneralizedLinearModel, A <: Generalized
           model = algorithm.run(rdd, model.weights)
           logInfo("Model updated")
         }
-        this.latest()
+        logInfo("Current model: weights, %s".format(model.weights.toString))
+        logInfo("Current model: intercept, %s".format(model.intercept.toString))
     }
   }