Merge pull request #529 from hsaputra/cleanup_right_arrowop_scala

Change the ⇒ character (maybe from scalariform) to => in Scala code for style consistency

Looks like there are some ⇒ Unicode character (maybe from scalariform) in Scala code.
This PR is to change it to => to get some consistency on the Scala code.

If we want to use ⇒ as default we could use sbt plugin scalariform to make sure all Scala code has ⇒ instead of =>

And remove unused imports found in TwitterInputDStream.scala while I was there =)

Author: Henry Saputra <hsaputra@apache.org>

== Merge branch commits ==

commit 29c1771d346dff901b0b778f764e6b4409900234
Author: Henry Saputra <hsaputra@apache.org>
Date:   Sat Feb 1 22:05:16 2014 -0800

    Change the ⇒ character (maybe from scalariform) to => in Scala code for style consistency.

1 files changed, 8 insertions, 8 deletions

diff --git a/streaming/src/main/scala/org/apache/spark/streaming/receivers/ActorReceiver.scala b/streaming/src/main/scala/org/apache/spark/streaming/receivers/ActorReceiver.scala
index 79ed696814..9c5b177c16 100644
--- a/streaming/src/main/scala/org/apache/spark/streaming/receivers/ActorReceiver.scala
+++ b/streaming/src/main/scala/org/apache/spark/streaming/receivers/ActorReceiver.scala
@@ -37,8 +37,8 @@ object ReceiverSupervisorStrategy {
 
   val defaultStrategy = OneForOneStrategy(maxNrOfRetries = 10, withinTimeRange =
     15 millis) {
-    case _: RuntimeException ⇒ Restart
-    case _: Exception ⇒ Escalate
+    case _: RuntimeException => Restart
+    case _: Exception => Escalate
   }
 }
 
@@ -66,7 +66,7 @@ object ReceiverSupervisorStrategy {
  */
 trait Receiver {
 
-  self: Actor ⇒ // to ensure that this can be added to Actor classes only
+  self: Actor => // to ensure that this can be added to Actor classes only
 
   /**
    * Push an iterator received data into Spark Streaming for processing
@@ -139,25 +139,25 @@ private[streaming] class ActorReceiver[T: ClassTag](
 
     def receive = {
 
-      case Data(iter: Iterator[_]) ⇒ pushBlock(iter.asInstanceOf[Iterator[T]])
+      case Data(iter: Iterator[_]) => pushBlock(iter.asInstanceOf[Iterator[T]])
 
-      case Data(msg) ⇒
+      case Data(msg) =>
         blocksGenerator += msg.asInstanceOf[T]
         n.incrementAndGet
 
-      case props: Props ⇒
+      case props: Props =>
         val worker = context.actorOf(props)
         logInfo("Started receiver worker at:" + worker.path)
         sender ! worker
 
-      case (props: Props, name: String) ⇒
+      case (props: Props, name: String) =>
         val worker = context.actorOf(props, name)
         logInfo("Started receiver worker at:" + worker.path)
         sender ! worker
 
       case _: PossiblyHarmful => hiccups.incrementAndGet()
 
-      case _: Statistics ⇒
+      case _: Statistics =>
         val workers = context.children
         sender ! Statistics(n.get, workers.size, hiccups.get, workers.mkString("\n"))