diff options
author | Tathagata Das <tathagata.das1565@gmail.com> | 2012-10-23 16:24:05 -0700 |
---|---|---|
committer | Tathagata Das <tathagata.das1565@gmail.com> | 2012-10-23 16:24:05 -0700 |
commit | 020d6434844b22c2fe611303b338eaf53397c9db (patch) | |
tree | 19d6b96bbdfd7a80ccd83b935df196d0d05e3189 /streaming/src | |
parent | 0e5d9be4dfe0d072db8410fe6d254555bba9367d (diff) | |
download | spark-020d6434844b22c2fe611303b338eaf53397c9db.tar.gz spark-020d6434844b22c2fe611303b338eaf53397c9db.tar.bz2 spark-020d6434844b22c2fe611303b338eaf53397c9db.zip |
Renamed the streaming testsuites.
Diffstat (limited to 'streaming/src')
-rw-r--r-- | streaming/src/test/scala/spark/streaming/BasicOperationsSuite.scala (renamed from streaming/src/test/scala/spark/streaming/DStreamBasicSuite.scala) | 4 | ||||
-rw-r--r-- | streaming/src/test/scala/spark/streaming/CheckpointSuite.scala | 2 | ||||
-rw-r--r-- | streaming/src/test/scala/spark/streaming/TestSuiteBase.scala (renamed from streaming/src/test/scala/spark/streaming/DStreamSuiteBase.scala) | 4 | ||||
-rw-r--r-- | streaming/src/test/scala/spark/streaming/WindowOperationsSuite.scala (renamed from streaming/src/test/scala/spark/streaming/DStreamWindowSuite.scala) | 4 |
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 |