diff options
author | Henry Saputra <hsaputra@apache.org> | 2014-02-02 21:51:17 -0800 |
---|---|---|
committer | Reynold Xin <rxin@apache.org> | 2014-02-02 21:51:17 -0800 |
commit | 0386f42e383dc01b8df33c4a70b024e7902b5fdd (patch) | |
tree | f5f2152d661ca67dacb81788236548219264d3bb /streaming/src | |
parent | a8cf3ec157fc9a512421b319cfffc5e4f07cf1f3 (diff) | |
download | spark-0386f42e383dc01b8df33c4a70b024e7902b5fdd.tar.gz spark-0386f42e383dc01b8df33c4a70b024e7902b5fdd.tar.bz2 spark-0386f42e383dc01b8df33c4a70b024e7902b5fdd.zip |
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.
Diffstat (limited to 'streaming/src')
-rw-r--r-- | streaming/src/main/scala/org/apache/spark/streaming/receivers/ActorReceiver.scala | 16 |
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")) |