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 /examples/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 'examples/src')
| -rw-r--r-- | examples/src/main/scala/org/apache/spark/streaming/examples/ActorWordCount.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/examples/src/main/scala/org/apache/spark/streaming/examples/ActorWordCount.scala b/examples/src/main/scala/org/apache/spark/streaming/examples/ActorWordCount.scala index a5888811cc..bc0d1633f1 100644 --- a/examples/src/main/scala/org/apache/spark/streaming/examples/ActorWordCount.scala +++ b/examples/src/main/scala/org/apache/spark/streaming/examples/ActorWordCount.scala @@ -88,7 +88,7 @@ extends Actor with Receiver { override def preStart = remotePublisher ! SubscribeReceiver(context.self) def receive = { - case msg ⇒ pushBlock(msg.asInstanceOf[T]) + case msg => pushBlock(msg.asInstanceOf[T]) } override def postStop() = remotePublisher ! UnsubscribeReceiver(context.self) |