Fix docs

apache · Jan 19, 2016 · d495ecc · d495ecc
1 parent 9a1b275
commit d495ecc
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/external/akka/src/main/scala/org/apache/spark/streaming/akka/ActorReceiver.scala b/external/akka/src/main/scala/org/apache/spark/streaming/akka/ActorReceiver.scala
@@ -59,7 +59,6 @@ object ActorSupervisorStrategy {
  *      }
  *  }
  *
- *  // Can be used with AkkaUtils.createStream as follows
  *  AkkaUtils.createStream[String](Props[MyActor](),"MyActorReceiver")
  *
  * }}}
@@ -104,12 +103,12 @@ abstract class ActorReceiver extends Actor {
  *
  * @example {{{
  *  class MyActor extends JavaActorReceiver {
- *      def receive {
- *          case anything: String => store(anything)
+ *      @Override
+ *      public void onReceive(Object msg) throws Exception {
+ *          store((String) msg);
  *      }
  *  }
  *
- *  // Can be used with AkkaUtils.createStream as follows
  *  AkkaUtils.<String>createStream(Props.create(MyActor.class), "MyActorReceiver");
  *
  * }}}