diff options
| author | Patrick Wendell <pwendell@gmail.com> | 2013-02-16 15:56:04 -0800 |
|---|---|---|
| committer | Patrick Wendell <pwendell@gmail.com> | 2013-02-19 08:30:32 -0800 |
| commit | 9d49a6b03fb91d516bf40e50f67e87155c69dba1 (patch) | |
| tree | 4b019f70e3ab292d001008ff98f6e020da726eb7 /streaming/src/test/java | |
| parent | 8b9c673fce1c733c7fcd8b978e84f943be9e9e35 (diff) | |
| download | spark-9d49a6b03fb91d516bf40e50f67e87155c69dba1.tar.gz spark-9d49a6b03fb91d516bf40e50f67e87155c69dba1.tar.bz2 spark-9d49a6b03fb91d516bf40e50f67e87155c69dba1.zip | |
Use RDD type for `foreach` operator in Java.
Diffstat (limited to 'streaming/src/test/java')
| -rw-r--r-- | streaming/src/test/java/spark/streaming/JavaAPISuite.java | 1 | ||||
| -rw-r--r-- | streaming/src/test/java/spark/streaming/JavaTestUtils.scala | 5 |
2 files changed, 4 insertions, 2 deletions
diff --git a/streaming/src/test/java/spark/streaming/JavaAPISuite.java b/streaming/src/test/java/spark/streaming/JavaAPISuite.java index 5d510fd89f..4fe2de5a1a 100644 --- a/streaming/src/test/java/spark/streaming/JavaAPISuite.java +++ b/streaming/src/test/java/spark/streaming/JavaAPISuite.java @@ -12,6 +12,7 @@ import org.junit.Test; import scala.Tuple2; import spark.HashPartitioner; import spark.api.java.JavaRDD; +import spark.api.java.JavaRDDLike; import spark.api.java.JavaSparkContext; import spark.api.java.function.*; import spark.storage.StorageLevel; diff --git a/streaming/src/test/java/spark/streaming/JavaTestUtils.scala b/streaming/src/test/java/spark/streaming/JavaTestUtils.scala index 52ea28732a..64a7e7cbf9 100644 --- a/streaming/src/test/java/spark/streaming/JavaTestUtils.scala +++ b/streaming/src/test/java/spark/streaming/JavaTestUtils.scala @@ -31,8 +31,9 @@ trait JavaTestBase extends TestSuiteBase { * Attach a provided stream to it's associated StreamingContext as a * [[spark.streaming.TestOutputStream]]. **/ - def attachTestOutputStream[T, This <: spark.streaming.api.java.JavaDStreamLike[T,This]]( - dstream: JavaDStreamLike[T, This]) = { + def attachTestOutputStream[T, This <: spark.streaming.api.java.JavaDStreamLike[T, This, R], + R <: spark.api.java.JavaRDDLike[T, R]]( + dstream: JavaDStreamLike[T, This, R]) = { implicit val cm: ClassManifest[T] = implicitly[ClassManifest[AnyRef]].asInstanceOf[ClassManifest[T]] val ostream = new TestOutputStream(dstream.dstream, |