diff options
| author | seanm <sean.mcnamara@webtrends.com> | 2013-04-15 12:54:55 -0600 |
|---|---|---|
| committer | seanm <sean.mcnamara@webtrends.com> | 2013-04-15 12:54:55 -0600 |
| commit | b42d68c8ce9f63513969297b65f4b5a2b06e6078 (patch) | |
| tree | fbdb34a85e14e73afd3575fbca957d5cfe8a85fc /streaming/src/test | |
| parent | 8ac9efba5a435443be9abf8ebbe867806d42c9db (diff) | |
| download | spark-b42d68c8ce9f63513969297b65f4b5a2b06e6078.tar.gz spark-b42d68c8ce9f63513969297b65f4b5a2b06e6078.tar.bz2 spark-b42d68c8ce9f63513969297b65f4b5a2b06e6078.zip | |
fixing Spark Streaming count() so that 0 will be emitted when there is nothing to count
Diffstat (limited to 'streaming/src/test')
| -rw-r--r-- | streaming/src/test/scala/spark/streaming/BasicOperationsSuite.scala | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/streaming/src/test/scala/spark/streaming/BasicOperationsSuite.scala b/streaming/src/test/scala/spark/streaming/BasicOperationsSuite.scala index 8fce91853c..168e1b7a55 100644 --- a/streaming/src/test/scala/spark/streaming/BasicOperationsSuite.scala +++ b/streaming/src/test/scala/spark/streaming/BasicOperationsSuite.scala @@ -90,9 +90,9 @@ class BasicOperationsSuite extends TestSuiteBase { test("count") { testOperation( - Seq(1 to 1, 1 to 2, 1 to 3, 1 to 4), + Seq(Seq(), 1 to 1, 1 to 2, 1 to 3, 1 to 4), (s: DStream[Int]) => s.count(), - Seq(Seq(1L), Seq(2L), Seq(3L), Seq(4L)) + Seq(Seq(0L), Seq(1L), Seq(2L), Seq(3L), Seq(4L)) ) } |