[SPARK-13583][CORE][STREAMING] Remove unused imports and add checkstyle rule
## What changes were proposed in this pull request? After SPARK-6990, `dev/lint-java` keeps Java code healthy and helps PR review by saving much time. This issue aims remove unused imports from Java/Scala code and add `UnusedImports` checkstyle rule to help developers. ## How was this patch tested? ``` ./dev/lint-java ./build/sbt compile ``` Author: Dongjoon Hyun <[email protected]> Closes #11438 from dongjoon-hyun/SPARK-13583. Project: http://git-wip-us.apache.org/repos/asf/bahir/repo Commit: http://git-wip-us.apache.org/repos/asf/bahir/commit/1d9e8910 Tree: http://git-wip-us.apache.org/repos/asf/bahir/tree/1d9e8910 Diff: http://git-wip-us.apache.org/repos/asf/bahir/diff/1d9e8910 Branch: refs/heads/master Commit: 1d9e89108b86e96429a7f1d835a823a74d299830 Parents: a784af6 Author: Dongjoon Hyun <[email protected]> Authored: Thu Mar 3 10:12:32 2016 +0000 Committer: Sean Owen <[email protected]> Committed: Thu Mar 3 10:12:32 2016 +0000 ---------------------------------------------------------------------- .../apache/spark/examples/streaming/akka/ActorWordCount.scala | 1 - .../scala/org/apache/spark/streaming/mqtt/MQTTStreamSuite.scala | 2 +- .../spark/examples/streaming/twitter/TwitterAlgebirdCMS.scala | 1 - .../spark/examples/streaming/twitter/TwitterPopularTags.scala | 1 - .../scala/org/apache/spark/streaming/twitter/TwitterUtils.scala | 4 ++-- .../apache/spark/examples/streaming/zeromq/ZeroMQWordCount.scala | 3 +-- 6 files changed, 4 insertions(+), 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/bahir/blob/1d9e8910/streaming-akka/examples/src/main/scala/org/apache/spark/examples/streaming/akka/ActorWordCount.scala ---------------------------------------------------------------------- diff --git a/streaming-akka/examples/src/main/scala/org/apache/spark/examples/streaming/akka/ActorWordCount.scala b/streaming-akka/examples/src/main/scala/org/apache/spark/examples/streaming/akka/ActorWordCount.scala index 9f7c7d5..2770b8a 100644 --- a/streaming-akka/examples/src/main/scala/org/apache/spark/examples/streaming/akka/ActorWordCount.scala +++ b/streaming-akka/examples/src/main/scala/org/apache/spark/examples/streaming/akka/ActorWordCount.scala @@ -19,7 +19,6 @@ package org.apache.spark.examples.streaming import scala.collection.mutable.LinkedHashSet -import scala.reflect.ClassTag import scala.util.Random import akka.actor._ http://git-wip-us.apache.org/repos/asf/bahir/blob/1d9e8910/streaming-mqtt/src/test/scala/org/apache/spark/streaming/mqtt/MQTTStreamSuite.scala ---------------------------------------------------------------------- diff --git a/streaming-mqtt/src/test/scala/org/apache/spark/streaming/mqtt/MQTTStreamSuite.scala b/streaming-mqtt/src/test/scala/org/apache/spark/streaming/mqtt/MQTTStreamSuite.scala index a6a9249..fdcd18c 100644 --- a/streaming-mqtt/src/test/scala/org/apache/spark/streaming/mqtt/MQTTStreamSuite.scala +++ b/streaming-mqtt/src/test/scala/org/apache/spark/streaming/mqtt/MQTTStreamSuite.scala @@ -23,7 +23,7 @@ import scala.language.postfixOps import org.scalatest.BeforeAndAfter import org.scalatest.concurrent.Eventually -import org.apache.spark.{SparkConf, SparkFunSuite} +import org.apache.spark.SparkFunSuite import org.apache.spark.storage.StorageLevel import org.apache.spark.streaming.{Milliseconds, StreamingContext} http://git-wip-us.apache.org/repos/asf/bahir/blob/1d9e8910/streaming-twitter/examples/src/main/scala/org/apache/spark/examples/streaming/twitter/TwitterAlgebirdCMS.scala ---------------------------------------------------------------------- diff --git a/streaming-twitter/examples/src/main/scala/org/apache/spark/examples/streaming/twitter/TwitterAlgebirdCMS.scala b/streaming-twitter/examples/src/main/scala/org/apache/spark/examples/streaming/twitter/TwitterAlgebirdCMS.scala index 825c671..5af82e1 100644 --- a/streaming-twitter/examples/src/main/scala/org/apache/spark/examples/streaming/twitter/TwitterAlgebirdCMS.scala +++ b/streaming-twitter/examples/src/main/scala/org/apache/spark/examples/streaming/twitter/TwitterAlgebirdCMS.scala @@ -22,7 +22,6 @@ import com.twitter.algebird._ import com.twitter.algebird.CMSHasherImplicits._ import org.apache.spark.SparkConf -import org.apache.spark.SparkContext._ import org.apache.spark.storage.StorageLevel import org.apache.spark.streaming.{Seconds, StreamingContext} import org.apache.spark.streaming.twitter._ http://git-wip-us.apache.org/repos/asf/bahir/blob/1d9e8910/streaming-twitter/examples/src/main/scala/org/apache/spark/examples/streaming/twitter/TwitterPopularTags.scala ---------------------------------------------------------------------- diff --git a/streaming-twitter/examples/src/main/scala/org/apache/spark/examples/streaming/twitter/TwitterPopularTags.scala b/streaming-twitter/examples/src/main/scala/org/apache/spark/examples/streaming/twitter/TwitterPopularTags.scala index 49cee1b..c386e39 100644 --- a/streaming-twitter/examples/src/main/scala/org/apache/spark/examples/streaming/twitter/TwitterPopularTags.scala +++ b/streaming-twitter/examples/src/main/scala/org/apache/spark/examples/streaming/twitter/TwitterPopularTags.scala @@ -19,7 +19,6 @@ package org.apache.spark.examples.streaming import org.apache.spark.streaming.{Seconds, StreamingContext} -import org.apache.spark.SparkContext._ import org.apache.spark.streaming.twitter._ import org.apache.spark.SparkConf http://git-wip-us.apache.org/repos/asf/bahir/blob/1d9e8910/streaming-twitter/src/main/scala/org/apache/spark/streaming/twitter/TwitterUtils.scala ---------------------------------------------------------------------- diff --git a/streaming-twitter/src/main/scala/org/apache/spark/streaming/twitter/TwitterUtils.scala b/streaming-twitter/src/main/scala/org/apache/spark/streaming/twitter/TwitterUtils.scala index 3e843e9..9cb0106 100644 --- a/streaming-twitter/src/main/scala/org/apache/spark/streaming/twitter/TwitterUtils.scala +++ b/streaming-twitter/src/main/scala/org/apache/spark/streaming/twitter/TwitterUtils.scala @@ -22,8 +22,8 @@ import twitter4j.auth.Authorization import org.apache.spark.storage.StorageLevel import org.apache.spark.streaming.StreamingContext -import org.apache.spark.streaming.api.java.{JavaDStream, JavaReceiverInputDStream, JavaStreamingContext} -import org.apache.spark.streaming.dstream.{DStream, ReceiverInputDStream} +import org.apache.spark.streaming.api.java.{JavaReceiverInputDStream, JavaStreamingContext} +import org.apache.spark.streaming.dstream.ReceiverInputDStream object TwitterUtils { /** http://git-wip-us.apache.org/repos/asf/bahir/blob/1d9e8910/streaming-zeromq/examples/src/main/scala/org/apache/spark/examples/streaming/zeromq/ZeroMQWordCount.scala ---------------------------------------------------------------------- diff --git a/streaming-zeromq/examples/src/main/scala/org/apache/spark/examples/streaming/zeromq/ZeroMQWordCount.scala b/streaming-zeromq/examples/src/main/scala/org/apache/spark/examples/streaming/zeromq/ZeroMQWordCount.scala index f612e50..99b5617 100644 --- a/streaming-zeromq/examples/src/main/scala/org/apache/spark/examples/streaming/zeromq/ZeroMQWordCount.scala +++ b/streaming-zeromq/examples/src/main/scala/org/apache/spark/examples/streaming/zeromq/ZeroMQWordCount.scala @@ -25,9 +25,8 @@ import akka.actor.actorRef2Scala import akka.util.ByteString import akka.zeromq._ import akka.zeromq.Subscribe -import com.typesafe.config.ConfigFactory -import org.apache.spark.{SparkConf, TaskContext} +import org.apache.spark.SparkConf import org.apache.spark.streaming.{Seconds, StreamingContext} import org.apache.spark.streaming.zeromq._
