Renamed the streaming testsuites.

4 files changed, 8 insertions, 6 deletions

diff --git a/streaming/src/test/scala/spark/streaming/DStreamBasicSuite.scala b/streaming/src/test/scala/spark/streaming/BasicOperationsSuite.scala
index 290a216797..d0aaac0f2e 100644
--- a/streaming/src/test/scala/spark/streaming/DStreamBasicSuite.scala
+++ b/streaming/src/test/scala/spark/streaming/BasicOperationsSuite.scala
@@ -4,7 +4,9 @@ import spark.streaming.StreamingContext._
 import scala.runtime.RichInt
 import util.ManualClock
 
-class DStreamBasicSuite extends DStreamSuiteBase {
+class BasicOperationsSuite extends TestSuiteBase {
+
+  override def framework() = "BasicOperationsSuite"
 
   test("map") {
     val input = Seq(1 to 4, 5 to 8, 9 to 12)
diff --git a/streaming/src/test/scala/spark/streaming/CheckpointSuite.scala b/streaming/src/test/scala/spark/streaming/CheckpointSuite.scala
index 061b331a16..6dcedcf463 100644
--- a/streaming/src/test/scala/spark/streaming/CheckpointSuite.scala
+++ b/streaming/src/test/scala/spark/streaming/CheckpointSuite.scala
@@ -3,7 +3,7 @@ package spark.streaming
 import spark.streaming.StreamingContext._
 import java.io.File
 
-class CheckpointSuite extends DStreamSuiteBase {
+class CheckpointSuite extends TestSuiteBase {
 
   override def framework() = "CheckpointSuite"
 
diff --git a/streaming/src/test/scala/spark/streaming/DStreamSuiteBase.scala b/streaming/src/test/scala/spark/streaming/TestSuiteBase.scala
index 2a4b37c965..c1b7772e7b 100644
--- a/streaming/src/test/scala/spark/streaming/DStreamSuiteBase.scala
+++ b/streaming/src/test/scala/spark/streaming/TestSuiteBase.scala
@@ -33,11 +33,11 @@ class TestOutputStream[T: ClassManifest](parent: DStream[T], val output: ArrayBu
     output += collected
   })
 
-trait DStreamSuiteBase extends FunSuite with Logging {
+trait TestSuiteBase extends FunSuite with Logging {
 
   System.setProperty("spark.streaming.clock", "spark.streaming.util.ManualClock")
 
-  def framework() = "DStreamSuiteBase"
+  def framework() = "TestSuiteBase"
 
   def master() = "local[2]"
 
diff --git a/streaming/src/test/scala/spark/streaming/DStreamWindowSuite.scala b/streaming/src/test/scala/spark/streaming/WindowOperationsSuite.scala
index cfcab6298d..90d67844bb 100644
--- a/streaming/src/test/scala/spark/streaming/DStreamWindowSuite.scala
+++ b/streaming/src/test/scala/spark/streaming/WindowOperationsSuite.scala
@@ -2,9 +2,9 @@ package spark.streaming
 
 import spark.streaming.StreamingContext._
 
-class DStreamWindowSuite extends DStreamSuiteBase {
+class WindowOperationsSuite extends TestSuiteBase {
 
-  override def framework() = "DStreamWindowSuite"
+  override def framework() = "WindowOperationsSuite"
 
   override def maxWaitTimeMillis() = 20000