[SPARK-3873][STREAMING] Import order fixes for streaming. Also included a few miscelaneous other modules that had very few violations.
Author: Marcelo Vanzin <van...@cloudera.com> Closes #10532 from vanzin/SPARK-3873-streaming. Project: http://git-wip-us.apache.org/repos/asf/bahir/repo Commit: http://git-wip-us.apache.org/repos/asf/bahir/commit/d2d48331 Tree: http://git-wip-us.apache.org/repos/asf/bahir/tree/d2d48331 Diff: http://git-wip-us.apache.org/repos/asf/bahir/diff/d2d48331 Branch: refs/heads/master Commit: d2d4833158c0959df6bbad7733b11553e6644c7f Parents: 47e0e0e Author: Marcelo Vanzin <van...@cloudera.com> Authored: Thu Dec 31 01:34:13 2015 -0800 Committer: Reynold Xin <r...@databricks.com> Committed: Thu Dec 31 01:34:13 2015 -0800 ---------------------------------------------------------------------- .../apache/spark/streaming/twitter/TwitterInputDStream.scala | 6 +++--- .../org/apache/spark/streaming/twitter/TwitterUtils.scala | 5 +++-- .../scala/org/apache/spark/streaming/zeromq/ZeroMQUtils.scala | 2 +- 3 files changed, 7 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/bahir/blob/d2d48331/streaming-twitter/src/main/scala/org/apache/spark/streaming/twitter/TwitterInputDStream.scala ---------------------------------------------------------------------- diff --git a/streaming-twitter/src/main/scala/org/apache/spark/streaming/twitter/TwitterInputDStream.scala b/streaming-twitter/src/main/scala/org/apache/spark/streaming/twitter/TwitterInputDStream.scala index 9a85a65..a48eec7 100644 --- a/streaming-twitter/src/main/scala/org/apache/spark/streaming/twitter/TwitterInputDStream.scala +++ b/streaming-twitter/src/main/scala/org/apache/spark/streaming/twitter/TwitterInputDStream.scala @@ -19,13 +19,13 @@ package org.apache.spark.streaming.twitter import twitter4j._ import twitter4j.auth.Authorization -import twitter4j.conf.ConfigurationBuilder import twitter4j.auth.OAuthAuthorization +import twitter4j.conf.ConfigurationBuilder +import org.apache.spark.Logging +import org.apache.spark.storage.StorageLevel import org.apache.spark.streaming._ import org.apache.spark.streaming.dstream._ -import org.apache.spark.storage.StorageLevel -import org.apache.spark.Logging import org.apache.spark.streaming.receiver.Receiver /* A stream of Twitter statuses, potentially filtered by one or more keywords. http://git-wip-us.apache.org/repos/asf/bahir/blob/d2d48331/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 c6a9a2b..3e843e9 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 @@ -19,10 +19,11 @@ package org.apache.spark.streaming.twitter import twitter4j.Status import twitter4j.auth.Authorization + import org.apache.spark.storage.StorageLevel import org.apache.spark.streaming.StreamingContext -import org.apache.spark.streaming.api.java.{JavaReceiverInputDStream, JavaDStream, JavaStreamingContext} -import org.apache.spark.streaming.dstream.{ReceiverInputDStream, DStream} +import org.apache.spark.streaming.api.java.{JavaDStream, JavaReceiverInputDStream, JavaStreamingContext} +import org.apache.spark.streaming.dstream.{DStream, ReceiverInputDStream} object TwitterUtils { /** http://git-wip-us.apache.org/repos/asf/bahir/blob/d2d48331/streaming-zeromq/src/main/scala/org/apache/spark/streaming/zeromq/ZeroMQUtils.scala ---------------------------------------------------------------------- diff --git a/streaming-zeromq/src/main/scala/org/apache/spark/streaming/zeromq/ZeroMQUtils.scala b/streaming-zeromq/src/main/scala/org/apache/spark/streaming/zeromq/ZeroMQUtils.scala index 4ea218e..63cd8a2 100644 --- a/streaming-zeromq/src/main/scala/org/apache/spark/streaming/zeromq/ZeroMQUtils.scala +++ b/streaming-zeromq/src/main/scala/org/apache/spark/streaming/zeromq/ZeroMQUtils.scala @@ -17,8 +17,8 @@ package org.apache.spark.streaming.zeromq -import scala.reflect.ClassTag import scala.collection.JavaConverters._ +import scala.reflect.ClassTag import akka.actor.{Props, SupervisorStrategy} import akka.util.ByteString
