Repository: bahir-website Updated Branches: refs/heads/asf-site 1dccb9c2d -> 0d0ba347c
Publishing from f8d356989c150427f4d85c1ff12e2f06864f4d63 Project: http://git-wip-us.apache.org/repos/asf/bahir-website/repo Commit: http://git-wip-us.apache.org/repos/asf/bahir-website/commit/0d0ba347 Tree: http://git-wip-us.apache.org/repos/asf/bahir-website/tree/0d0ba347 Diff: http://git-wip-us.apache.org/repos/asf/bahir-website/diff/0d0ba347 Branch: refs/heads/asf-site Commit: 0d0ba347cad4210a1f2817a3826e3fcac27e795f Parents: 1dccb9c Author: Luciano Resende <[email protected]> Authored: Wed Aug 10 14:57:50 2016 -0700 Committer: Luciano Resende <[email protected]> Committed: Wed Aug 10 14:57:50 2016 -0700 ---------------------------------------------------------------------- .../spark/current/spark-streaming-akka/index.html | 17 ++++++++--------- content/feed.xml | 4 ++-- 2 files changed, 10 insertions(+), 11 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/bahir-website/blob/0d0ba347/content/docs/spark/current/spark-streaming-akka/index.html ---------------------------------------------------------------------- diff --git a/content/docs/spark/current/spark-streaming-akka/index.html b/content/docs/spark/current/spark-streaming-akka/index.html index 50aedaa..3384628 100644 --- a/content/docs/spark/current/spark-streaming-akka/index.html +++ b/content/docs/spark/current/spark-streaming-akka/index.html @@ -192,11 +192,11 @@ this actor can be configured to handle failures, etc.</p> case data: String => store(data) } } -</code></pre> -<p>// A new input stream can be created with this custom actor as -val ssc: StreamingContext = ⦠-val lines = AkkaUtils.createStream<a href="ssc, Props[CustomActor]()," title="CustomReceiver">String</a></p> +// A new input stream can be created with this custom actor as +val ssc: StreamingContext = ... +val lines = AkkaUtils.createStream[String](ssc, Props[CustomActor](), "CustomReceiver") +</code></pre> <h3 id="java-api">Java API</h3> @@ -209,12 +209,11 @@ this actor can be configured to handle failures, etc.</p> store((String) msg); } } -</code></pre> -<p>// A new input stream can be created with this custom actor as -JavaStreamingContext jssc = â¦; -JavaDStream<string> lines = AkkaUtils.<string>createStream(jssc, Props.create(CustomActor.class), "CustomReceiver"); -```</string></string></p> +// A new input stream can be created with this custom actor as +JavaStreamingContext jssc = ...; +JavaDStream<String> lines = AkkaUtils.<String>createStream(jssc, Props.create(CustomActor.class), "CustomReceiver"); +</code></pre> <p>See end-to-end examples at <a href="https://github.com/apache/bahir/tree/master/streaming-akka/examples";>Akka Examples</a></p> http://git-wip-us.apache.org/repos/asf/bahir-website/blob/0d0ba347/content/feed.xml ---------------------------------------------------------------------- diff --git a/content/feed.xml b/content/feed.xml index 6fd6e15..1beccf9 100644 --- a/content/feed.xml +++ b/content/feed.xml @@ -6,8 +6,8 @@ </description> <link>http://bahir.apache.org/</link> <atom:link href="http://bahir.apache.org/feed.xml"; rel="self" type="application/rss+xml"/> - <pubDate>Wed, 10 Aug 2016 14:14:01 -0700</pubDate> - <lastBuildDate>Wed, 10 Aug 2016 14:14:01 -0700</lastBuildDate> + <pubDate>Wed, 10 Aug 2016 14:57:49 -0700</pubDate> + <lastBuildDate>Wed, 10 Aug 2016 14:57:49 -0700</lastBuildDate> <generator>Jekyll v3.0.0</generator> <item>
