diff options
| author | Tathagata Das <tathagata.das1565@gmail.com> | 2012-09-02 02:35:17 -0700 |
|---|---|---|
| committer | Tathagata Das <tathagata.das1565@gmail.com> | 2012-09-02 02:35:17 -0700 |
| commit | 7419d2c7ea1be9dcc0079dbe6dfd7046f0c549e0 (patch) | |
| tree | 210fa3852c6e4677c8d94b6b05a67d666254aa91 /streaming/src/test/scala | |
| parent | 2d01d38a4199590145551a108903a3ac7cffcceb (diff) | |
| download | spark-7419d2c7ea1be9dcc0079dbe6dfd7046f0c549e0.tar.gz spark-7419d2c7ea1be9dcc0079dbe6dfd7046f0c549e0.tar.bz2 spark-7419d2c7ea1be9dcc0079dbe6dfd7046f0c549e0.zip | |
Added transformRDD DStream operation and TransformedDStream. Added sbt assembly option for streaming project.
Diffstat (limited to 'streaming/src/test/scala')
| -rw-r--r-- | streaming/src/test/scala/spark/streaming/DStreamSuite.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/streaming/src/test/scala/spark/streaming/DStreamSuite.scala b/streaming/src/test/scala/spark/streaming/DStreamSuite.scala index d5eb20b37e..030f351080 100644 --- a/streaming/src/test/scala/spark/streaming/DStreamSuite.scala +++ b/streaming/src/test/scala/spark/streaming/DStreamSuite.scala @@ -105,7 +105,7 @@ class DStreamSuite extends FunSuite with BeforeAndAfter with Logging { Seq(("a", 1), ("b", 1), ("c", 1)), Seq(("a", 2), ("b", 2), ("c", 2)), Seq(("a", 3), ("b", 3), ("c", 3)) - )//.map(array => array.toSeq.map(x => (x._1, new RichInt(x._2)))) + ) val updateStateOp =(s: DStream[String]) => { val updateFunc = (values: Seq[Int], state: RichInt) => { |