SPARK-1729. Optimize imports.

Author: harishreedharan

external/flume/src/main/scala/org/apache/spark/streaming/flume/EventTransformer.scala

@@ -18,8 +18,10 @@
 package org.apache.spark.streaming.flume
 
 import java.io.{ObjectOutput, ObjectInput}
-import org.apache.spark.util.Utils
+
 import scala.collection.JavaConversions._
+
+import org.apache.spark.util.Utils
 import org.apache.spark.Logging
 
 /**

external/flume/src/main/scala/org/apache/spark/streaming/flume/FlumePollingInputDStream.scala

@@ -16,23 +16,29 @@
  */
 package org.apache.spark.streaming.flume
 
-import scala.reflect.ClassTag
-import org.apache.spark.streaming.StreamingContext
-import org.apache.spark.storage.StorageLevel
-import org.apache.spark.streaming.dstream.ReceiverInputDStream
-import org.apache.spark.streaming.receiver.Receiver
-import org.apache.spark.Logging
+
+import java.io.{ObjectOutput, ObjectInput, Externalizable}
 import java.net.InetSocketAddress
+import java.nio.ByteBuffer
 import java.util.concurrent.{TimeUnit, Executors}
+
+import scala.collection.JavaConversions._
+import scala.collection.mutable
+import scala.reflect.ClassTag
+
+import com.google.common.util.concurrent.ThreadFactoryBuilder
 import org.apache.avro.ipc.NettyTransceiver
 import org.apache.avro.ipc.specific.SpecificRequestor
-import org.apache.spark.flume.{SparkSinkEvent, SparkFlumeProtocol}
 import org.jboss.netty.channel.socket.nio.NioClientSocketChannelFactory
-import com.google.common.util.concurrent.ThreadFactoryBuilder
-import java.io.{ObjectOutput, ObjectInput, Externalizable}
-import java.nio.ByteBuffer
-import scala.collection.JavaConversions._
-import scala.collection.mutable
+
+import org.apache.spark.Logging
+import org.apache.spark.flume.{SparkSinkEvent, SparkFlumeProtocol}
+import org.apache.spark.storage.StorageLevel
+import org.apache.spark.streaming.StreamingContext
+import org.apache.spark.streaming.dstream.ReceiverInputDStream
+import org.apache.spark.streaming.receiver.Receiver
+
+
 
 class FlumePollingInputDStream[T: ClassTag](
   @transient ssc_ : StreamingContext,

external/flume/src/main/scala/org/apache/spark/streaming/flume/FlumeUtils.scala

@@ -17,11 +17,13 @@
 
 package org.apache.spark.streaming.flume
 
+import java.net.InetSocketAddress
+
 import org.apache.spark.storage.StorageLevel
 import org.apache.spark.streaming.StreamingContext
 import org.apache.spark.streaming.api.java.{JavaReceiverInputDStream, JavaStreamingContext}
 import org.apache.spark.streaming.dstream.ReceiverInputDStream
-import java.net.InetSocketAddress
+
 
 object FlumeUtils {
   /**

external/flume/src/test/scala/org/apache/spark/streaming/flume/FlumePollingReceiverSuite.scala

@@ -18,19 +18,22 @@
  */
 package org.apache.spark.streaming.flume
 
-import org.apache.spark.streaming.{TestSuiteBase, TestOutputStream, StreamingContext}
-import org.apache.spark.storage.StorageLevel
+import java.net.InetSocketAddress
+import java.util.concurrent.{Callable, ExecutorCompletionService, Executors}
+
+import scala.collection.JavaConversions._
 import scala.collection.mutable.{SynchronizedBuffer, ArrayBuffer}
-import org.apache.spark.streaming.util.ManualClock
-import org.apache.flume.channel.MemoryChannel
+
 import org.apache.flume.Context
+import org.apache.flume.channel.MemoryChannel
 import org.apache.flume.conf.Configurables
-import org.apache.spark.flume.sink.{SparkSinkConfig, SparkSink}
-import scala.collection.JavaConversions._
 import org.apache.flume.event.EventBuilder
+
+import org.apache.spark.flume.sink.{SparkSinkConfig, SparkSink}
+import org.apache.spark.storage.StorageLevel
 import org.apache.spark.streaming.dstream.ReceiverInputDStream
-import java.net.InetSocketAddress
-import java.util.concurrent.{Callable, ExecutorCompletionService, Executors}
+import org.apache.spark.streaming.util.ManualClock
+import org.apache.spark.streaming.{TestSuiteBase, TestOutputStream, StreamingContext}
 
 class FlumePollingReceiverSuite extends TestSuiteBase {