diff options
| author | Josh Rosen <joshrosen@eecs.berkeley.edu> | 2013-08-12 18:55:02 -0700 |
|---|---|---|
| committer | Josh Rosen <joshrosen@eecs.berkeley.edu> | 2013-08-12 18:55:02 -0700 |
| commit | cf08bb7a3e0596fe502fa618fdd6958772ebbeb5 (patch) | |
| tree | cfae15e18d863dac598778946344a9c68d83d01f /core | |
| parent | d7f78b443b7c31b4db4eabb106801dc4a1866db7 (diff) | |
| download | spark-cf08bb7a3e0596fe502fa618fdd6958772ebbeb5.tar.gz spark-cf08bb7a3e0596fe502fa618fdd6958772ebbeb5.tar.bz2 spark-cf08bb7a3e0596fe502fa618fdd6958772ebbeb5.zip | |
Fix import organization.
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/spark/api/java/JavaPairRDD.scala | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/core/src/main/scala/spark/api/java/JavaPairRDD.scala b/core/src/main/scala/spark/api/java/JavaPairRDD.scala index 6e00ef955a..ff12e8b76c 100644 --- a/core/src/main/scala/spark/api/java/JavaPairRDD.scala +++ b/core/src/main/scala/spark/api/java/JavaPairRDD.scala @@ -23,6 +23,7 @@ import java.util.Comparator import scala.Tuple2 import scala.collection.JavaConversions._ +import com.google.common.base.Optional import org.apache.hadoop.io.compress.CompressionCodec import org.apache.hadoop.mapred.JobConf import org.apache.hadoop.mapred.OutputFormat @@ -41,8 +42,6 @@ import spark.Partitioner._ import spark.RDD import spark.SparkContext.rddToPairRDDFunctions -import com.google.common.base.Optional - class JavaPairRDD[K, V](val rdd: RDD[(K, V)])(implicit val kManifest: ClassManifest[K], implicit val vManifest: ClassManifest[V]) extends JavaRDDLike[(K, V), JavaPairRDD[K, V]] { |