diff options
| author | Prashant Sharma <prashant.s@imaginea.com> | 2013-08-23 09:41:32 +0530 |
|---|---|---|
| committer | Prashant Sharma <prashant.s@imaginea.com> | 2013-08-23 09:44:02 +0530 |
| commit | 2bc348e92c458ea36872ac43a2583370d1f3eb41 (patch) | |
| tree | f6c525de48d4c54c149212206546561389a4f2b5 /streaming | |
| parent | 3049415e245eefac0593a3e33ee7c8a845eeb800 (diff) | |
| download | spark-2bc348e92c458ea36872ac43a2583370d1f3eb41.tar.gz spark-2bc348e92c458ea36872ac43a2583370d1f3eb41.tar.bz2 spark-2bc348e92c458ea36872ac43a2583370d1f3eb41.zip | |
Linking custom receiver guide
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/src/main/scala/spark/streaming/StreamingContext.scala | 2 | ||||
| -rw-r--r-- | streaming/src/main/scala/spark/streaming/receivers/ActorReceiver.scala | 2 |
2 files changed, 4 insertions, 0 deletions
diff --git a/streaming/src/main/scala/spark/streaming/StreamingContext.scala b/streaming/src/main/scala/spark/streaming/StreamingContext.scala index 36b841af8f..9abe55ecce 100644 --- a/streaming/src/main/scala/spark/streaming/StreamingContext.scala +++ b/streaming/src/main/scala/spark/streaming/StreamingContext.scala @@ -166,6 +166,7 @@ class StreamingContext private ( /** * Create an input stream with any arbitrary user implemented network receiver. + * Find more details at: http://spark-project.org/docs/latest/streaming-custom-receivers.html * @param receiver Custom implementation of NetworkReceiver */ def networkStream[T: ClassManifest]( @@ -178,6 +179,7 @@ class StreamingContext private ( /** * Create an input stream with any arbitrary user implemented actor receiver. + * Find more details at: http://spark-project.org/docs/latest/streaming-custom-receivers.html * @param props Props object defining creation of the actor * @param name Name of the actor * @param storageLevel RDD storage level. Defaults to memory-only. diff --git a/streaming/src/main/scala/spark/streaming/receivers/ActorReceiver.scala b/streaming/src/main/scala/spark/streaming/receivers/ActorReceiver.scala index 036c95a860..3eca397f1a 100644 --- a/streaming/src/main/scala/spark/streaming/receivers/ActorReceiver.scala +++ b/streaming/src/main/scala/spark/streaming/receivers/ActorReceiver.scala @@ -28,6 +28,8 @@ object ReceiverSupervisorStrategy { * A receiver trait to be mixed in with your Actor to gain access to * pushBlock API. * + * Find more details at: http://spark-project.org/docs/latest/streaming-custom-receivers.html + * * @example {{{ * class MyActor extends Actor with Receiver{ * def receive { |