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

Import fixup

Browse source
This commit is contained in:
Patrick Wendell 2013-01-17 18:38:30 -08:00
parent 2261e62ee5
commit 70ba994d6d
3 changed files with 0 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -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
/**

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

@ -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._

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

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