diff --git a/mllib/src/main/scala/org/apache/spark/mllib/regression/StreamingLinearRegression.scala b/mllib/src/main/scala/org/apache/spark/mllib/regression/StreamingLinearRegression.scala index 225c9e5b00f24..7b16a94af913c 100644 --- a/mllib/src/main/scala/org/apache/spark/mllib/regression/StreamingLinearRegression.scala +++ b/mllib/src/main/scala/org/apache/spark/mllib/regression/StreamingLinearRegression.scala @@ -17,8 +17,8 @@ package org.apache.spark.mllib.regression -import org.apache.spark.mllib.linalg.Vectors import org.apache.spark.annotation.Experimental +import org.apache.spark.mllib.linalg.Vectors /** * Train or predict a linear regression model on streaming data. Training uses 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 index 3ccfe1e3caf14..901db687c56b7 100644 --- a/mllib/src/main/scala/org/apache/spark/mllib/regression/StreamingRegression.scala +++ b/mllib/src/main/scala/org/apache/spark/mllib/regression/StreamingRegression.scala @@ -17,8 +17,8 @@ package org.apache.spark.mllib.regression -import org.apache.spark.Logging import org.apache.spark.annotation.{Experimental, DeveloperApi} +import org.apache.spark.Logging import org.apache.spark.streaming.dstream.DStream /** diff --git a/mllib/src/main/scala/org/apache/spark/mllib/util/MLStreamingUtils.scala b/mllib/src/main/scala/org/apache/spark/mllib/util/MLStreamingUtils.scala index 6bc7b5250b307..b90adca8b24b5 100644 --- a/mllib/src/main/scala/org/apache/spark/mllib/util/MLStreamingUtils.scala +++ b/mllib/src/main/scala/org/apache/spark/mllib/util/MLStreamingUtils.scala @@ -18,9 +18,9 @@ package org.apache.spark.mllib.util import org.apache.spark.annotation.Experimental +import org.apache.spark.mllib.regression.{LabeledPointParser, LabeledPoint} import org.apache.spark.streaming.dstream.DStream import org.apache.spark.streaming.StreamingContext -import org.apache.spark.mllib.regression.{LabeledPointParser, LabeledPoint} /** * Helper methods to load streaming data for MLLib applications. diff --git a/mllib/src/test/scala/org/apache/spark/mllib/regression/StreamingLinearRegressionSuite.scala b/mllib/src/test/scala/org/apache/spark/mllib/regression/StreamingLinearRegressionSuite.scala index 9b9d9678df644..8c1a8722761b1 100644 --- a/mllib/src/test/scala/org/apache/spark/mllib/regression/StreamingLinearRegressionSuite.scala +++ b/mllib/src/test/scala/org/apache/spark/mllib/regression/StreamingLinearRegressionSuite.scala @@ -19,14 +19,15 @@ package org.apache.spark.mllib.regression import java.io.File -import com.google.common.io.Files +import scala.collection.mutable.ArrayBuffer + import org.apache.commons.io.FileUtils +import com.google.common.io.Files import org.scalatest.FunSuite + +import org.apache.spark.mllib.util.{MLStreamingUtils, LinearDataGenerator, LocalSparkContext} import org.apache.spark.SparkConf import org.apache.spark.streaming.{Milliseconds, Seconds, StreamingContext} -import org.apache.spark.mllib.util.{MLStreamingUtils, LinearDataGenerator, LocalSparkContext} - -import scala.collection.mutable.ArrayBuffer class StreamingLinearRegressionSuite extends FunSuite {