You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by jm...@apache.org on 2017/06/09 18:46:24 UTC
svn commit: r1798258 [22/22] - in /samza/site: ./ archive/ community/
contribute/ img/latest/learn/documentation/introduction/
img/latest/learn/tutorials/
img/latest/learn/tutorials/hello-samza-high-level/
learn/documentation/latest/ learn/documentatio...
Added: samza/site/learn/tutorials/latest/hello-samza-high-level-zk.html
URL: http://svn.apache.org/viewvc/samza/site/learn/tutorials/latest/hello-samza-high-level-zk.html?rev=1798258&view=auto
==============================================================================
--- samza/site/learn/tutorials/latest/hello-samza-high-level-zk.html (added)
+++ samza/site/learn/tutorials/latest/hello-samza-high-level-zk.html Fri Jun 9 18:46:20 2017
@@ -0,0 +1,268 @@
+<!DOCTYPE html>
+<!--
+ Licensed to the Apache Software Foundation (ASF) under one or more
+ contributor license agreements. See the NOTICE file distributed with
+ this work for additional information regarding copyright ownership.
+ The ASF licenses this file to You under the Apache License, Version 2.0
+ (the "License"); you may not use this file except in compliance with
+ the License. You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
+-->
+<html lang="en">
+ <head>
+ <meta charset="utf-8">
+ <title>Samza - Hello Samza High Level API - Zookeeper Deployment</title>
+ <link href='/css/ropa-sans.css' rel='stylesheet' type='text/css'/>
+ <link href="/css/bootstrap.min.css" rel="stylesheet"/>
+ <link href="/css/font-awesome.min.css" rel="stylesheet"/>
+ <link href="/css/main.css" rel="stylesheet"/>
+ <link href="/css/syntax.css" rel="stylesheet"/>
+ <link rel="icon" type="image/png" href="/img/samza-icon.png">
+ <script src="/js/jquery-1.11.1.min.js"></script>
+ </head>
+ <body>
+ <div class="wrapper">
+ <div class="wrapper-content">
+
+ <div class="masthead">
+ <div class="container">
+ <div class="masthead-logo">
+ <a href="/" class="logo">samza</a>
+ </div>
+ <div class="masthead-icons">
+ <div class="pull-right">
+ <a href="/startup/download"><i class="fa fa-arrow-circle-o-down masthead-icon"></i></a>
+ <a href="https://git-wip-us.apache.org/repos/asf?p=samza.git;a=tree" target="_blank"><i class="fa fa-code masthead-icon" style="font-weight: bold;"></i></a>
+ <a href="https://twitter.com/samzastream" target="_blank"><i class="fa fa-twitter masthead-icon"></i></a>
+ <!-- this icon only shows in versioned pages -->
+
+
+
+
+ <a href="http://samza.apache.org/learn/tutorials/0.13/hello-samza-high-level-zk.html"><i id="switch-version-button"></i></a>
+ <!-- links for the navigation bar -->
+
+
+ </div>
+ </div>
+ </div><!-- /.container -->
+ </div>
+
+ <div class="container">
+ <div class="menu">
+ <h1><i class="fa fa-rocket"></i> Getting Started</h1>
+ <ul>
+ <li><a href="/startup/hello-samza/latest">Hello Samza</a></li>
+ <li><a href="/startup/download">Download</a></li>
+ <li><a href="/startup/preview">Feature Preview</a></li>
+ </ul>
+
+ <h1><i class="fa fa-book"></i> Learn</h1>
+ <ul>
+ <li><a href="/learn/documentation/latest">Documentation</a></li>
+ <li><a href="/learn/documentation/latest/jobs/configuration-table.html">Configuration</a></li>
+ <li><a href="/learn/documentation/latest/container/metrics-table.html">Metrics</a></li>
+ <li><a href="/learn/documentation/latest/api/javadocs/">Javadocs</a></li>
+ <li><a href="/learn/tutorials/latest">Tutorials</a></li>
+ <li><a href="https://cwiki.apache.org/confluence/display/SAMZA/FAQ">FAQ</a></li>
+ <li><a href="https://cwiki.apache.org/confluence/display/SAMZA/Apache+Samza">Wiki</a></li>
+ <li><a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=51812876">Papers & Talks</a></li>
+ <li><a href="http://blogs.apache.org/samza">Blog</a></li>
+ </ul>
+
+ <h1><i class="fa fa-comments"></i> Community</h1>
+ <ul>
+ <li><a href="/community/mailing-lists.html">Mailing Lists</a></li>
+ <li><a href="/community/irc.html">IRC</a></li>
+ <li><a href="https://issues.apache.org/jira/browse/SAMZA">Bugs</a></li>
+ <li><a href="https://cwiki.apache.org/confluence/display/SAMZA/Powered+By">Powered by</a></li>
+ <li><a href="https://cwiki.apache.org/confluence/display/SAMZA/Ecosystem">Ecosystem</a></li>
+ <li><a href="/community/committers.html">Committers</a></li>
+ </ul>
+
+ <h1><i class="fa fa-code"></i> Contribute</h1>
+ <ul>
+ <li><a href="/contribute/contributors-corner.html">Contributor's Corner</a></li>
+ <li><a href="/contribute/coding-guide.html">Coding Guide</a></li>
+ <li><a href="/contribute/design-documents.html">Design Documents</a></li>
+ <li><a href="/contribute/code.html">Code</a></li>
+ <li><a href="/contribute/tests.html">Tests</a></li>
+ </ul>
+
+ <h1><i class="fa fa-history"></i> Archive</h1>
+ <ul>
+ <li><a href="/archive/index.html#latest">latest</a></li>
+ <li><a href="/archive/index.html#13">0.13</a></li>
+ <li><a href="/archive/index.html#12">0.12</a></li>
+ <li><a href="/archive/index.html#11">0.11</a></li>
+ <li><a href="/archive/index.html#10">0.10</a></li>
+ <li><a href="/archive/index.html#09">0.9</a></li>
+ <li><a href="/archive/index.html#08">0.8</a></li>
+ <li><a href="/archive/index.html#07">0.7</a></li>
+ </ul>
+ </div>
+
+ <div class="content">
+ <!--
+ Licensed to the Apache Software Foundation (ASF) under one or more
+ contributor license agreements. See the NOTICE file distributed with
+ this work for additional information regarding copyright ownership.
+ The ASF licenses this file to You under the Apache License, Version 2.0
+ (the "License"); you may not use this file except in compliance with
+ the License. You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
+-->
+
+<h2>Hello Samza High Level API - Zookeeper Deployment</h2>
+
+<!--
+ Licensed to the Apache Software Foundation (ASF) under one or more
+ contributor license agreements. See the NOTICE file distributed with
+ this work for additional information regarding copyright ownership.
+ The ASF licenses this file to You under the Apache License, Version 2.0
+ (the "License"); you may not use this file except in compliance with
+ the License. You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
+-->
+
+<p>The <a href="https://github.com/apache/samza-hello-samza">hello-samza</a> project is designed to get started with your first Samza job.
+In this tutorial, we will learn how to run a Samza application using ZooKeeper deployment model.</p>
+
+<h3 id="get-the-code">Get the Code</h3>
+
+<p>Let’s get started by cloning the hello-samza project</p>
+
+<div class="highlight"><pre><code class="bash">git clone https://git.apache.org/samza-hello-samza.git hello-samza
+<span class="nb">cd </span>hello-samza
+git checkout latest</code></pre></div>
+
+<p>The project comes up with numerous examples and for this tutorial, we will pick the Wikipedia application.</p>
+
+<h3 id="setting-up-the-deployment-environment">Setting up the Deployment Environment</h3>
+
+<p>For our Wikipedia application, we require two systems: <a href="http://kafka.apache.org/">Kafka</a> and <a href="http://zookeeper.apache.org/">ZooKeeper</a>. The hello-samza project comes with a script called “grid” to help with the environment setup</p>
+
+<div class="highlight"><pre><code class="bash">./bin/grid standalone</code></pre></div>
+
+<p>This command will download, install, and start ZooKeeper and Kafka. It will also check out the latest version of Samza and build it. All package files will be put in a sub-directory called “deploy” inside hello-samza’s root folder.</p>
+
+<p>If you get a complaint that JAVA_HOME is not set, then you’ll need to set it to the path where Java is installed on your system.</p>
+
+<h3 id="building-the-hello-samza-project">Building the Hello Samza Project</h3>
+
+<p>NOTE: if you are building from the latest branch of hello-samza project and want to use your local copy of samza, make sure that you run the following step from your local Samza project first</p>
+
+<div class="highlight"><pre><code class="bash">./gradlew publishToMavenLocal</code></pre></div>
+
+<p>With the environment setup complete, let us move on to building the hello-samza project. Execute the following commands:</p>
+
+<div class="highlight"><pre><code class="bash">mvn clean package
+mkdir -p deploy/samza
+tar -xvf ./target/hello-samza-0.13.1-SNAPSHOT-dist.tar.gz -C deploy/samza</code></pre></div>
+
+<p>We are now all set to deploy the application locally.</p>
+
+<h3 id="running-the-wikipedia-application">Running the Wikipedia application</h3>
+
+<p>In order to run the application, we will use the <em>run-wikipedia-zk-application</em> script.</p>
+
+<div class="highlight"><pre><code class="bash">./deploy/samza/bin/run-wikipedia-zk-application.sh</code></pre></div>
+
+<p>The above command executes the helper script which invokes the <em>WikipediaZkLocalApplication</em> main class with the appropriate job configurations as command line arguments. The main class is an application wrapper
+that initializes the application and passes it to the local runner for execution. It is blocking and waits for the <em>LocalApplicationRunner</em> to finish.</p>
+
+<p>To run your own application using ZooKeeper deployment model, you would need something similar to <em>WikipediaZkLocalApplication</em> class that initializes your application
+and uses the <em>LocalApplicationRunner</em> to run it. To learn more about the internals checkout <a href="/startup/preview/">deployment-models</a> documentation and the <a href="/learn/documentation/latest/jobs/configuration-table.html">configurations</a> table.</p>
+
+<p>Getting back to our example, the application consumes a feed of real-time edits from Wikipedia, and produces them to a Kafka topic called “wikipedia-stats”. Give the job a minute to startup, and then tail the Kafka topic. To do so, run the following command:</p>
+
+<div class="highlight"><pre><code class="bash">./deploy/kafka/bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic wikipedia-stats</code></pre></div>
+
+<p>The messages in the stats topic should look like the sample below:</p>
+
+<div class="highlight"><pre><code class="json"><span class="p">{</span><span class="nt">"is-talk"</span><span class="p">:</span><span class="mi">2</span><span class="p">,</span><span class="nt">"bytes-added"</span><span class="p">:</span><span class="mi">5276</span><span class="p">,</span><span class="nt">"edits"</span><span class="p">:</span><span class="mi">13</span><span class="p">,</span><span class="nt">"unique-titles"</span><span class="p">:</span><span class="mi">13</span><span class="p">}</span>
+<span class="p">{</span><span class="nt">"is-bot-edit"</span><span class="p">:</span><span class="mi">1</span><span class="p">,</span><span class="nt">"is-talk"</span><span class="p">:</span><span class="mi">3</span><span class="p">,</span><span class="nt">"bytes-added"</span><span class="p">:</span><span class="mi">4211</span><span class="p">,</span><span class="nt">"edits"</span><span class="p">:</span><span class="mi">30</span><span class="p">,</span><span class="nt">"unique-titles"</span><span class="p">:</span><span class="mi">30</span><span class="p">,</span><span class="nt">"is-unpatrolled"</span><span class="p">:</span><span class="mi">1</span><span class="p">,</span><span class="nt">"is-new"</span><span class="p">:</span><span class="mi">2</span><span class="p">,</span><span class="nt">"is-minor"</span><span class="p">:</span><span class="mi">7</span><span class="p">}</span>
+<span class="p">{</span><span class="nt">"bytes-added"</span><span class="p">:</span><span class="mi">3180</span><span class="p">,</span><span class="nt">"edits"</span><span class="p">:</span><span class="mi">19</span><span class="p">,</span><span class="nt">"unique-titles"</span><span class="p">:</span><span class="mi">19</span><span class="p">,</span><span class="nt">"is-unpatrolled"</span><span class="p">:</span><span class="mi">1</span><span class="p">,</span><span class="nt">"is-new"</span><span class="p">:</span><span class="mi">1</span><span class="p">,</span><span class="nt">"is-minor"</span><span class="p">:</span><span class="mi">3</span><span class="p">}</span>
+<span class="p">{</span><span class="nt">"bytes-added"</span><span class="p">:</span><span class="mi">2218</span><span class="p">,</span><span class="nt">"edits"</span><span class="p">:</span><span class="mi">18</span><span class="p">,</span><span class="nt">"unique-titles"</span><span class="p">:</span><span class="mi">18</span><span class="p">,</span><span class="nt">"is-unpatrolled"</span><span class="p">:</span><span class="mi">2</span><span class="p">,</span><span class="nt">"is-new"</span><span class="p">:</span><span class="mi">2</span><span class="p">,</span><span class="nt">"is-minor"</span><span class="p">:</span><span class="mi">3</span><span class="p">}</span></code></pre></div>
+
+<p>Excellent! Now that the job is running, open the <em>plan.html</em> file under <em>deploy/samza/bin</em> directory to take a look at the execution plan for the Wikipedia application.
+The execution plan is a colorful graphic representing various stages of your application and how they are connected. Here is a sample plan visualization:</p>
+
+<p><img src="/img/latest/learn/tutorials/hello-samza-high-level/wikipedia-execution-plan.png" alt="Execution plan" style="max-width: 100%; height: auto;" onclick="window.open(this.src)"/></p>
+
+<h3 id="shutdown">Shutdown</h3>
+
+<p>The Wikipedia application can be shutdown by terminating the <em>run-wikipedia-zk-application</em> script.
+We can use the <em>grid</em> script to tear down the local environment (<a href="http://kafka.apache.org/">Kafka</a> and <a href="http://zookeeper.apache.org/">Zookeeper</a>).</p>
+
+<div class="highlight"><pre><code class="bash">bin/grid stop all</code></pre></div>
+
+<p>Congratulations! You’ve now successfully run a Samza application using ZooKeeper deployment model. Next up, check out the <a href="/startup/preview/">deployment-models</a> and <a href="/startup/preview.html">high level API</a> pages.</p>
+
+
+ </div>
+ </div>
+
+ </div><!-- /.wrapper-content -->
+ </div><!-- /.wrapper -->
+
+ <div class="footer">
+ <div class="container">
+ <!-- nothing for now. -->
+ </div>
+ </div>
+
+
+ <script>
+ $( document ).ready(function() {
+ if ( $.fn.urlExists( "/learn/tutorials/0.13/hello-samza-high-level-zk.html" ) ) {
+ $("#switch-version-button").addClass("fa fa-history masthead-icon");
+ }
+ });
+
+ /* a function to test whether the url exists or not */
+ (function( $ ) {
+ $.fn.urlExists = function(url) {
+ var http = new XMLHttpRequest();
+ http.open('HEAD', url, false);
+ http.send();
+ return http.status != 404;
+ };
+ }( jQuery ));
+ </script>
+
+
+ <!-- Google Analytics -->
+ <script>
+ (function(i,s,o,g,r,a,m){i['GoogleAnalyticsObject']=r;i[r]=i[r]||function(){
+ (i[r].q=i[r].q||[]).push(arguments)},i[r].l=1*new Date();a=s.createElement(o),
+ m=s.getElementsByTagName(o)[0];a.async=1;a.src=g;m.parentNode.insertBefore(a,m)
+ })(window,document,'script','//www.google-analytics.com/analytics.js','ga');
+
+ ga('create', 'UA-43122768-1', 'apache.org');
+ ga('send', 'pageview');
+
+ </script>
+ </body>
+</html>
Modified: samza/site/learn/tutorials/latest/index.html
URL: http://svn.apache.org/viewvc/samza/site/learn/tutorials/latest/index.html?rev=1798258&r1=1798257&r2=1798258&view=diff
==============================================================================
--- samza/site/learn/tutorials/latest/index.html (original)
+++ samza/site/learn/tutorials/latest/index.html Fri Jun 9 18:46:20 2017
@@ -46,7 +46,7 @@
- <a href="http://samza.apache.org/learn/tutorials/0.12/index.html"><i id="switch-version-button"></i></a>
+ <a href="http://samza.apache.org/learn/tutorials/0.13/index.html"><i id="switch-version-button"></i></a>
<!-- links for the navigation bar -->
@@ -61,6 +61,7 @@
<ul>
<li><a href="/startup/hello-samza/latest">Hello Samza</a></li>
<li><a href="/startup/download">Download</a></li>
+ <li><a href="/startup/preview">Feature Preview</a></li>
</ul>
<h1><i class="fa fa-book"></i> Learn</h1>
@@ -98,6 +99,7 @@
<h1><i class="fa fa-history"></i> Archive</h1>
<ul>
<li><a href="/archive/index.html#latest">latest</a></li>
+ <li><a href="/archive/index.html#13">0.13</a></li>
<li><a href="/archive/index.html#12">0.12</a></li>
<li><a href="/archive/index.html#11">0.11</a></li>
<li><a href="/archive/index.html#10">0.10</a></li>
@@ -144,6 +146,16 @@
limitations under the License.
-->
+<!-- Uncomment after these features are fully released
+[[Preview] Hello Samza High Level API Zookeeper Deployment](hello-samza-high-level-zk.html)
+
+[[Preview] Hello Samza High Level API Yarn Deployment](hello-samza-high-level-yarn.html)
+
+[[Preview] Hello Samza High Level API Code](hello-samza-high-level-code.html)
+-->
+
+<p><a href="/startup/hello-samza/latest/">Hello Samza Low Level API Yarn Deployment</a></p>
+
<p><a href="remote-debugging-samza.html">Remote Debugging with Samza</a></p>
<p><a href="deploy-samza-job-from-hdfs.html">Deploying a Samza Job from HDFS</a></p>
@@ -185,7 +197,7 @@
<script>
$( document ).ready(function() {
- if ( $.fn.urlExists( "/learn/tutorials/0.12/index.html" ) ) {
+ if ( $.fn.urlExists( "/learn/tutorials/0.13/index.html" ) ) {
$("#switch-version-button").addClass("fa fa-history masthead-icon");
}
});
Modified: samza/site/learn/tutorials/latest/remote-debugging-samza.html
URL: http://svn.apache.org/viewvc/samza/site/learn/tutorials/latest/remote-debugging-samza.html?rev=1798258&r1=1798257&r2=1798258&view=diff
==============================================================================
--- samza/site/learn/tutorials/latest/remote-debugging-samza.html (original)
+++ samza/site/learn/tutorials/latest/remote-debugging-samza.html Fri Jun 9 18:46:20 2017
@@ -46,7 +46,7 @@
- <a href="http://samza.apache.org/learn/tutorials/0.12/remote-debugging-samza.html"><i id="switch-version-button"></i></a>
+ <a href="http://samza.apache.org/learn/tutorials/0.13/remote-debugging-samza.html"><i id="switch-version-button"></i></a>
<!-- links for the navigation bar -->
@@ -61,6 +61,7 @@
<ul>
<li><a href="/startup/hello-samza/latest">Hello Samza</a></li>
<li><a href="/startup/download">Download</a></li>
+ <li><a href="/startup/preview">Feature Preview</a></li>
</ul>
<h1><i class="fa fa-book"></i> Learn</h1>
@@ -98,6 +99,7 @@
<h1><i class="fa fa-history"></i> Archive</h1>
<ul>
<li><a href="/archive/index.html#latest">latest</a></li>
+ <li><a href="/archive/index.html#13">0.13</a></li>
<li><a href="/archive/index.html#12">0.12</a></li>
<li><a href="/archive/index.html#11">0.11</a></li>
<li><a href="/archive/index.html#10">0.10</a></li>
@@ -193,7 +195,7 @@
<div class="highlight"><pre><code class="bash">mvn clean package
mkdir -p deploy/samza
-tar -xvf ./target/hello-samza-0.12.0-dist.tar.gz -C deploy/samza
+tar -xvf ./target/hello-samza-0.13.1-dist.tar.gz -C deploy/samza
deploy/samza/bin/run-job.sh --config-factory<span class="o">=</span>org.apache.samza.config.factories.PropertiesConfigFactory --config-path<span class="o">=</span>file://<span class="nv">$PWD</span>/deploy/samza/config/wikipedia-feed.properties</code></pre></div>
<p>When the wikipedia-feed job starts up, a single Samza container will be created to process all incoming messages. This is the container that we’ll want to connect to from the remote debugger.</p>
@@ -224,7 +226,7 @@ deploy/samza/bin/run-job.sh --config-fac
<script>
$( document ).ready(function() {
- if ( $.fn.urlExists( "/learn/tutorials/0.12/remote-debugging-samza.html" ) ) {
+ if ( $.fn.urlExists( "/learn/tutorials/0.13/remote-debugging-samza.html" ) ) {
$("#switch-version-button").addClass("fa fa-history masthead-icon");
}
});
Modified: samza/site/learn/tutorials/latest/run-hello-samza-without-internet.html
URL: http://svn.apache.org/viewvc/samza/site/learn/tutorials/latest/run-hello-samza-without-internet.html?rev=1798258&r1=1798257&r2=1798258&view=diff
==============================================================================
--- samza/site/learn/tutorials/latest/run-hello-samza-without-internet.html (original)
+++ samza/site/learn/tutorials/latest/run-hello-samza-without-internet.html Fri Jun 9 18:46:20 2017
@@ -46,7 +46,7 @@
- <a href="http://samza.apache.org/learn/tutorials/0.12/run-hello-samza-without-internet.html"><i id="switch-version-button"></i></a>
+ <a href="http://samza.apache.org/learn/tutorials/0.13/run-hello-samza-without-internet.html"><i id="switch-version-button"></i></a>
<!-- links for the navigation bar -->
@@ -61,6 +61,7 @@
<ul>
<li><a href="/startup/hello-samza/latest">Hello Samza</a></li>
<li><a href="/startup/download">Download</a></li>
+ <li><a href="/startup/preview">Feature Preview</a></li>
</ul>
<h1><i class="fa fa-book"></i> Learn</h1>
@@ -98,6 +99,7 @@
<h1><i class="fa fa-history"></i> Archive</h1>
<ul>
<li><a href="/archive/index.html#latest">latest</a></li>
+ <li><a href="/archive/index.html#13">0.13</a></li>
<li><a href="/archive/index.html#12">0.12</a></li>
<li><a href="/archive/index.html#11">0.11</a></li>
<li><a href="/archive/index.html#10">0.10</a></li>
@@ -203,7 +205,7 @@ NOTICE AUTH :*** Found your hostname
<script>
$( document ).ready(function() {
- if ( $.fn.urlExists( "/learn/tutorials/0.12/run-hello-samza-without-internet.html" ) ) {
+ if ( $.fn.urlExists( "/learn/tutorials/0.13/run-hello-samza-without-internet.html" ) ) {
$("#switch-version-button").addClass("fa fa-history masthead-icon");
}
});
Modified: samza/site/learn/tutorials/latest/run-in-multi-node-yarn.html
URL: http://svn.apache.org/viewvc/samza/site/learn/tutorials/latest/run-in-multi-node-yarn.html?rev=1798258&r1=1798257&r2=1798258&view=diff
==============================================================================
--- samza/site/learn/tutorials/latest/run-in-multi-node-yarn.html (original)
+++ samza/site/learn/tutorials/latest/run-in-multi-node-yarn.html Fri Jun 9 18:46:20 2017
@@ -46,7 +46,7 @@
- <a href="http://samza.apache.org/learn/tutorials/0.12/run-in-multi-node-yarn.html"><i id="switch-version-button"></i></a>
+ <a href="http://samza.apache.org/learn/tutorials/0.13/run-in-multi-node-yarn.html"><i id="switch-version-button"></i></a>
<!-- links for the navigation bar -->
@@ -61,6 +61,7 @@
<ul>
<li><a href="/startup/hello-samza/latest">Hello Samza</a></li>
<li><a href="/startup/download">Download</a></li>
+ <li><a href="/startup/preview">Feature Preview</a></li>
</ul>
<h1><i class="fa fa-book"></i> Learn</h1>
@@ -98,6 +99,7 @@
<h1><i class="fa fa-history"></i> Archive</h1>
<ul>
<li><a href="/archive/index.html#latest">latest</a></li>
+ <li><a href="/archive/index.html#13">0.13</a></li>
<li><a href="/archive/index.html#12">0.12</a></li>
<li><a href="/archive/index.html#11">0.11</a></li>
<li><a href="/archive/index.html#10">0.10</a></li>
@@ -246,13 +248,13 @@ vi src/main/config/wikipedia-feed.proper
<p>Change the yarn.package.path property to be:</p>
-<div class="highlight"><pre><code class="jproperties"><span class="na">yarn.package.path</span><span class="o">=</span><span class="s">http://yourHostname:8000/target/hello-samza-0.12.0-dist.tar.gz</span></code></pre></div>
+<div class="highlight"><pre><code class="jproperties"><span class="na">yarn.package.path</span><span class="o">=</span><span class="s">http://yourHostname:8000/target/hello-samza-0.13.1-dist.tar.gz</span></code></pre></div>
<p>3. Compile hello-samza.</p>
<div class="highlight"><pre><code class="bash">mvn clean package
mkdir -p deploy/samza
-tar -xvf ./target/hello-samza-0.12.0-dist.tar.gz -C deploy/samza</code></pre></div>
+tar -xvf ./target/hello-samza-0.13.1-dist.tar.gz -C deploy/samza</code></pre></div>
<p>4. Deploy Samza job package to Http server..</p>
@@ -284,7 +286,7 @@ tar -xvf ./target/hello-samza-0.12.0-dis
<script>
$( document ).ready(function() {
- if ( $.fn.urlExists( "/learn/tutorials/0.12/run-in-multi-node-yarn.html" ) ) {
+ if ( $.fn.urlExists( "/learn/tutorials/0.13/run-in-multi-node-yarn.html" ) ) {
$("#switch-version-button").addClass("fa fa-history masthead-icon");
}
});
Modified: samza/site/learn/tutorials/latest/samza-async-user-guide.html
URL: http://svn.apache.org/viewvc/samza/site/learn/tutorials/latest/samza-async-user-guide.html?rev=1798258&r1=1798257&r2=1798258&view=diff
==============================================================================
--- samza/site/learn/tutorials/latest/samza-async-user-guide.html (original)
+++ samza/site/learn/tutorials/latest/samza-async-user-guide.html Fri Jun 9 18:46:20 2017
@@ -46,7 +46,7 @@
- <a href="http://samza.apache.org/learn/tutorials/0.12/samza-async-user-guide.html"><i id="switch-version-button"></i></a>
+ <a href="http://samza.apache.org/learn/tutorials/0.13/samza-async-user-guide.html"><i id="switch-version-button"></i></a>
<!-- links for the navigation bar -->
@@ -61,6 +61,7 @@
<ul>
<li><a href="/startup/hello-samza/latest">Hello Samza</a></li>
<li><a href="/startup/download">Download</a></li>
+ <li><a href="/startup/preview">Feature Preview</a></li>
</ul>
<h1><i class="fa fa-book"></i> Learn</h1>
@@ -98,6 +99,7 @@
<h1><i class="fa fa-history"></i> Archive</h1>
<ul>
<li><a href="/archive/index.html#latest">latest</a></li>
+ <li><a href="/archive/index.html#13">0.13</a></li>
<li><a href="/archive/index.html#12">0.12</a></li>
<li><a href="/archive/index.html#11">0.11</a></li>
<li><a href="/archive/index.html#10">0.10</a></li>
@@ -181,7 +183,7 @@
<h3 id="asynchronous-process-with-asyncstreamtask-api">Asynchronous Process with AsyncStreamTask API</h3>
-<p>If your job process is asynchronous, e.g. making non-blocking remote IO calls, <a href="javadocs/org/apache/samza/task/AsyncStreamTask.html">AsyncStreamTask</a> interface provides the support for it. In the following example AsyncRestTask makes asynchronous rest call and triggers callback once it’s complete. </p>
+<p>If your job process is asynchronous, e.g. making non-blocking remote IO calls, <a href="/learn/documentation/latest/api/javadocs/org/apache/samza/task/AsyncStreamTask.html">AsyncStreamTask</a> interface provides the support for it. In the following example AsyncRestTask makes asynchronous rest call and triggers callback once it’s complete.</p>
<div class="highlight"><pre><code class="java"><span class="kd">public</span> <span class="kd">class</span> <span class="nc">AsyncRestTask</span> <span class="kd">implements</span> <span class="n">AsyncStreamTask</span><span class="o">,</span> <span class="n">InitableTask</span><span class="o">,</span> <span class="n">ClosableTask</span> <span class="o">{</span>
<span class="kd">private</span> <span class="n">Client</span> <span class="n">client</span><span class="o">;</span>
@@ -217,7 +219,7 @@
<span class="o">}</span>
<span class="o">}</span></code></pre></div>
-<p>In the above example, the process is not complete when processAsync() returns. In the callback thread from Jersey client, we trigger <a href="javadocs/org/apache/samza/task/TaskCallback.html">TaskCallback</a> to indicate the process is done. In order to make sure the callback will be triggered within certain time interval, e.g. 5 seconds, you can config the following property:</p>
+<p>In the above example, the process is not complete when processAsync() returns. In the callback thread from Jersey client, we trigger <a href="/learn/documentation/latest/api/javadocs/org/apache/samza/task/TaskCallback.html">TaskCallback</a> to indicate the process is done. In order to make sure the callback will be triggered within certain time interval, e.g. 5 seconds, you can config the following property:</p>
<div class="highlight"><pre><code class="jproperties"><span class="c"># Timeout for processAsync() callback. When the timeout happens, it will throw a TaskCallbackTimeoutException and shut down the container.</span>
<span class="na">task.callback.timeout.ms</span><span class="o">=</span><span class="s">5000</span></code></pre></div>
@@ -259,7 +261,7 @@
<script>
$( document ).ready(function() {
- if ( $.fn.urlExists( "/learn/tutorials/0.12/samza-async-user-guide.html" ) ) {
+ if ( $.fn.urlExists( "/learn/tutorials/0.13/samza-async-user-guide.html" ) ) {
$("#switch-version-button").addClass("fa fa-history masthead-icon");
}
});
Modified: samza/site/learn/tutorials/latest/samza-rest-getting-started.html
URL: http://svn.apache.org/viewvc/samza/site/learn/tutorials/latest/samza-rest-getting-started.html?rev=1798258&r1=1798257&r2=1798258&view=diff
==============================================================================
--- samza/site/learn/tutorials/latest/samza-rest-getting-started.html (original)
+++ samza/site/learn/tutorials/latest/samza-rest-getting-started.html Fri Jun 9 18:46:20 2017
@@ -46,7 +46,7 @@
- <a href="http://samza.apache.org/learn/tutorials/0.12/samza-rest-getting-started.html"><i id="switch-version-button"></i></a>
+ <a href="http://samza.apache.org/learn/tutorials/0.13/samza-rest-getting-started.html"><i id="switch-version-button"></i></a>
<!-- links for the navigation bar -->
@@ -61,6 +61,7 @@
<ul>
<li><a href="/startup/hello-samza/latest">Hello Samza</a></li>
<li><a href="/startup/download">Download</a></li>
+ <li><a href="/startup/preview">Feature Preview</a></li>
</ul>
<h1><i class="fa fa-book"></i> Learn</h1>
@@ -98,6 +99,7 @@
<h1><i class="fa fa-history"></i> Archive</h1>
<ul>
<li><a href="/archive/index.html#latest">latest</a></li>
+ <li><a href="/archive/index.html#13">0.13</a></li>
<li><a href="/archive/index.html#12">0.12</a></li>
<li><a href="/archive/index.html#11">0.11</a></li>
<li><a href="/archive/index.html#10">0.10</a></li>
@@ -171,7 +173,7 @@
<div class="highlight"><pre><code class="bash"><span class="nb">cd </span>samza-rest/build/distributions/
mkdir -p deploy/samza-rest
-tar -xvf ./samza-rest-0.13.0-SNAPSHOT.tgz -C deploy/samza-rest</code></pre></div>
+tar -xvf ./samza-rest-0.13.1-SNAPSHOT.tgz -C deploy/samza-rest</code></pre></div>
<h4 id="configure-the-installations-path">Configure the Installations Path</h4>
@@ -228,7 +230,7 @@ tar -xvf ./samza-rest-0.13.0-SNAPSHOT.tg
<script>
$( document ).ready(function() {
- if ( $.fn.urlExists( "/learn/tutorials/0.12/samza-rest-getting-started.html" ) ) {
+ if ( $.fn.urlExists( "/learn/tutorials/0.13/samza-rest-getting-started.html" ) ) {
$("#switch-version-button").addClass("fa fa-history masthead-icon");
}
});
Modified: samza/site/sitemap.xml
URL: http://svn.apache.org/viewvc/samza/site/sitemap.xml?rev=1798258&r1=1798257&r2=1798258&view=diff
==============================================================================
--- samza/site/sitemap.xml (original)
+++ samza/site/sitemap.xml Fri Jun 9 18:46:20 2017
@@ -20,7 +20,7 @@
<url>
<loc>http://samza.apache.org/</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
<changefreq>daily</changefreq>
<priority>1.0</priority>
</url>
@@ -30,462 +30,462 @@
<url>
<loc>http://samza.apache.org/learn/documentation/versioned/yarn/application-master.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/documentation/versioned/introduction/architecture.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/documentation/versioned/introduction/background.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/documentation/versioned/container/checkpointing.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/contribute/code.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/contribute/coding-guide.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/community/committers.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/documentation/versioned/introduction/concepts.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/documentation/versioned/jobs/configuration.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/documentation/versioned/hdfs/consumer.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/contribute/contributors-corner.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/documentation/versioned/container/coordinator-stream.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/tutorials/versioned/deploy-samza-job-from-hdfs.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/tutorials/versioned/deploy-samza-to-CDH.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/contribute/design-documents.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/documentation/versioned/container/event-loop.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/tutorials/versioned/hello-samza-high-level-code.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/tutorials/versioned/hello-samza-high-level-yarn.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/tutorials/versioned/hello-samza-high-level-zk.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/documentation/versioned/index.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/archive/index.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/index.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/tutorials/versioned/index.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/startup/download/index.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/startup/hello-samza/versioned/index.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/startup/preview/index.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/documentation/versioned/comparisons/introduction.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/community/irc.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/documentation/versioned/yarn/isolation.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/documentation/versioned/container/jmx.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/documentation/versioned/jobs/job-runner.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/documentation/versioned/rest/resources/jobs.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/documentation/versioned/operations/kafka.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/documentation/versioned/jobs/logging.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/community/mailing-lists.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/documentation/versioned/container/metrics.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/documentation/versioned/rest/monitors.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/documentation/versioned/comparisons/mupd8.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/documentation/versioned/rest/overview.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/documentation/versioned/api/overview.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/documentation/versioned/jobs/packaging.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/documentation/versioned/hdfs/producer.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/tutorials/versioned/remote-debugging-samza.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/documentation/versioned/jobs/reprocessing.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/documentation/versioned/rest/resource-directory.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/documentation/versioned/rest/resources.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/tutorials/versioned/run-hello-samza-without-internet.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/tutorials/versioned/run-in-multi-node-yarn.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/tutorials/versioned/samza-async-user-guide.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/documentation/versioned/container/samza-container.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/tutorials/versioned/samza-rest-getting-started.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/documentation/versioned/operations/security.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/documentation/versioned/container/serialization.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/documentation/versioned/comparisons/spark-streaming.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/documentation/versioned/jobs/split-deployment.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/documentation/versioned/container/state-management.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/documentation/versioned/comparisons/storm.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/documentation/versioned/container/streams.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/documentation/versioned/rest/resources/tasks.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/contribute/tests.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/documentation/versioned/jobs/web-ui-rest-api.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/documentation/versioned/container/windowing.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/documentation/versioned/yarn/yarn-host-affinity.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/documentation/versioned/jobs/yarn-jobs.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/documentation/versioned/yarn/yarn-resource-localization.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
<url>
<loc>http://samza.apache.org/learn/documentation/versioned/yarn/yarn-security.html</loc>
- <lastmod>2017-06-07</lastmod>
+ <lastmod>2017-06-09</lastmod>
</url>
Modified: samza/site/startup/download/index.html
URL: http://svn.apache.org/viewvc/samza/site/startup/download/index.html?rev=1798258&r1=1798257&r2=1798258&view=diff
==============================================================================
--- samza/site/startup/download/index.html (original)
+++ samza/site/startup/download/index.html Fri Jun 9 18:46:20 2017
@@ -95,6 +95,7 @@
<h1><i class="fa fa-history"></i> Archive</h1>
<ul>
<li><a href="/archive/index.html#latest">latest</a></li>
+ <li><a href="/archive/index.html#13">0.13</a></li>
<li><a href="/archive/index.html#12">0.12</a></li>
<li><a href="/archive/index.html#11">0.11</a></li>
<li><a href="/archive/index.html#10">0.10</a></li>
@@ -143,7 +144,7 @@
<p>Samza is released as a source artifact, and also through Maven.</p>
-<p>If you just want to play around with Samza for the first time, go to <a href="/startup/hello-samza/0.13">Hello Samza</a>.</p>
+<p>If you just want to play around with Samza for the first time, go to <a href="/startup/hello-samza/latest">Hello Samza</a>.</p>
<h3 id="jdk-notice">JDK Notice</h3>
@@ -152,6 +153,7 @@
<h3 id="source-releases">Source Releases</h3>
<ul>
+<li><a href="http://www.apache.org/dyn/closer.lua/samza/0.13.0">samza-sources-0.13.0.tgz</a></li>
<li><a href="http://www.apache.org/dyn/closer.lua/samza/0.12.0">samza-sources-0.12.0.tgz</a></li>
<li><a href="http://www.apache.org/dyn/closer.lua/samza/0.11.0">samza-sources-0.11.0.tgz</a></li>
<li><a href="http://www.apache.org/dyn/closer.lua/samza/0.10.1">samza-sources-0.10.1.tgz</a></li>
@@ -173,12 +175,12 @@
<div class="highlight"><pre><code class="xml"><span class="nt"><dependency></span>
<span class="nt"><groupId></span>org.apache.samza<span class="nt"></groupId></span>
<span class="nt"><artifactId></span>samza-api<span class="nt"></artifactId></span>
- <span class="nt"><version></span>0.12.0<span class="nt"></version></span>
+ <span class="nt"><version></span>0.13.0<span class="nt"></version></span>
<span class="nt"></dependency></span>
<span class="nt"><dependency></span>
<span class="nt"><groupId></span>org.apache.samza<span class="nt"></groupId></span>
<span class="nt"><artifactId></span>samza-core_2.11<span class="nt"></artifactId></span>
- <span class="nt"><version></span>0.12.0<span class="nt"></version></span>
+ <span class="nt"><version></span>0.13.0<span class="nt"></version></span>
<span class="nt"><scope></span>runtime<span class="nt"></scope></span>
<span class="nt"></dependency></span>
<span class="nt"><dependency></span>
@@ -186,37 +188,37 @@
<span class="nt"><artifactId></span>samza-shell<span class="nt"></artifactId></span>
<span class="nt"><classifier></span>dist<span class="nt"></classifier></span>
<span class="nt"><type></span>tgz<span class="nt"></type></span>
- <span class="nt"><version></span>0.12.0<span class="nt"></version></span>
+ <span class="nt"><version></span>0.13.0<span class="nt"></version></span>
<span class="nt"><scope></span>runtime<span class="nt"></scope></span>
<span class="nt"></dependency></span>
<span class="nt"><dependency></span>
<span class="nt"><groupId></span>org.apache.samza<span class="nt"></groupId></span>
<span class="nt"><artifactId></span>samza-yarn_2.11<span class="nt"></artifactId></span>
- <span class="nt"><version></span>0.12.0<span class="nt"></version></span>
+ <span class="nt"><version></span>0.13.0<span class="nt"></version></span>
<span class="nt"><scope></span>runtime<span class="nt"></scope></span>
<span class="nt"></dependency></span>
<span class="nt"><dependency></span>
<span class="nt"><groupId></span>org.apache.samza<span class="nt"></groupId></span>
<span class="nt"><artifactId></span>samza-kv_2.11<span class="nt"></artifactId></span>
- <span class="nt"><version></span>0.12.0<span class="nt"></version></span>
+ <span class="nt"><version></span>0.13.0<span class="nt"></version></span>
<span class="nt"><scope></span>runtime<span class="nt"></scope></span>
<span class="nt"></dependency></span>
<span class="nt"><dependency></span>
<span class="nt"><groupId></span>org.apache.samza<span class="nt"></groupId></span>
<span class="nt"><artifactId></span>samza-kv-rocksdb_2.11<span class="nt"></artifactId></span>
- <span class="nt"><version></span>0.12.0<span class="nt"></version></span>
+ <span class="nt"><version></span>0.13.0<span class="nt"></version></span>
<span class="nt"><scope></span>runtime<span class="nt"></scope></span>
<span class="nt"></dependency></span>
<span class="nt"><dependency></span>
<span class="nt"><groupId></span>org.apache.samza<span class="nt"></groupId></span>
<span class="nt"><artifactId></span>samza-kv-inmemory_2.11<span class="nt"></artifactId></span>
- <span class="nt"><version></span>0.12.0<span class="nt"></version></span>
+ <span class="nt"><version></span>0.13.0<span class="nt"></version></span>
<span class="nt"><scope></span>runtime<span class="nt"></scope></span>
<span class="nt"></dependency></span>
<span class="nt"><dependency></span>
<span class="nt"><groupId></span>org.apache.samza<span class="nt"></groupId></span>
<span class="nt"><artifactId></span>samza-kafka_2.11<span class="nt"></artifactId></span>
- <span class="nt"><version></span>0.12.0<span class="nt"></version></span>
+ <span class="nt"><version></span>0.13.0<span class="nt"></version></span>
<span class="nt"><scope></span>runtime<span class="nt"></scope></span>
<span class="nt"></dependency></span></code></pre></div>
@@ -236,7 +238,7 @@
<span class="nt"><version></span>0.8.1<span class="nt"></version></span>
<span class="nt"></dependency></span></code></pre></div>
-<p><a href="/startup/hello-samza/0.13">Hello Samza</a> is a working Maven project that illustrates how to build projects that have Samza jobs in them.</p>
+<p><a href="/startup/hello-samza/latest">Hello Samza</a> is a working Maven project that illustrates how to build projects that have Samza jobs in them.</p>
<h4 id="repositories">Repositories</h4>
Modified: samza/site/startup/hello-samza/latest/index.html
URL: http://svn.apache.org/viewvc/samza/site/startup/hello-samza/latest/index.html?rev=1798258&r1=1798257&r2=1798258&view=diff
==============================================================================
--- samza/site/startup/hello-samza/latest/index.html (original)
+++ samza/site/startup/hello-samza/latest/index.html Fri Jun 9 18:46:20 2017
@@ -46,7 +46,7 @@
- <a href="http://samza.apache.org/startup/hello-samza/0.12/index.html"><i id="switch-version-button"></i></a>
+ <a href="http://samza.apache.org/startup/hello-samza/0.13/index.html"><i id="switch-version-button"></i></a>
<!-- links for the navigation bar -->
@@ -61,6 +61,7 @@
<ul>
<li><a href="/startup/hello-samza/latest">Hello Samza</a></li>
<li><a href="/startup/download">Download</a></li>
+ <li><a href="/startup/preview">Feature Preview</a></li>
</ul>
<h1><i class="fa fa-book"></i> Learn</h1>
@@ -98,6 +99,7 @@
<h1><i class="fa fa-history"></i> Archive</h1>
<ul>
<li><a href="/archive/index.html#latest">latest</a></li>
+ <li><a href="/archive/index.html#13">0.13</a></li>
<li><a href="/archive/index.html#12">0.12</a></li>
<li><a href="/archive/index.html#11">0.11</a></li>
<li><a href="/archive/index.html#10">0.10</a></li>
@@ -144,7 +146,7 @@
limitations under the License.
-->
-<p>The <a href="https://github.com/apache/samza-hello-samza">hello-samza</a> project is a stand-alone project designed to help you run your first Samza job.</p>
+<p>The <a href="https://github.com/apache/samza-hello-samza">hello-samza</a> project is an example project designed to help you run your first Samza job.</p>
<h3 id="get-the-code">Get the Code</h3>
@@ -180,13 +182,13 @@ git checkout latest</code></pre></div>
<div class="highlight"><pre><code class="bash">mvn clean package
mkdir -p deploy/samza
-tar -xvf ./target/hello-samza-0.13.0-SNAPSHOT-dist.tar.gz -C deploy/samza</code></pre></div>
+tar -xvf ./target/hello-samza-0.13.1-SNAPSHOT-dist.tar.gz -C deploy/samza</code></pre></div>
<h3 id="run-a-samza-job">Run a Samza Job</h3>
-<p>After you’ve built your Samza package, you can start a job on the grid using the run-job.sh script.</p>
+<p>After you’ve built your Samza package, you can start a job on the grid using the run-app.sh script.</p>
-<div class="highlight"><pre><code class="bash">deploy/samza/bin/run-job.sh --config-factory<span class="o">=</span>org.apache.samza.config.factories.PropertiesConfigFactory --config-path<span class="o">=</span>file://<span class="nv">$PWD</span>/deploy/samza/config/wikipedia-feed.properties</code></pre></div>
+<div class="highlight"><pre><code class="bash">deploy/samza/bin/run-app.sh --config-factory<span class="o">=</span>org.apache.samza.config.factories.PropertiesConfigFactory --config-path<span class="o">=</span>file://<span class="nv">$PWD</span>/deploy/samza/config/wikipedia-feed.properties</code></pre></div>
<p>The job will consume a feed of real-time edits from Wikipedia, and produce them to a Kafka topic called “wikipedia-raw”. Give the job a minute to startup, and then tail the Kafka topic:</p>
@@ -200,8 +202,8 @@ tar -xvf ./target/hello-samza-0.13.0-SNA
<p>Let’s calculate some statistics based on the messages in the wikipedia-raw topic. Start two more jobs:</p>
-<div class="highlight"><pre><code class="bash">deploy/samza/bin/run-job.sh --config-factory<span class="o">=</span>org.apache.samza.config.factories.PropertiesConfigFactory --config-path<span class="o">=</span>file://<span class="nv">$PWD</span>/deploy/samza/config/wikipedia-parser.properties
-deploy/samza/bin/run-job.sh --config-factory<span class="o">=</span>org.apache.samza.config.factories.PropertiesConfigFactory --config-path<span class="o">=</span>file://<span class="nv">$PWD</span>/deploy/samza/config/wikipedia-stats.properties</code></pre></div>
+<div class="highlight"><pre><code class="bash">deploy/samza/bin/run-app.sh --config-factory<span class="o">=</span>org.apache.samza.config.factories.PropertiesConfigFactory --config-path<span class="o">=</span>file://<span class="nv">$PWD</span>/deploy/samza/config/wikipedia-parser.properties
+deploy/samza/bin/run-app.sh --config-factory<span class="o">=</span>org.apache.samza.config.factories.PropertiesConfigFactory --config-path<span class="o">=</span>file://<span class="nv">$PWD</span>/deploy/samza/config/wikipedia-stats.properties</code></pre></div>
<p>The first job (wikipedia-parser) parses the messages in wikipedia-raw, and extracts information about the size of the edit, who made the change, etc. You can take a look at its output with:</p>
@@ -222,6 +224,10 @@ deploy/samza/bin/run-job.sh --config-fac
<h3 id="shutdown">Shutdown</h3>
+<p>To shutdown one of the jobs, use the same script with an extra ‘–operation=kill’ argument</p>
+
+<div class="highlight"><pre><code class="bash">deploy/samza/bin/run-app.sh --config-factory<span class="o">=</span>org.apache.samza.config.factories.PropertiesConfigFactory --config-path<span class="o">=</span>file://<span class="nv">$PWD</span>/deploy/samza/config/wikipedia-feed.properties --operation<span class="o">=</span><span class="nb">kill</span></code></pre></div>
+
<p>After you’re done, you can clean everything up using the same grid script.</p>
<div class="highlight"><pre><code class="bash">bin/grid stop all</code></pre></div>
@@ -244,7 +250,7 @@ deploy/samza/bin/run-job.sh --config-fac
<script>
$( document ).ready(function() {
- if ( $.fn.urlExists( "/startup/hello-samza/0.12/index.html" ) ) {
+ if ( $.fn.urlExists( "/startup/hello-samza/0.13/index.html" ) ) {
$("#switch-version-button").addClass("fa fa-history masthead-icon");
}
});
Modified: samza/site/startup/preview/index.html
URL: http://svn.apache.org/viewvc/samza/site/startup/preview/index.html?rev=1798258&r1=1798257&r2=1798258&view=diff
==============================================================================
--- samza/site/startup/preview/index.html (original)
+++ samza/site/startup/preview/index.html Fri Jun 9 18:46:20 2017
@@ -95,6 +95,7 @@
<h1><i class="fa fa-history"></i> Archive</h1>
<ul>
<li><a href="/archive/index.html#latest">latest</a></li>
+ <li><a href="/archive/index.html#13">0.13</a></li>
<li><a href="/archive/index.html#12">0.12</a></li>
<li><a href="/archive/index.html#11">0.11</a></li>
<li><a href="/archive/index.html#10">0.10</a></li>
@@ -162,9 +163,9 @@
<p>Want to skip all the details and get some hands on experience? There are three tutorials to help you get acquainted with running Samza applications in both YARN and embedded modes and programming with the high level API:</p>
<ul>
-<li><a href="/learn/tutorials/0.13/hello-samza-high-level-yarn.html">Yarn Deployment</a> - run a pre-existing Wikipedia application on YARN and observe the output.</li>
-<li><a href="/learn/tutorials/0.13/hello-samza-high-level-code.html">High Level API Code Walkthrough</a> - walk through building the Wikipedia application, step by step.</li>
-<li><a href="/learn/tutorials/0.13/hello-samza-high-level-zk.html">ZooKeeper Deployment</a> - run a pre-existing Wikipedia application with ZooKeeper coordination and observe the output.</li>
+<li><a href="/learn/tutorials/latest/hello-samza-high-level-yarn.html">Yarn Deployment</a> - run a pre-existing Wikipedia application on YARN and observe the output.</li>
+<li><a href="/learn/tutorials/latest/hello-samza-high-level-code.html">High Level API Code Walkthrough</a> - walk through building the Wikipedia application, step by step.</li>
+<li><a href="/learn/tutorials/latest/hello-samza-high-level-zk.html">ZooKeeper Deployment</a> - run a pre-existing Wikipedia application with ZooKeeper coordination and observe the output.</li>
</ul>
<hr>
@@ -179,19 +180,19 @@
<p>The Samza architecture has been overhauled with distinct layers to handle each stage of application development. The following diagram shows an overview of Apache Samza architecture with the high level API.</p>
-<p><img src="/img/0.13/learn/documentation/introduction/layered-arch.png" alt="Architecture diagram" style="max-width: 100%; height: auto;" onclick="window.open(this.src)"></p>
+<p><img src="/img/latest/learn/documentation/introduction/layered-arch.png" alt="Architecture diagram" style="max-width: 100%; height: auto;" onclick="window.open(this.src)"></p>
<p>There are four layers in the architecture. The following sections describe each of the layers.</p>
<h4 id="i.-high-level-api">I. High Level API</h4>
-<p>The high level API provides the libraries to define your application logic. The <a href="/learn/documentation/0.13/api/javadocs/org/apache/samza/application/StreamApplication.html">StreamApplication</a> is the central abstraction which your application must implement. You start by declaring your inputs as instances of <a href="/learn/documentation/0.13/api/javadocs/org/apache/samza/operators/MessageStream.html">MessageStream</a>. Then you can apply operators on each MessageStream like map, filter, window, and join to define the whole end-to-end data processing in a single program.</p>
+<p>The high level API provides the libraries to define your application logic. The <a href="/learn/documentation/latest/api/javadocs/org/apache/samza/application/StreamApplication.html">StreamApplication</a> is the central abstraction which your application must implement. You start by declaring your inputs as instances of <a href="/learn/documentation/latest/api/javadocs/org/apache/samza/operators/MessageStream.html">MessageStream</a>. Then you can apply operators on each MessageStream like map, filter, window, and join to define the whole end-to-end data processing in a single program.</p>
<p>For a deeper dive into the high level API, see <a href="#high-level-api">high level API section</a> below.</p>
<h4 id="ii.-applicationrunner">II. ApplicationRunner</h4>
-<p>Samza uses an <a href="/learn/documentation/0.13/api/javadocs/org/apache/samza/runtime/ApplicationRunner.html">ApplicationRunner</a> to run a stream application. The ApplicationRunner generates the configs (such as input/output streams), creates intermediate streams, and starts the execution. There are two types of ApplicationRunner:</p>
+<p>Samza uses an <a href="/learn/documentation/latest/api/javadocs/org/apache/samza/runtime/ApplicationRunner.html">ApplicationRunner</a> to run a stream application. The ApplicationRunner generates the configs (such as input/output streams), creates intermediate streams, and starts the execution. There are two types of ApplicationRunner:</p>
<p><strong>RemoteApplicationRunner</strong> - submits the application to a remote cluster. This runner is invoked via the <em>run-app.sh</em> script. To use RemoteApplicationRunner, set the following configurations</p>
@@ -199,7 +200,7 @@
<span class="na">app.class</span><span class="o">=</span><span class="s">com.company.job.YourStreamApplication</span>
<span class="na">job.factory.class</span><span class="o">=</span><span class="s">org.apache.samza.job.yarn.YarnJobFactory</span></code></pre></div>
-<p>Then use <em>run-app.sh</em> to run the application in the remote cluster. The script will invoke the RemoteApplicationRunner, which will launch one or more jobs using the factory specified with <em>job.factory.class</em>. Follow the <a href="/learn/tutorials/0.13/hello-samza-high-level-yarn.html">yarn deployment tutorial</a> to try it out.</p>
+<p>Then use <em>run-app.sh</em> to run the application in the remote cluster. The script will invoke the RemoteApplicationRunner, which will launch one or more jobs using the factory specified with <em>job.factory.class</em>. Follow the <a href="/learn/tutorials/latest/hello-samza-high-level-yarn.html">yarn deployment tutorial</a> to try it out.</p>
<p><strong>LocalApplicationRunner</strong> - runs the application in the JVM process of the runner. For example, to launch your application on multiple machines using ZooKeeper for coordination, you can run multiple instances of LocalApplicationRunner on various machines. After the applications load they will start cordinatinating their actions through ZooKeeper. Here is an example to run the StreamApplication in your program using the LocalApplicationRunner:</p>
@@ -215,7 +216,7 @@
<span class="n">System</span><span class="o">.</span><span class="na">out</span><span class="o">.</span><span class="na">println</span><span class="o">(</span><span class="s">"Application completed with status "</span> <span class="o">+</span> <span class="n">localRunner</span><span class="o">.</span><span class="na">status</span><span class="o">(</span><span class="n">app</span><span class="o">));</span>
<span class="o">}</span></code></pre></div>
-<p>Follow the <a href="/learn/tutorials/0.13/hello-samza-high-level-zk.html">ZooKeeper deployment tutorial</a> to try it out.</p>
+<p>Follow the <a href="/learn/tutorials/latest/hello-samza-high-level-zk.html">ZooKeeper deployment tutorial</a> to try it out.</p>
<h5 id="execution-plan">Execution Plan</h5>
@@ -228,7 +229,7 @@
<p>To view the plan, open the <em>bin/plan.html</em> file in a browser. Here’s a sample plan visualization:</p>
-<p><img src="/img/0.13/learn/documentation/introduction/execution-plan.png" alt="Execution plan" style="max-width: 100%; height: auto;" onclick="window.open(this.src)"/></p>
+<p><img src="/img/latest/learn/documentation/introduction/execution-plan.png" alt="Execution plan" style="max-width: 100%; height: auto;" onclick="window.open(this.src)"/></p>
<h4 id="iii.-execution-models">III. Execution Models</h4>
@@ -247,7 +248,7 @@
<h4 id="iv.-processor">IV. Processor</h4>
-<p>The lowest execution unit of a Samza application is the processor. It reads the configs generated from the <a href="/learn/documentation/0.13/api/javadocs/org/apache/samza/runtime/ApplicationRunner.html">ApplicationRunner</a> and processes the input stream partitions assigned by the JobCoordinator. It can access local state using a <a href="/learn/documentation/0.13/api/javadocs/org/apache/samza/storage/KeyValueStore.html">KeyValueStore</a> implementation (e.g. RocksDB or in-memory) and remote state (e.g. REST service) using multithreading.</p>
+<p>The lowest execution unit of a Samza application is the processor. It reads the configs generated from the <a href="/learn/documentation/latest/api/javadocs/org/apache/samza/runtime/ApplicationRunner.html">ApplicationRunner</a> and processes the input stream partitions assigned by the JobCoordinator. It can access local state using a <a href="/learn/documentation/latest/api/javadocs/org/apache/samza/storage/KeyValueStore.html">KeyValueStore</a> implementation (e.g. RocksDB or in-memory) and remote state (e.g. REST service) using multithreading.</p>
<hr>
@@ -270,7 +271,7 @@
<h3 id="streamapplication">StreamApplication</h3>
-<p>When writing your stream processing application using the Samza high-level API, you should implement a <a href="/learn/documentation/0.13/api/javadocs/org/apache/samza/application/StreamApplication.html">StreamApplication</a> and define your processing logic in the init method.</p>
+<p>When writing your stream processing application using the Samza high-level API, you should implement a <a href="/learn/documentation/latest/api/javadocs/org/apache/samza/application/StreamApplication.html">StreamApplication</a> and define your processing logic in the init method.</p>
<div class="highlight"><pre><code class="java"><span class="kd">public</span> <span class="kt">void</span> <span class="nf">init</span><span class="o">(</span><span class="n">StreamGraph</span> <span class="n">graph</span><span class="o">,</span> <span class="n">Config</span> <span class="n">config</span><span class="o">)</span> <span class="o">{</span> <span class="err">â¦</span> <span class="o">}</span></code></pre></div>
@@ -343,11 +344,11 @@
<h2 id="operators">Operators</h2>
-<p>The high level API supports common operators like map, flatmap, filter, merge, joins, and windowing on streams. Most of these operators accept corresponding Functions and these functions are <a href="/learn/documentation/0.13/api/javadocs/org/apache/samza/operators/functions/InitableFunction.html">Initable</a>.</p>
+<p>The high level API supports common operators like map, flatmap, filter, merge, joins, and windowing on streams. Most of these operators accept corresponding Functions and these functions are <a href="/learn/documentation/latest/api/javadocs/org/apache/samza/operators/functions/InitableFunction.html">Initable</a>.</p>
<h3 id="map">Map</h3>
-<p>Applies the provided 1:1 <a href="/learn/documentation/0.13/api/javadocs/org/apache/samza/operators/functions/MapFunction.html">MapFunction</a> to each element in the MessageStream and returns the transformed MessageStream. The MapFunction takes in a single message and returns a single message (potentially of a different type).</p>
+<p>Applies the provided 1:1 <a href="/learn/documentation/latest/api/javadocs/org/apache/samza/operators/functions/MapFunction.html">MapFunction</a> to each element in the MessageStream and returns the transformed MessageStream. The MapFunction takes in a single message and returns a single message (potentially of a different type).</p>
<div class="highlight"><pre><code class="java"><span class="n">MessageStream</span><span class="o"><</span><span class="n">Integer</span><span class="o">></span> <span class="n">numbers</span> <span class="o">=</span> <span class="o">...</span>
<span class="n">MessageStream</span><span class="o"><</span><span class="n">Integer</span><span class="o">></span> <span class="n">tripled</span><span class="o">=</span> <span class="n">numbers</span><span class="o">.</span><span class="na">map</span><span class="o">(</span><span class="n">m</span> <span class="o">-></span> <span class="n">m</span> <span class="o">*</span> <span class="mi">3</span><span class="o">)</span>
@@ -355,7 +356,7 @@
<h3 id="flatmap">Flatmap</h3>
-<p>Applies the provided 1:n <a href="/learn/documentation/0.13/api/javadocs/org/apache/samza/operators/functions/FlatMapFunction.html">FlatMapFunction</a> to each element in the MessageStream and returns the transformed MessageStream. The FlatMapFunction takes in a single message and returns zero or more messages.</p>
+<p>Applies the provided 1:n <a href="/learn/documentation/latest/api/javadocs/org/apache/samza/operators/functions/FlatMapFunction.html">FlatMapFunction</a> to each element in the MessageStream and returns the transformed MessageStream. The FlatMapFunction takes in a single message and returns zero or more messages.</p>
<div class="highlight"><pre><code class="java"><span class="n">MessageStream</span><span class="o"><</span><span class="n">String</span><span class="o">></span> <span class="n">sentence</span> <span class="o">=</span> <span class="o">...</span>
<span class="c1">// Parse the sentence into its individual words splitting by space</span>
@@ -364,7 +365,7 @@
<h3 id="filter">Filter</h3>
-<p>Applies the provided <a href="/learn/documentation/0.13/api/javadocs/org/apache/samza/operators/functions/FilterFunction.html">FilterFunction</a> to the MessageStream and returns the filtered MessageStream. The FilterFunction is a predicate that specifies whether a message should be retained in the filtered stream. Messages for which the FilterFunction returns false are filtered out.</p>
+<p>Applies the provided <a href="/learn/documentation/latest/api/javadocs/org/apache/samza/operators/functions/FilterFunction.html">FilterFunction</a> to the MessageStream and returns the filtered MessageStream. The FilterFunction is a predicate that specifies whether a message should be retained in the filtered stream. Messages for which the FilterFunction returns false are filtered out.</p>
<div class="highlight"><pre><code class="java"><span class="n">MessageStream</span><span class="o"><</span><span class="n">String</span><span class="o">></span> <span class="n">words</span> <span class="o">=</span> <span class="o">...</span>
<span class="c1">// Extract only the long words</span>
@@ -392,7 +393,7 @@
<p>The merge transform preserves the order of each MessageStream, so if message <code>m1</code> appears before <code>m2</code> in any provided stream, then, <code>m1</code> also appears before <code>m2</code> in the merged stream.</p>
-<p>As an alternative to the <code>merge</code> instance method, you also can use the <a href="/learn/documentation/0.13/api/javadocs/org/apache/samza/operators/MessageStream.html#mergeAll-java.util.Collection-">MessageStream#mergeAll</a> static method to merge MessageStreams without operating on an initial stream.</p>
+<p>As an alternative to the <code>merge</code> instance method, you also can use the <a href="/learn/documentation/latest/api/javadocs/org/apache/samza/operators/MessageStream.html#mergeAll-java.util.Collection-">MessageStream#mergeAll</a> static method to merge MessageStreams without operating on an initial stream.</p>
<h3 id="sendto">SendTo</h3>
@@ -408,7 +409,7 @@
<h3 id="sink">Sink</h3>
-<p>Allows sending messages from this MessageStream to an output system using the provided <a href="/learn/documentation/0.13/api/javadocs/org/apache/samza/operators/functions/SinkFunction.html">SinkFunction</a>.</p>
+<p>Allows sending messages from this MessageStream to an output system using the provided <a href="/learn/documentation/latest/api/javadocs/org/apache/samza/operators/functions/SinkFunction.html">SinkFunction</a>.</p>
<p>This offers more control than sendTo since the SinkFunction has access to the <code>MessageCollector</code> and the <code>TaskCoordinator</code>. For instance, you can choose to manually commit offsets, or shut-down the job using the TaskCoordinator APIs. This operator can also be used to send messages to non-Samza systems (e.g. remote databases, REST services, etc.)</p>
@@ -422,7 +423,7 @@
<h3 id="join">Join</h3>
-<p>The Join operator joins messages from two MessageStreams using the provided pairwise <a href="/learn/documentation/0.13/api/javadocs/org/apache/samza/operators/functions/JoinFunction.html">JoinFunction</a>. Messages are joined when the keys extracted from messages from the first stream match keys extracted from messages in the second stream. Messages in each stream are retained for the provided ttl duration and join results are emitted as matches are found.</p>
+<p>The Join operator joins messages from two MessageStreams using the provided pairwise <a href="/learn/documentation/latest/api/javadocs/org/apache/samza/operators/functions/JoinFunction.html">JoinFunction</a>. Messages are joined when the keys extracted from messages from the first stream match keys extracted from messages in the second stream. Messages in each stream are retained for the provided ttl duration and join results are emitted as matches are found.</p>
<div class="highlight"><pre><code class="java"><span class="c1">// Joins a stream of OrderRecord with a stream of ShipmentRecord by orderId with a TTL of 20 minutes.</span>
<span class="c1">// Results are produced to a new stream of FulfilledOrderRecord.</span>
@@ -455,9 +456,9 @@
<p><strong>Windows, Triggers, and WindowPanes</strong>: The window operator groups incoming messages in the MessageStream into finite windows. Each emitted result contains one or more messages in the window and is called a WindowPane.</p>
-<p>A window can have one or more associated triggers which determine when results from the window are emitted. Triggers can be either <a href="/learn/documentation/0.13/api/javadocs/org/apache/samza/operators/windows/Window.html#setEarlyTrigger-org.apache.samza.operators.triggers.Trigger-">early triggers</a> that allow emitting results speculatively before all data for the window has arrived, or late triggers that allow handling late messages for the window.</p>
+<p>A window can have one or more associated triggers which determine when results from the window are emitted. Triggers can be either <a href="/learn/documentation/latest/api/javadocs/org/apache/samza/operators/windows/Window.html#setEarlyTrigger-org.apache.samza.operators.triggers.Trigger-">early triggers</a> that allow emitting results speculatively before all data for the window has arrived, or late triggers that allow handling late messages for the window.</p>
-<p><strong>Aggregator Function</strong>: By default, the emitted WindowPane will contain all the messages for the window. Instead of retaining all messages, you typically define a more compact data structure for the WindowPane and update it incrementally as new messages arrive, e.g. for keeping a count of messages in the window. To do this, you can provide an aggregating <a href="/learn/documentation/0.13/api/javadocs/org/apache/samza/operators/functions/FoldLeftFunction.html">FoldLeftFunction</a> which is invoked for each incoming message added to the window and defines how to update the WindowPane for that message.</p>
+<p><strong>Aggregator Function</strong>: By default, the emitted WindowPane will contain all the messages for the window. Instead of retaining all messages, you typically define a more compact data structure for the WindowPane and update it incrementally as new messages arrive, e.g. for keeping a count of messages in the window. To do this, you can provide an aggregating <a href="/learn/documentation/latest/api/javadocs/org/apache/samza/operators/functions/FoldLeftFunction.html">FoldLeftFunction</a> which is invoked for each incoming message added to the window and defines how to update the WindowPane for that message.</p>
<p><strong>Accumulation Mode</strong>: A windowâs accumulation mode determines how results emitted from a window relate to previously emitted results for the same window. This is particularly useful when the window is configured with early or late triggers. The accumulation mode can either be discarding or accumulating.</p>
@@ -536,7 +537,7 @@
<h4 id="external-partition-management">External Partition Management</h4>
-<p>With external partition management, Samza doesnât manage the partitioning by itself. Instead it uses a <code>PassthroughJobCoordinator</code> which honors whatever partition mapping is provided by the <a href="/learn/documentation/0.13/api/javadocs/org/apache/samza/container/grouper/stream/SystemStreamPartitionGrouper.html">SystemStreamPartitionGrouper</a>. There are two common patterns for external partition management:</p>
+<p>With external partition management, Samza doesnât manage the partitioning by itself. Instead it uses a <code>PassthroughJobCoordinator</code> which honors whatever partition mapping is provided by the <a href="/learn/documentation/latest/api/javadocs/org/apache/samza/container/grouper/stream/SystemStreamPartitionGrouper.html">SystemStreamPartitionGrouper</a>. There are two common patterns for external partition management:</p>
<ul>
<li><strong>Using high level Kafka consumer</strong> - partition assignment is done by the high level Kafka consumer itself. To use this model, you need to implement and configure a SystemFactory which provides the Kafka high level consumer. Then you need to configure <em>job.systemstreampartition.grouper.factory</em> to <em>org.apache.samza.container.grouper.stream.AllSspToSingleTaskGrouper</em> so Kafka’s partition assignments all go to one task.</li>
@@ -580,7 +581,7 @@ There is one leader processor which gene
<p>The following diagram shows the relationships of the coordinators in the ZooKeeper coordination service implementation.</p>
-<p><img src="/img/0.13/learn/documentation/introduction/coordination-service.png" alt="Coordination service diagram" style="max-width: 100%; height: auto;" onclick="window.open(this.src)"></p>
+<p><img src="/img/latest/learn/documentation/introduction/coordination-service.png" alt="Coordination service diagram" style="max-width: 100%; height: auto;" onclick="window.open(this.src)"></p>
<p>Here are a few important details about the coordination service:</p>
@@ -594,7 +595,7 @@ There is one leader processor which gene
<p>Embedded deployment is designed to help users who want more control over the deployment of their application. So it is the user’s responsibility to configure and deploy the processors. In case of ZooKeeper coordination, you also need to configure the URL for an instance of ZooKeeper.</p>
-<p>Additionally, each processor requires a unique ID to be used with the coordination service. If location affinity is important, this ID should be unique for each processor on a specific hostname (assuming local Storage services). To address this requirement, Samza uses a <a href="/learn/documentation/0.13/api/javadocs/org/apache/samza/runtime/ProcessorIdGenerator.html">ProcessorIdGenerator</a> to provide the ID for each processor. If no generator is explicitly configured, the default one will create a UUID for each processor.</p>
+<p>Additionally, each processor requires a unique ID to be used with the coordination service. If location affinity is important, this ID should be unique for each processor on a specific hostname (assuming local Storage services). To address this requirement, Samza uses a <a href="/learn/documentation/latest/api/javadocs/org/apache/samza/runtime/ProcessorIdGenerator.html">ProcessorIdGenerator</a> to provide the ID for each processor. If no generator is explicitly configured, the default one will create a UUID for each processor.</p>
<h4 id="configuration">Configuration</h4>
@@ -634,7 +635,7 @@ There is one leader processor which gene
<p>In the code above, <code>WikipediaApplication</code> is an application written with the <a href="#high-level-api">high level API</a>.</p>
-<p>Check out the <a href="/learn/tutorials/0.13/hello-samza-high-level-zk.html">tutorial</a> to run this application with ZooKeeper coordination on your machine now.</p>
+<p>Check out the <a href="/learn/tutorials/latest/hello-samza-high-level-zk.html">tutorial</a> to run this application with ZooKeeper coordination on your machine now.</p>
<h4 id="deployment-and-scaling">Deployment and Scaling</h4>