From 5004eec37c01db3b96d665b0d9606002af209eda Mon Sep 17 00:00:00 2001
From: Patrick Wendell <pwendell@gmail.com>
Date: Wed, 9 Jan 2013 22:02:07 -0800
Subject: Import Cleanup

---
 .../src/main/scala/spark/streaming/api/java/JavaPairDStream.scala     | 2 +-
 .../main/scala/spark/streaming/api/java/JavaStreamingContext.scala    | 1 -
 streaming/src/test/scala/spark/streaming/JavaAPISuite.java            | 4 ++--
 3 files changed, 3 insertions(+), 4 deletions(-)

(limited to 'streaming/src')

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 f36b870046..a19a476724 100644
--- a/streaming/src/main/scala/spark/streaming/api/java/JavaPairDStream.scala
+++ b/streaming/src/main/scala/spark/streaming/api/java/JavaPairDStream.scala
@@ -11,7 +11,7 @@ import spark.Partitioner
 import org.apache.hadoop.mapred.{JobConf, OutputFormat}
 import org.apache.hadoop.mapreduce.{OutputFormat => NewOutputFormat}
 import org.apache.hadoop.conf.Configuration
-import spark.api.java.{JavaPairRDD, JavaRDD}
+import spark.api.java.JavaPairRDD
 import spark.storage.StorageLevel
 
 class JavaPairDStream[K, V](val dstream: DStream[(K, V)])(
diff --git a/streaming/src/main/scala/spark/streaming/api/java/JavaStreamingContext.scala b/streaming/src/main/scala/spark/streaming/api/java/JavaStreamingContext.scala
index f96b4fbd7d..37ce037d5c 100644
--- a/streaming/src/main/scala/spark/streaming/api/java/JavaStreamingContext.scala
+++ b/streaming/src/main/scala/spark/streaming/api/java/JavaStreamingContext.scala
@@ -62,7 +62,6 @@ class JavaStreamingContext(val ssc: StreamingContext) {
       converter: JFunction[InputStream, java.lang.Iterable[T]],
       storageLevel: StorageLevel)
   : JavaDStream[T] = {
-    import scala.collection.JavaConverters._
     def fn = (x: InputStream) => converter.apply(x).toIterator
     implicit val cmt: ClassManifest[T] =
       implicitly[ClassManifest[AnyRef]].asInstanceOf[ClassManifest[T]]
diff --git a/streaming/src/test/scala/spark/streaming/JavaAPISuite.java b/streaming/src/test/scala/spark/streaming/JavaAPISuite.java
index fa3a5801dd..9e8438d04c 100644
--- a/streaming/src/test/scala/spark/streaming/JavaAPISuite.java
+++ b/streaming/src/test/scala/spark/streaming/JavaAPISuite.java
@@ -1,8 +1,8 @@
 package spark.streaming;
 
 import com.google.common.collect.Lists;
-import org.junit.Assert;
 import org.junit.After;
+import org.junit.Assert;
 import org.junit.Before;
 import org.junit.Test;
 import scala.Tuple2;
@@ -12,10 +12,10 @@ import spark.api.java.function.FlatMapFunction;
 import spark.api.java.function.Function;
 import spark.api.java.function.Function2;
 import spark.api.java.function.PairFunction;
-import spark.streaming.JavaTestUtils;
 import spark.streaming.api.java.JavaDStream;
 import spark.streaming.api.java.JavaPairDStream;
 import spark.streaming.api.java.JavaStreamingContext;
+import spark.streaming.JavaTestUtils;
 
 import java.io.Serializable;
 import java.util.*;
-- 
cgit v1.2.3