move unit test

clockfly · clockfly · commit e8745e7fd62e · 2016-08-23T11:43:39.000+08:00
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/QuantileSummaries.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/QuantileSummaries.scala
@@ -42,10 +42,10 @@ import org.apache.spark.sql.catalyst.util.QuantileSummaries.Stats
  *              (excluding the head buffer)
  */
 class QuantileSummaries(
-  val compressThreshold: Int,
-  val relativeError: Double,
-  val sampled: Array[Stats] = Array.empty,
-  val count: Long = 0L) extends Serializable {
+    val compressThreshold: Int,
+    val relativeError: Double,
+    val sampled: Array[Stats] = Array.empty,
+    val count: Long = 0L) extends Serializable {
 
   // a buffer of latest samples seen so far
   private val headSampled: ArrayBuffer[Double] = ArrayBuffer.empty
@@ -231,8 +231,8 @@ object QuantileSummaries {
   case class Stats(value: Double, g: Int, delta: Int)
 
   private def compressImmut(
-    currentSamples: IndexedSeq[Stats],
-    mergeThreshold: Double): Array[Stats] = {
+      currentSamples: IndexedSeq[Stats],
+      mergeThreshold: Double): Array[Stats] = {
     if (currentSamples.isEmpty) {
       return Array.empty[Stats]
     }
diff --git a/sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/util/QuantileSummariesSuite.scala b/sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/util/QuantileSummariesSuite.scala
@@ -15,14 +15,13 @@
  * limitations under the License.
  */
 
-package org.apache.spark.sql.execution.stat
+package org.apache.spark.sql.catalyst.util
 
 import scala.util.Random
 
 import org.apache.spark.SparkFunSuite
-import org.apache.spark.sql.catalyst.util.QuantileSummaries
 
-class ApproxQuantileSuite extends SparkFunSuite {
+class QuantileSummariesSuite extends SparkFunSuite {
 
   private val r = new Random(1)
   private val n = 100
@@ -124,5 +123,4 @@ class ApproxQuantileSuite extends SparkFunSuite {
       checkQuantile(0.001, data, s)
     }
   }
-
 }

Original file line number	Diff line number	Diff line change
`@@ -15,14 +15,13 @@`
`15`	`15`	`* limitations under the License.`
`16`	`16`	`*/`
`17`	`17`
`18`		`-package org.apache.spark.sql.execution.stat`
	`18`	`+package org.apache.spark.sql.catalyst.util`
`19`	`19`
`20`	`20`	`import scala.util.Random`
`21`	`21`
`22`	`22`	`import org.apache.spark.SparkFunSuite`
`23`		`-import org.apache.spark.sql.catalyst.util.QuantileSummaries`
`24`	`23`
`25`		`-class ApproxQuantileSuite extends SparkFunSuite {`
	`24`	`+class QuantileSummariesSuite extends SparkFunSuite {`
`26`	`25`
`27`	`26`	`private val r = new Random(1)`
`28`	`27`	`private val n = 100`
`@@ -124,5 +123,4 @@ class ApproxQuantileSuite extends SparkFunSuite {`
`124`	`123`	`checkQuantile(0.001, data, s)`
`125`	`124`	`}`
`126`	`125`	`}`
`127`		`-`
`128`	`126`	`}`