Renamed the streaming testsuites.

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)

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"
 

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]"
 

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