ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Small changes that were missing in merge

Browse source
This commit is contained in:
Patrick Wendell 2013-02-19 08:44:20 -08:00
parent fed1122d74
commit 041c19e5f0
2 changed files with 2 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
streaming/src/main/scala/spark/streaming/api/java/JavaPairDStream.scala
View file

@ -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],

1
streaming/src/test/java/spark/streaming/JavaAPISuite.java
View file

@ -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;