diff options
| author | Prashant Sharma <prashant.s@imaginea.com> | 2013-12-10 11:34:10 +0530 |
|---|---|---|
| committer | Prashant Sharma <prashant.s@imaginea.com> | 2013-12-10 11:47:16 +0530 |
| commit | 17db6a9041d5e83d7b6fe47f9c36758d0613fcd6 (patch) | |
| tree | 6c99fe68332d7bec882be2fd5e50347c3fb3c134 /streaming/src | |
| parent | c1201f47e0d44e92da42adb23d27f60d9d494642 (diff) | |
| download | spark-17db6a9041d5e83d7b6fe47f9c36758d0613fcd6.tar.gz spark-17db6a9041d5e83d7b6fe47f9c36758d0613fcd6.tar.bz2 spark-17db6a9041d5e83d7b6fe47f9c36758d0613fcd6.zip | |
Style fixes and addressed review comments at #221
Diffstat (limited to 'streaming/src')
| -rw-r--r-- | streaming/src/main/scala/org/apache/spark/streaming/receivers/ZeroMQReceiver.scala | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/receivers/ZeroMQReceiver.scala b/streaming/src/main/scala/org/apache/spark/streaming/receivers/ZeroMQReceiver.scala index ce8c56fa8a..f164d516b0 100644 --- a/streaming/src/main/scala/org/apache/spark/streaming/receivers/ZeroMQReceiver.scala +++ b/streaming/src/main/scala/org/apache/spark/streaming/receivers/ZeroMQReceiver.scala @@ -17,14 +17,14 @@ package org.apache.spark.streaming.receivers +import scala.reflect.ClassTag + import akka.actor.Actor import akka.util.ByteString import akka.zeromq._ import org.apache.spark.Logging -import scala.reflect.ClassTag - /** * A receiver to subscribe to ZeroMQ stream. */ |