aboutsummaryrefslogtreecommitdiff
path: root/streaming/src
diff options
context:
space:
mode:
authorPatrick Wendell <pwendell@gmail.com>2013-01-17 18:38:30 -0800
committerPatrick Wendell <pwendell@gmail.com>2013-01-17 18:41:59 -0800
commit70ba994d6d6f9e62269168e6a8a61ffce736a4d2 (patch)
tree6dcada9f06a337f4f195aefeba7ed57d8267d554 /streaming/src
parent2261e62ee52495599b7a8717884e878497d343ea (diff)
downloadspark-70ba994d6d6f9e62269168e6a8a61ffce736a4d2.tar.gz
spark-70ba994d6d6f9e62269168e6a8a61ffce736a4d2.tar.bz2
spark-70ba994d6d6f9e62269168e6a8a61ffce736a4d2.zip
Import fixup
Diffstat (limited to 'streaming/src')
-rw-r--r--streaming/src/main/scala/spark/streaming/api/java/JavaDStream.scala1
-rw-r--r--streaming/src/main/scala/spark/streaming/api/java/JavaStreamingContext.scala1
-rw-r--r--streaming/src/test/scala/spark/streaming/JavaAPISuite.java1
3 files changed, 0 insertions, 3 deletions
diff --git a/streaming/src/main/scala/spark/streaming/api/java/JavaDStream.scala b/streaming/src/main/scala/spark/streaming/api/java/JavaDStream.scala
index e21e54d3e5..2e7466b16c 100644
--- a/streaming/src/main/scala/spark/streaming/api/java/JavaDStream.scala
+++ b/streaming/src/main/scala/spark/streaming/api/java/JavaDStream.scala
@@ -3,7 +3,6 @@ package spark.streaming.api.java
import spark.streaming.{Duration, Time, DStream}
import spark.api.java.function.{Function => JFunction}
import spark.api.java.JavaRDD
-import java.util.{List => JList}
import spark.storage.StorageLevel
/**
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 7e1c2a999f..accac82e09 100644
--- a/streaming/src/main/scala/spark/streaming/api/java/JavaStreamingContext.scala
+++ b/streaming/src/main/scala/spark/streaming/api/java/JavaStreamingContext.scala
@@ -1,7 +1,6 @@
package spark.streaming.api.java
import scala.collection.JavaConversions._
-import java.util.{List => JList}
import java.lang.{Long => JLong, Integer => JInt}
import spark.streaming._
diff --git a/streaming/src/test/scala/spark/streaming/JavaAPISuite.java b/streaming/src/test/scala/spark/streaming/JavaAPISuite.java
index 8a63e8cd3f..374793b57e 100644
--- a/streaming/src/test/scala/spark/streaming/JavaAPISuite.java
+++ b/streaming/src/test/scala/spark/streaming/JavaAPISuite.java
@@ -20,7 +20,6 @@ import spark.streaming.api.java.JavaStreamingContext;
import spark.streaming.JavaTestUtils;
import spark.streaming.JavaCheckpointTestUtils;
import spark.streaming.dstream.KafkaPartitionKey;
-import sun.org.mozilla.javascript.annotations.JSFunction;
import java.io.*;
import java.util.*;