diff options
author | Patrick Wendell <pwendell@gmail.com> | 2013-02-19 08:44:20 -0800 |
---|---|---|
committer | Patrick Wendell <pwendell@gmail.com> | 2013-02-19 08:44:20 -0800 |
commit | 041c19e5f0309e7a667faab5fee9f9081db58237 (patch) | |
tree | 8686b648576ba8c375adbee5d35abb718efcaac5 /streaming/src | |
parent | fed1122d74c9d92ce26c28b0bf429e556dcc9bdd (diff) | |
download | spark-041c19e5f0309e7a667faab5fee9f9081db58237.tar.gz spark-041c19e5f0309e7a667faab5fee9f9081db58237.tar.bz2 spark-041c19e5f0309e7a667faab5fee9f9081db58237.zip |
Small changes that were missing in merge
Diffstat (limited to 'streaming/src')
-rw-r--r-- | streaming/src/main/scala/spark/streaming/api/java/JavaPairDStream.scala | 1 | ||||
-rw-r--r-- | streaming/src/test/java/spark/streaming/JavaAPISuite.java | 1 |
2 files changed, 2 insertions, 0 deletions
diff --git a/streaming/src/main/scala/spark/streaming/api/java/JavaPairDStream.scala b/streaming/src/main/scala/spark/streaming/api/java/JavaPairDStream.scala index de3e802300..c1c8783559 100644 --- a/streaming/src/main/scala/spark/streaming/api/java/JavaPairDStream.scala +++ b/streaming/src/main/scala/spark/streaming/api/java/JavaPairDStream.scala @@ -15,6 +15,7 @@ import org.apache.hadoop.conf.Configuration import spark.api.java.JavaPairRDD import spark.storage.StorageLevel import com.google.common.base.Optional +import spark.RDD class JavaPairDStream[K, V](val dstream: DStream[(K, V)])( implicit val kManifiest: ClassManifest[K], diff --git a/streaming/src/test/java/spark/streaming/JavaAPISuite.java b/streaming/src/test/java/spark/streaming/JavaAPISuite.java index 9be680dbdc..53fac14386 100644 --- a/streaming/src/test/java/spark/streaming/JavaAPISuite.java +++ b/streaming/src/test/java/spark/streaming/JavaAPISuite.java @@ -13,6 +13,7 @@ import scala.Tuple2; import spark.HashPartitioner; import spark.api.java.JavaRDD; import spark.api.java.JavaRDDLike; +import spark.api.java.JavaPairRDD; import spark.api.java.JavaSparkContext; import spark.api.java.function.*; import spark.storage.StorageLevel; |