You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by bo...@apache.org on 2019/06/12 17:07:48 UTC
svn commit: r1861168 [19/23] - in /samza/site: ./ archive/ blog/
case-studies/ community/ contribute/ learn/documentation/versioned/
learn/documentation/versioned/api/
learn/documentation/versioned/api/javadocs/
learn/documentation/versioned/api/javado...
Modified: samza/site/learn/documentation/versioned/api/test-framework.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/api/test-framework.html?rev=1861168&r1=1861167&r2=1861168&view=diff
==============================================================================
--- samza/site/learn/documentation/versioned/api/test-framework.html (original)
+++ samza/site/learn/documentation/versioned/api/test-framework.html Wed Jun 12 17:07:42 2019
@@ -227,6 +227,12 @@
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.2.0">1.2.0</a>
+
+
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.1.0">1.1.0</a>
+
+
<a class="side-navigation__group-item" data-match-active="" href="/releases/1.0.0">1.0.0</a>
@@ -514,6 +520,18 @@
+ <li class="hide"><a href="/learn/documentation/1.2/api/test-framework">1.2</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.1/api/test-framework">1.1</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.0/api/test-framework">1.0</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/0.14/api/test-framework">0.14</a></li>
@@ -534,10 +552,6 @@
- <li class="hide"><a href="/learn/documentation/1.0/api/test-framework">1.0</a></li>
-
-
-
<li class="hide"><a href="/learn/documentation/0.9/api/test-framework">0.9</a></li>
Modified: samza/site/learn/documentation/versioned/architecture/architecture-overview.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/architecture/architecture-overview.html?rev=1861168&r1=1861167&r2=1861168&view=diff
==============================================================================
--- samza/site/learn/documentation/versioned/architecture/architecture-overview.html (original)
+++ samza/site/learn/documentation/versioned/architecture/architecture-overview.html Wed Jun 12 17:07:42 2019
@@ -227,6 +227,12 @@
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.2.0">1.2.0</a>
+
+
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.1.0">1.1.0</a>
+
+
<a class="side-navigation__group-item" data-match-active="" href="/releases/1.0.0">1.0.0</a>
@@ -514,6 +520,18 @@
+ <li class="hide"><a href="/learn/documentation/1.2/architecture/architecture-overview">1.2</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.1/architecture/architecture-overview">1.1</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.0/architecture/architecture-overview">1.0</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/0.14/architecture/architecture-overview">0.14</a></li>
@@ -534,10 +552,6 @@
- <li class="hide"><a href="/learn/documentation/1.0/architecture/architecture-overview">1.0</a></li>
-
-
-
<li class="hide"><a href="/learn/documentation/0.9/architecture/architecture-overview">0.9</a></li>
Modified: samza/site/learn/documentation/versioned/architecture/kinesis.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/architecture/kinesis.html?rev=1861168&r1=1861167&r2=1861168&view=diff
==============================================================================
--- samza/site/learn/documentation/versioned/architecture/kinesis.html (original)
+++ samza/site/learn/documentation/versioned/architecture/kinesis.html Wed Jun 12 17:07:42 2019
@@ -227,6 +227,12 @@
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.2.0">1.2.0</a>
+
+
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.1.0">1.1.0</a>
+
+
<a class="side-navigation__group-item" data-match-active="" href="/releases/1.0.0">1.0.0</a>
@@ -514,6 +520,18 @@
+ <li class="hide"><a href="/learn/documentation/1.2/architecture/kinesis">1.2</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.1/architecture/kinesis">1.1</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.0/architecture/kinesis">1.0</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/0.14/architecture/kinesis">0.14</a></li>
@@ -534,10 +552,6 @@
- <li class="hide"><a href="/learn/documentation/1.0/architecture/kinesis">1.0</a></li>
-
-
-
<li class="hide"><a href="/learn/documentation/0.9/architecture/kinesis">0.9</a></li>
Modified: samza/site/learn/documentation/versioned/comparisons/introduction.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/comparisons/introduction.html?rev=1861168&r1=1861167&r2=1861168&view=diff
==============================================================================
--- samza/site/learn/documentation/versioned/comparisons/introduction.html (original)
+++ samza/site/learn/documentation/versioned/comparisons/introduction.html Wed Jun 12 17:07:42 2019
@@ -227,6 +227,12 @@
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.2.0">1.2.0</a>
+
+
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.1.0">1.1.0</a>
+
+
<a class="side-navigation__group-item" data-match-active="" href="/releases/1.0.0">1.0.0</a>
@@ -514,6 +520,18 @@
+ <li class="hide"><a href="/learn/documentation/1.2/comparisons/introduction">1.2</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.1/comparisons/introduction">1.1</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.0/comparisons/introduction">1.0</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/0.14/comparisons/introduction">0.14</a></li>
@@ -534,10 +552,6 @@
- <li class="hide"><a href="/learn/documentation/1.0/comparisons/introduction">1.0</a></li>
-
-
-
<li class="hide"><a href="/learn/documentation/0.9/comparisons/introduction">0.9</a></li>
Modified: samza/site/learn/documentation/versioned/comparisons/mupd8.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/comparisons/mupd8.html?rev=1861168&r1=1861167&r2=1861168&view=diff
==============================================================================
--- samza/site/learn/documentation/versioned/comparisons/mupd8.html (original)
+++ samza/site/learn/documentation/versioned/comparisons/mupd8.html Wed Jun 12 17:07:42 2019
@@ -227,6 +227,12 @@
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.2.0">1.2.0</a>
+
+
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.1.0">1.1.0</a>
+
+
<a class="side-navigation__group-item" data-match-active="" href="/releases/1.0.0">1.0.0</a>
@@ -514,6 +520,18 @@
+ <li class="hide"><a href="/learn/documentation/1.2/comparisons/mupd8">1.2</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.1/comparisons/mupd8">1.1</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.0/comparisons/mupd8">1.0</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/0.14/comparisons/mupd8">0.14</a></li>
@@ -534,10 +552,6 @@
- <li class="hide"><a href="/learn/documentation/1.0/comparisons/mupd8">1.0</a></li>
-
-
-
<li class="hide"><a href="/learn/documentation/0.9/comparisons/mupd8">0.9</a></li>
Modified: samza/site/learn/documentation/versioned/comparisons/spark-streaming.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/comparisons/spark-streaming.html?rev=1861168&r1=1861167&r2=1861168&view=diff
==============================================================================
--- samza/site/learn/documentation/versioned/comparisons/spark-streaming.html (original)
+++ samza/site/learn/documentation/versioned/comparisons/spark-streaming.html Wed Jun 12 17:07:42 2019
@@ -227,6 +227,12 @@
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.2.0">1.2.0</a>
+
+
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.1.0">1.1.0</a>
+
+
<a class="side-navigation__group-item" data-match-active="" href="/releases/1.0.0">1.0.0</a>
@@ -514,6 +520,18 @@
+ <li class="hide"><a href="/learn/documentation/1.2/comparisons/spark-streaming">1.2</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.1/comparisons/spark-streaming">1.1</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.0/comparisons/spark-streaming">1.0</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/0.14/comparisons/spark-streaming">0.14</a></li>
@@ -534,10 +552,6 @@
- <li class="hide"><a href="/learn/documentation/1.0/comparisons/spark-streaming">1.0</a></li>
-
-
-
<li class="hide"><a href="/learn/documentation/0.9/comparisons/spark-streaming">0.9</a></li>
Modified: samza/site/learn/documentation/versioned/comparisons/storm.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/comparisons/storm.html?rev=1861168&r1=1861167&r2=1861168&view=diff
==============================================================================
--- samza/site/learn/documentation/versioned/comparisons/storm.html (original)
+++ samza/site/learn/documentation/versioned/comparisons/storm.html Wed Jun 12 17:07:42 2019
@@ -227,6 +227,12 @@
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.2.0">1.2.0</a>
+
+
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.1.0">1.1.0</a>
+
+
<a class="side-navigation__group-item" data-match-active="" href="/releases/1.0.0">1.0.0</a>
@@ -514,6 +520,18 @@
+ <li class="hide"><a href="/learn/documentation/1.2/comparisons/storm">1.2</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.1/comparisons/storm">1.1</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.0/comparisons/storm">1.0</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/0.14/comparisons/storm">0.14</a></li>
@@ -534,10 +552,6 @@
- <li class="hide"><a href="/learn/documentation/1.0/comparisons/storm">1.0</a></li>
-
-
-
<li class="hide"><a href="/learn/documentation/0.9/comparisons/storm">0.9</a></li>
Modified: samza/site/learn/documentation/versioned/connectors/eventhubs.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/connectors/eventhubs.html?rev=1861168&r1=1861167&r2=1861168&view=diff
==============================================================================
--- samza/site/learn/documentation/versioned/connectors/eventhubs.html (original)
+++ samza/site/learn/documentation/versioned/connectors/eventhubs.html Wed Jun 12 17:07:42 2019
@@ -227,6 +227,12 @@
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.2.0">1.2.0</a>
+
+
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.1.0">1.1.0</a>
+
+
<a class="side-navigation__group-item" data-match-active="" href="/releases/1.0.0">1.0.0</a>
@@ -514,6 +520,18 @@
+ <li class="hide"><a href="/learn/documentation/1.2/connectors/eventhubs">1.2</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.1/connectors/eventhubs">1.1</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.0/connectors/eventhubs">1.0</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/0.14/connectors/eventhubs">0.14</a></li>
@@ -534,10 +552,6 @@
- <li class="hide"><a href="/learn/documentation/1.0/connectors/eventhubs">1.0</a></li>
-
-
-
<li class="hide"><a href="/learn/documentation/0.9/connectors/eventhubs">0.9</a></li>
@@ -587,7 +601,7 @@
<p>The Samza EventHubs connector provides access to <a href="https://docs.microsoft.com/en-us/azure/event-hubs/event-hubs-features">Azure EventHubs</a>, Microsoftâs data streaming service on Azure. An eventhub is similar to a Kafka topic and can have multiple partitions with producers and consumers. Each message produced or consumed from an event hub is an instance of <a href="https://docs.microsoft.com/en-us/java/api/com.microsoft.azure.eventhubs._event_data">EventData</a>. </p>
-<p>The <a href="https://github.com/apache/samza-hello-samza">hello-samza</a> project includes an <a href="../../../tutorials/versioned/samza-event-hubs-standalone.md">example</a> of reading and writing to EventHubs.</p>
+<p>The <a href="https://github.com/apache/samza-hello-samza">hello-samza</a> project includes an <a href="../../../tutorials/versioned/samza-event-hubs-standalone.html">example</a> of reading and writing to EventHubs.</p>
<h3 id="concepts">Concepts</h3>
Modified: samza/site/learn/documentation/versioned/connectors/hdfs.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/connectors/hdfs.html?rev=1861168&r1=1861167&r2=1861168&view=diff
==============================================================================
--- samza/site/learn/documentation/versioned/connectors/hdfs.html (original)
+++ samza/site/learn/documentation/versioned/connectors/hdfs.html Wed Jun 12 17:07:42 2019
@@ -227,6 +227,12 @@
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.2.0">1.2.0</a>
+
+
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.1.0">1.1.0</a>
+
+
<a class="side-navigation__group-item" data-match-active="" href="/releases/1.0.0">1.0.0</a>
@@ -514,6 +520,18 @@
+ <li class="hide"><a href="/learn/documentation/1.2/connectors/hdfs">1.2</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.1/connectors/hdfs">1.1</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.0/connectors/hdfs">1.0</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/0.14/connectors/hdfs">0.14</a></li>
@@ -534,10 +552,6 @@
- <li class="hide"><a href="/learn/documentation/1.0/connectors/hdfs">1.0</a></li>
-
-
-
<li class="hide"><a href="/learn/documentation/0.9/connectors/hdfs">0.9</a></li>
@@ -612,12 +626,10 @@ To interact with HDFS, Samza requires yo
<h4 id="defining-streams">Defining streams</h4>
-<p>Samza uses the notion of a <em>system</em> to describe any I/O source it interacts with. To consume from HDFS, you should create a new system that points to - <code>HdfsSystemFactory</code>. You can then associate multiple streams with this <em>system</em>. Each stream should have a <em>physical name</em>, which should be set to the name of the directory on HDFS.</p>
-
-<figure class="highlight"><pre><code class="language-jproperties" data-lang="jproperties"><span></span><span class="na">systems.hdfs.samza.factory</span><span class="o">=</span><span class="s">org.apache.samza.system.hdfs.HdfsSystemFactory</span>
+<p>In Samza high level API, you can use <code>HdfsSystemDescriptor</code> to create a HDFS system. The stream name should be set to the name of the directory on HDFS.</p>
-<span class="na">streams.hdfs-clickstream.samza.system</span><span class="o">=</span><span class="s">hdfs</span>
-<span class="na">streams.hdfs-clickstream.samza.physical.name</span><span class="o">=</span><span class="s">hdfs:/data/clickstream/2016/09/11</span></code></pre></figure>
+<figure class="highlight"><pre><code class="language-java" data-lang="java"><span></span><span class="n">HdfsSystemDescriptor</span> <span class="n">hsd</span> <span class="o">=</span> <span class="k">new</span> <span class="n">HdfsSystemDescriptor</span><span class="o">(</span><span class="s">"hdfs-clickstream"</span><span class="o">);</span>
+<span class="n">HdfsInputDescriptor</span> <span class="n">hid</span> <span class="o">=</span> <span class="n">hsd</span><span class="o">.</span><span class="na">getInputDescriptor</span><span class="o">(</span><span class="s">"/data/clickstream/2016/09/11"</span><span class="o">);</span></code></pre></figure>
<p>The above example defines a stream called <code>hdfs-clickstream</code> that reads data from the <code>/data/clickstream/2016/09/11</code> directory. </p>
@@ -625,8 +637,9 @@ To interact with HDFS, Samza requires yo
<p>If you only want to consume from files that match a certain pattern, you can configure a whitelist. Likewise, you can also blacklist consuming from certain files. When both are specified, the <em>whitelist</em> selects the files to be filtered and the <em>blacklist</em> is later applied on its results. </p>
-<figure class="highlight"><pre><code class="language-jproperties" data-lang="jproperties"><span></span><span class="na">systems.hdfs.partitioner.defaultPartitioner.whitelist</span><span class="o">=</span><span class="s">.*avro</span>
-<span class="na">systems.hdfs.partitioner.defaultPartitioner.blacklist</span><span class="o">=</span><span class="s">somefile.avro</span></code></pre></figure>
+<figure class="highlight"><pre><code class="language-java" data-lang="java"><span></span><span class="n">HdfsSystemDescriptor</span> <span class="n">hsd</span> <span class="o">=</span> <span class="k">new</span> <span class="n">HdfsSystemDescriptor</span><span class="o">(</span><span class="s">"hdfs-clickstream"</span><span class="o">)</span>
+ <span class="o">.</span><span class="na">withConsumerWhiteList</span><span class="o">(</span><span class="s">".*avro"</span><span class="o">)</span>
+ <span class="o">.</span><span class="na">withConsumerBlackList</span><span class="o">(</span><span class="s">"somefile.avro"</span><span class="o">);</span></code></pre></figure>
<h3 id="producing-to-hdfs">Producing to HDFS</h3>
@@ -634,27 +647,27 @@ To interact with HDFS, Samza requires yo
<p>Samza allows writing your output results to HDFS in AVRO format. You can either use avro’s GenericRecords or have Samza automatically infer the schema for your object using reflection. </p>
-<figure class="highlight"><pre><code class="language-jproperties" data-lang="jproperties"><span></span><span class="c"># set the SystemFactory implementation to instantiate HdfsSystemProducer aliased to 'hdfs'</span>
-<span class="na">systems.hdfs.samza.factory</span><span class="o">=</span><span class="s">org.apache.samza.system.hdfs.HdfsSystemFactory</span>
-<span class="na">systems.hdfs.producer.hdfs.writer.class</span><span class="o">=</span><span class="s">org.apache.samza.system.hdfs.writer.AvroDataFileHdfsWriter</span></code></pre></figure>
-
-<p>If your output is non-avro, you can describe its format by implementing your own serializer.</p>
-
-<figure class="highlight"><pre><code class="language-jproperties" data-lang="jproperties"><span></span><span class="na">systems.hdfs.producer.hdfs.writer.class</span><span class="o">=</span><span class="s">org.apache.samza.system.hdfs.writer.TextSequenceFileHdfsWriter</span>
-<span class="na">serializers.registry.my-serde-name.class</span><span class="o">=</span><span class="s">MySerdeFactory</span>
-<span class="na">systems.hdfs.samza.msg.serde</span><span class="o">=</span><span class="s">my-serde-name</span></code></pre></figure>
+<figure class="highlight"><pre><code class="language-java" data-lang="java"><span></span><span class="n">HdfsSystemDescriptor</span> <span class="n">hsd</span> <span class="o">=</span> <span class="k">new</span> <span class="n">HdfsSystemDescriptor</span><span class="o">(</span><span class="s">"hdfs-clickstream"</span><span class="o">)</span>
+ <span class="o">.</span><span class="na">withWriterClassName</span><span class="o">(</span><span class="n">AvroDataFileHdfsWriter</span><span class="o">.</span><span class="na">class</span><span class="o">.</span><span class="na">getName</span><span class="o">());</span></code></pre></figure>
+
+<p>If your output is non-avro, use <code>TextSequenceFileHdfsWriter</code>.</p>
+
+<figure class="highlight"><pre><code class="language-java" data-lang="java"><span></span><span class="n">HdfsSystemDescriptor</span> <span class="n">hsd</span> <span class="o">=</span> <span class="k">new</span> <span class="n">HdfsSystemDescriptor</span><span class="o">(</span><span class="s">"hdfs-clickstream"</span><span class="o">)</span>
+ <span class="o">.</span><span class="na">withWriterClassName</span><span class="o">(</span><span class="n">TextSequenceFileHdfsWriter</span><span class="o">.</span><span class="na">class</span><span class="o">.</span><span class="na">getName</span><span class="o">());</span></code></pre></figure>
<h4 id="output-directory-structure">Output directory structure</h4>
<p>Samza allows you to control the base HDFS directory to write your output. You can also organize the output into sub-directories depending on the time your application ran, by configuring a date-formatter. </p>
-<figure class="highlight"><pre><code class="language-jproperties" data-lang="jproperties"><span></span><span class="na">systems.hdfs.producer.hdfs.base.output.dir</span><span class="o">=</span><span class="s">/user/me/analytics/clickstream_data</span>
-<span class="na">systems.hdfs.producer.hdfs.bucketer.date.path.format</span><span class="o">=</span><span class="s">yyyy_MM_dd</span></code></pre></figure>
+<figure class="highlight"><pre><code class="language-java" data-lang="java"><span></span><span class="n">HdfsSystemDescriptor</span> <span class="n">hsd</span> <span class="o">=</span> <span class="k">new</span> <span class="n">HdfsSystemDescriptor</span><span class="o">(</span><span class="s">"hdfs-clickstream"</span><span class="o">)</span>
+ <span class="o">.</span><span class="na">withOutputBaseDir</span><span class="o">(</span><span class="s">"/user/me/analytics/clickstream_data"</span><span class="o">)</span>
+ <span class="o">.</span><span class="na">withDatePathFormat</span><span class="o">(</span><span class="s">"yyyy_MM_dd"</span><span class="o">);</span></code></pre></figure>
<p>You can configure the maximum size of each file or the maximum number of records per-file. Once either limits have been reached, Samza will create a new file.</p>
-<figure class="highlight"><pre><code class="language-jproperties" data-lang="jproperties"><span></span><span class="na">systems.hdfs.producer.hdfs.write.batch.size.bytes</span><span class="o">=</span><span class="s">134217728</span>
-<span class="na">systems.hdfs.producer.hdfs.write.batch.size.records</span><span class="o">=</span><span class="s">10000</span></code></pre></figure>
+<figure class="highlight"><pre><code class="language-java" data-lang="java"><span></span><span class="n">HdfsSystemDescriptor</span> <span class="n">hsd</span> <span class="o">=</span> <span class="k">new</span> <span class="n">HdfsSystemDescriptor</span><span class="o">(</span><span class="s">"hdfs-clickstream"</span><span class="o">)</span>
+ <span class="o">.</span><span class="na">withWriteBatchSizeBytes</span><span class="o">(</span><span class="mi">134217728</span><span class="o">)</span>
+ <span class="o">.</span><span class="na">withWriteBatchSizeRecords</span><span class="o">(</span><span class="mi">10000</span><span class="o">);</span></code></pre></figure>
<h3 id="security">Security</h3>
Modified: samza/site/learn/documentation/versioned/connectors/kafka.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/connectors/kafka.html?rev=1861168&r1=1861167&r2=1861168&view=diff
==============================================================================
--- samza/site/learn/documentation/versioned/connectors/kafka.html (original)
+++ samza/site/learn/documentation/versioned/connectors/kafka.html Wed Jun 12 17:07:42 2019
@@ -227,6 +227,12 @@
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.2.0">1.2.0</a>
+
+
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.1.0">1.1.0</a>
+
+
<a class="side-navigation__group-item" data-match-active="" href="/releases/1.0.0">1.0.0</a>
@@ -514,6 +520,18 @@
+ <li class="hide"><a href="/learn/documentation/1.2/connectors/kafka">1.2</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.1/connectors/kafka">1.1</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.0/connectors/kafka">1.0</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/0.14/connectors/kafka">0.14</a></li>
@@ -534,10 +552,6 @@
- <li class="hide"><a href="/learn/documentation/1.0/connectors/kafka">1.0</a></li>
-
-
-
<li class="hide"><a href="/learn/documentation/0.9/connectors/kafka">0.9</a></li>
Modified: samza/site/learn/documentation/versioned/connectors/kinesis.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/connectors/kinesis.html?rev=1861168&r1=1861167&r2=1861168&view=diff
==============================================================================
--- samza/site/learn/documentation/versioned/connectors/kinesis.html (original)
+++ samza/site/learn/documentation/versioned/connectors/kinesis.html Wed Jun 12 17:07:42 2019
@@ -227,6 +227,12 @@
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.2.0">1.2.0</a>
+
+
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.1.0">1.1.0</a>
+
+
<a class="side-navigation__group-item" data-match-active="" href="/releases/1.0.0">1.0.0</a>
@@ -514,6 +520,18 @@
+ <li class="hide"><a href="/learn/documentation/1.2/connectors/kinesis">1.2</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.1/connectors/kinesis">1.1</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.0/connectors/kinesis">1.0</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/0.14/connectors/kinesis">0.14</a></li>
@@ -534,10 +552,6 @@
- <li class="hide"><a href="/learn/documentation/1.0/connectors/kinesis">1.0</a></li>
-
-
-
<li class="hide"><a href="/learn/documentation/0.9/connectors/kinesis">0.9</a></li>
@@ -600,21 +614,15 @@ wraps the Record into a <a href="https:/
<h4 id="basic-configuration">Basic Configuration</h4>
-<p>Here is the required configuration for consuming messages from Kinesis. </p>
+<p>Here is the required configuration for consuming messages from Kinesis, through <code>KinesisSystemDescriptor</code> and <code>KinesisInputDescriptor</code>. </p>
-<figure class="highlight"><pre><code class="language-jproperties" data-lang="jproperties"><span></span><span class="c">// Define a Kinesis system factory with your identifier. eg: kinesis-system</span>
-<span class="na">systems.kinesis-system.samza.factory</span><span class="o">=</span><span class="s">org.apache.samza.system.kinesis.KinesisSystemFactory</span>
-
-<span class="c">// Kinesis consumer works with only AllSspToSingleTaskGrouperFactory</span>
-<span class="na">job.systemstreampartition.grouper.factory</span><span class="o">=</span><span class="s">org.apache.samza.container.grouper.stream.AllSspToSingleTaskGrouperFactory</span>
-
-<span class="c">// Define your streams</span>
-<span class="na">task.inputs</span><span class="o">=</span><span class="s">kinesis-system.input0</span>
-
-<span class="c">// Define required properties for your streams</span>
-<span class="na">systems.kinesis-system.streams.input0.aws.region</span><span class="o">=</span><span class="s">YOUR-STREAM-REGION</span>
-<span class="na">systems.kinesis-system.streams.input0.aws.accessKey</span><span class="o">=</span><span class="s">YOUR-ACCESS_KEY</span>
-<span class="na">sensitive.systems.kinesis-system.streams.input0.aws.secretKey</span><span class="o">=</span><span class="s">YOUR-SECRET-KEY</span></code></pre></figure>
+<figure class="highlight"><pre><code class="language-java" data-lang="java"><span></span><span class="n">KinesisSystemDescriptor</span> <span class="n">ksd</span> <span class="o">=</span> <span class="k">new</span> <span class="n">KinesisSystemDescriptor</span><span class="o">(</span><span class="s">"kinesis"</span><span class="o">);</span>
+
+<span class="n">KinesisInputDescriptor</span><span class="o"><</span><span class="n">KV</span><span class="o"><</span><span class="n">String</span><span class="o">,</span> <span class="kt">byte</span><span class="o">[]>></span> <span class="n">kid</span> <span class="o">=</span>
+ <span class="n">ksd</span><span class="o">.</span><span class="na">getInputDescriptor</span><span class="o">(</span><span class="s">"STREAM-NAME"</span><span class="o">,</span> <span class="k">new</span> <span class="n">NoOpSerde</span><span class="o"><</span><span class="kt">byte</span><span class="o">[]>())</span>
+ <span class="o">.</span><span class="na">withRegion</span><span class="o">(</span><span class="s">"STREAM-REGION"</span><span class="o">)</span>
+ <span class="o">.</span><span class="na">withAccessKey</span><span class="o">(</span><span class="s">"YOUR-ACCESS_KEY"</span><span class="o">)</span>
+ <span class="o">.</span><span class="na">withSecretKey</span><span class="o">(</span><span class="s">"YOUR-SECRET-KEY"</span><span class="o">);</span></code></pre></figure>
<h4 id="coordination">Coordination</h4>
@@ -627,9 +635,11 @@ set your <code>grouper</code> configurat
<p>Each Kinesis stream in a given AWS <a href="https://docs.aws.amazon.com/AmazonRDS/latest/UserGuide/Concepts.RegionsAndAvailabilityZones.html">region</a> can be accessed by providing an <a href="https://docs.aws.amazon.com/general/latest/gr/aws-sec-cred-types.html#access-keys-and-secret-access-keys">access key</a>. An Access key consists of two parts: an access key ID (for example, <code>AKIAIOSFODNN7EXAMPLE</code>) and a secret access key (for example, <code>wJalrXUtnFEMI/K7MDENG/bPxRfiCYEXAMPLEKEY</code>) which you can use to send programmatic requests to AWS. </p>
-<figure class="highlight"><pre><code class="language-jproperties" data-lang="jproperties"><span></span><span class="na">systems.kinesis-system.streams.input0.aws.region</span><span class="o">=</span><span class="s">YOUR-STREAM-REGION</span>
-<span class="na">systems.kinesis-system.streams.input0.aws.accessKey</span><span class="o">=</span><span class="s">YOUR-ACCESS_KEY</span>
-<span class="na">sensitive.systems.kinesis-system.streams.input0.aws.secretKey</span><span class="o">=</span><span class="s">YOUR-SECRET-KEY</span></code></pre></figure>
+<figure class="highlight"><pre><code class="language-java" data-lang="java"><span></span><span class="n">KinesisInputDescriptor</span><span class="o"><</span><span class="n">KV</span><span class="o"><</span><span class="n">String</span><span class="o">,</span> <span class="kt">byte</span><span class="o">[]>></span> <span class="n">kid</span> <span class="o">=</span>
+ <span class="n">ksd</span><span class="o">.</span><span class="na">getInputDescriptor</span><span class="o">(</span><span class="s">"STREAM-NAME"</span><span class="o">,</span> <span class="k">new</span> <span class="n">NoOpSerde</span><span class="o"><</span><span class="kt">byte</span><span class="o">[]>())</span>
+ <span class="o">.</span><span class="na">withRegion</span><span class="o">(</span><span class="s">"STREAM-REGION"</span><span class="o">)</span>
+ <span class="o">.</span><span class="na">withAccessKey</span><span class="o">(</span><span class="s">"YOUR-ACCESS_KEY"</span><span class="o">)</span>
+ <span class="o">.</span><span class="na">withSecretKey</span><span class="o">(</span><span class="s">"YOUR-SECRET-KEY"</span><span class="o">);</span></code></pre></figure>
<h3 id="advanced-configuration">Advanced Configuration</h3>
@@ -637,25 +647,40 @@ set your <code>grouper</code> configurat
<p>Samza Kinesis Connector uses the <a href="https://docs.aws.amazon.com/streams/latest/dev/developing-consumers-with-kcl.html#kinesis-record-processor-overview-kcl">Kinesis Client Library</a>
(KCL) to access the Kinesis data streams. You can set any <a href="https://github.com/awslabs/amazon-kinesis-client/blob/master/amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/coordinator/KinesisClientLibConfiguration.java">KCL Configuration</a>
-for a stream by configuring it with the <strong>systems.system-name.streams.stream-name.aws.kcl.</strong>* prefix.</p>
+for a stream by configuring it through <code>KinesisInputDescriptor</code>.</p>
+
+<figure class="highlight"><pre><code class="language-java" data-lang="java"><span></span><span class="n">KinesisInputDescriptor</span><span class="o"><</span><span class="n">KV</span><span class="o"><</span><span class="n">String</span><span class="o">,</span> <span class="kt">byte</span><span class="o">[]>></span> <span class="n">kid</span> <span class="o">=</span> <span class="o">...</span>
-<figure class="highlight"><pre><code class="language-jproperties" data-lang="jproperties"><span></span><span class="na">systems.system-name.streams.stream-name.aws.kcl.CONFIG-PARAM</span><span class="o">=</span><span class="s">CONFIG-VALUE</span></code></pre></figure>
+<span class="n">Map</span><span class="o"><</span><span class="n">String</span><span class="o">,</span> <span class="n">String</span><span class="o">></span> <span class="n">kclConfig</span> <span class="o">=</span> <span class="k">new</span> <span class="n">HashMap</span><span class="o"><>;</span>
+<span class="n">kclConfig</span><span class="o">.</span><span class="na">put</span><span class="o">(</span><span class="s">"CONFIG-PARAM"</span><span class="o">,</span> <span class="s">"CONFIG-VALUE"</span><span class="o">);</span>
+
+<span class="n">kid</span><span class="o">.</span><span class="na">withKCLConfig</span><span class="o">(</span><span class="n">kclConfig</span><span class="o">);</span></code></pre></figure>
<p>As an example, the below configuration is equivalent to invoking <code>kclClient#WithTableName(myTable)</code> on the KCL instance.</p>
-<figure class="highlight"><pre><code class="language-jproperties" data-lang="jproperties"><span></span><span class="na">systems.system-name.streams.stream-name.aws.kcl.TableName</span><span class="o">=</span><span class="s">myTable</span></code></pre></figure>
+<figure class="highlight"><pre><code class="language-java" data-lang="java"><span></span><span class="n">KinesisInputDescriptor</span><span class="o"><</span><span class="n">KV</span><span class="o"><</span><span class="n">String</span><span class="o">,</span> <span class="kt">byte</span><span class="o">[]>></span> <span class="n">kid</span> <span class="o">=</span> <span class="o">...</span>
+
+<span class="n">Map</span><span class="o"><</span><span class="n">String</span><span class="o">,</span> <span class="n">String</span><span class="o">></span> <span class="n">kclConfig</span> <span class="o">=</span> <span class="k">new</span> <span class="n">HashMap</span><span class="o"><>;</span>
+<span class="n">kclConfig</span><span class="o">.</span><span class="na">put</span><span class="o">(</span><span class="s">"TableName"</span><span class="o">,</span> <span class="s">"myTable"</span><span class="o">);</span>
+
+<span class="n">kid</span><span class="o">.</span><span class="na">withKCLConfig</span><span class="o">(</span><span class="n">kclConfig</span><span class="o">);</span></code></pre></figure>
<h4 id="aws-client-configs">AWS Client configs</h4>
<p>Samza allows you to specify any <a href="http://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/ClientConfiguration.html">AWS client configs</a> to connect to your Kinesis instance.
-You can configure any <a href="http://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/ClientConfiguration.html">AWS client configuration</a> with the <code>systems.your-system-name.aws.clientConfig.*</code> prefix.</p>
+You can configure any <a href="http://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/ClientConfiguration.html">AWS client configuration</a> through <code>KinesisSystemDescriptor</code>.</p>
+
+<figure class="highlight"><pre><code class="language-java" data-lang="java"><span></span><span class="n">Map</span><span class="o"><</span><span class="n">String</span><span class="o">,</span> <span class="n">String</span><span class="o">></span> <span class="n">awsConfig</span> <span class="o">=</span> <span class="k">new</span> <span class="n">HashMap</span><span class="o"><>;</span>
+<span class="n">awsConfig</span><span class="o">.</span><span class="na">put</span><span class="o">(</span><span class="s">"CONFIG-PARAM"</span><span class="o">,</span> <span class="s">"CONFIG-VALUE"</span><span class="o">);</span>
-<figure class="highlight"><pre><code class="language-jproperties" data-lang="jproperties"><span></span><span class="na">systems.system-name.aws.clientConfig.CONFIG-PARAM</span><span class="o">=</span><span class="s">CONFIG-VALUE</span></code></pre></figure>
+<span class="n">KinesisSystemDescriptor</span> <span class="n">sd</span> <span class="o">=</span> <span class="k">new</span> <span class="n">KinesisSystemDescriptor</span><span class="o">(</span><span class="n">systemName</span><span class="o">)</span>
+ <span class="o">.</span><span class="na">withAWSConfig</span><span class="o">(</span><span class="n">awsConfig</span><span class="o">);</span></code></pre></figure>
-<p>As an example, to set the <em>proxy host</em> and <em>proxy port</em> to be used by the Kinesis Client:</p>
+<p>Through <code>KinesisSystemDescriptor</code> you can also set the <em>proxy host</em> and <em>proxy port</em> to be used by the Kinesis Client:</p>
-<figure class="highlight"><pre><code class="language-jproperties" data-lang="jproperties"><span></span><span class="na">systems.system-name.aws.clientConfig.ProxyHost</span><span class="o">=</span><span class="s">my-proxy-host.com</span>
-<span class="na">systems.system-name.aws.clientConfig.ProxyPort</span><span class="o">=</span><span class="s">my-proxy-port</span></code></pre></figure>
+<figure class="highlight"><pre><code class="language-java" data-lang="java"><span></span><span class="n">KinesisSystemDescriptor</span> <span class="n">sd</span> <span class="o">=</span> <span class="k">new</span> <span class="n">KinesisSystemDescriptor</span><span class="o">(</span><span class="n">systemName</span><span class="o">)</span>
+ <span class="o">.</span><span class="na">withProxyHost</span><span class="o">(</span><span class="s">"YOUR-PROXY-HOST"</span><span class="o">)</span>
+ <span class="o">.</span><span class="na">withProxyPort</span><span class="o">(</span><span class="n">YOUR</span><span class="o">-</span><span class="n">PROXY</span><span class="o">-</span><span class="n">PORT</span><span class="o">);</span></code></pre></figure>
<h3 id="resetting-offsets">Resetting Offsets</h3>
@@ -663,12 +688,30 @@ You can configure any <a href="http://do
These checkpoints are stored and managed by the KCL library internally. You can reset the checkpoints by configuring a different name for the DynamoDB table. </p>
<figure class="highlight"><pre><code class="language-jproperties" data-lang="jproperties"><span></span><span class="c">// change the TableName to a unique name to reset checkpoints.</span>
-<span class="na">systems.kinesis-system.streams.input0.aws.kcl.TableName</span><span class="o">=</span><span class="s">my-app-table-name</span></code></pre></figure>
+<span class="na">systems.kinesis-system.streams.STREAM-NAME.aws.kcl.TableName</span><span class="o">=</span><span class="s">my-app-table-name</span></code></pre></figure>
+
+<p>Or through <code>KinesisInputDescriptor</code></p>
+
+<figure class="highlight"><pre><code class="language-java" data-lang="java"><span></span><span class="n">KinesisInputDescriptor</span><span class="o"><</span><span class="n">KV</span><span class="o"><</span><span class="n">String</span><span class="o">,</span> <span class="kt">byte</span><span class="o">[]>></span> <span class="n">kid</span> <span class="o">=</span> <span class="o">...</span>
+
+<span class="n">Map</span><span class="o"><</span><span class="n">String</span><span class="o">,</span> <span class="n">String</span><span class="o">></span> <span class="n">kclConfig</span> <span class="o">=</span> <span class="k">new</span> <span class="n">HashMap</span><span class="o"><>;</span>
+<span class="n">kclConfig</span><span class="o">.</span><span class="na">put</span><span class="o">(</span><span class="s">"TableName"</span><span class="o">,</span> <span class="s">"my-new-app-table-name"</span><span class="o">);</span>
+
+<span class="n">kid</span><span class="o">.</span><span class="na">withKCLConfig</span><span class="o">(</span><span class="n">kclConfig</span><span class="o">);</span></code></pre></figure>
<p>When you reset checkpoints, you can configure your job to start consuming from either the earliest or latest offset in the stream. </p>
<figure class="highlight"><pre><code class="language-jproperties" data-lang="jproperties"><span></span><span class="c">// set the starting position to either TRIM_HORIZON (oldest) or LATEST (latest)</span>
-<span class="na">systems.kinesis-system.streams.input0.aws.kcl.InitialPositionInStream</span><span class="o">=</span><span class="s">LATEST</span></code></pre></figure>
+<span class="na">systems.kinesis-system.streams.STREAM-NAME.aws.kcl.InitialPositionInStream</span><span class="o">=</span><span class="s">LATEST</span></code></pre></figure>
+
+<p>Or through <code>KinesisInputDescriptor</code></p>
+
+<figure class="highlight"><pre><code class="language-java" data-lang="java"><span></span><span class="n">KinesisInputDescriptor</span><span class="o"><</span><span class="n">KV</span><span class="o"><</span><span class="n">String</span><span class="o">,</span> <span class="kt">byte</span><span class="o">[]>></span> <span class="n">kid</span> <span class="o">=</span> <span class="o">...</span>
+
+<span class="n">Map</span><span class="o"><</span><span class="n">String</span><span class="o">,</span> <span class="n">String</span><span class="o">></span> <span class="n">kclConfig</span> <span class="o">=</span> <span class="k">new</span> <span class="n">HashMap</span><span class="o"><>;</span>
+<span class="n">kclConfig</span><span class="o">.</span><span class="na">put</span><span class="o">(</span><span class="s">"InitialPositionInStream"</span><span class="o">,</span> <span class="s">"LATEST"</span><span class="o">);</span>
+
+<span class="n">kid</span><span class="o">.</span><span class="na">withKCLConfig</span><span class="o">(</span><span class="n">kclConfig</span><span class="o">);</span></code></pre></figure>
<p>Alternately, if you want to start from a particular offset in the Kinesis stream, you can login to the <a href="https://docs.aws.amazon.com/amazondynamodb/latest/developerguide/ConsoleDynamoDB.html">AWS console</a> and edit the offsets in your DynamoDB Table.
By default, the table-name has the following format: “<job name>-<job id>-<kinesis stream>”.</p>
Modified: samza/site/learn/documentation/versioned/connectors/overview.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/connectors/overview.html?rev=1861168&r1=1861167&r2=1861168&view=diff
==============================================================================
--- samza/site/learn/documentation/versioned/connectors/overview.html (original)
+++ samza/site/learn/documentation/versioned/connectors/overview.html Wed Jun 12 17:07:42 2019
@@ -227,6 +227,12 @@
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.2.0">1.2.0</a>
+
+
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.1.0">1.1.0</a>
+
+
<a class="side-navigation__group-item" data-match-active="" href="/releases/1.0.0">1.0.0</a>
@@ -514,6 +520,18 @@
+ <li class="hide"><a href="/learn/documentation/1.2/connectors/overview">1.2</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.1/connectors/overview">1.1</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.0/connectors/overview">1.0</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/0.14/connectors/overview">0.14</a></li>
@@ -534,10 +552,6 @@
- <li class="hide"><a href="/learn/documentation/1.0/connectors/overview">1.0</a></li>
-
-
-
<li class="hide"><a href="/learn/documentation/0.9/connectors/overview">0.9</a></li>
Modified: samza/site/learn/documentation/versioned/container/checkpointing.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/container/checkpointing.html?rev=1861168&r1=1861167&r2=1861168&view=diff
==============================================================================
--- samza/site/learn/documentation/versioned/container/checkpointing.html (original)
+++ samza/site/learn/documentation/versioned/container/checkpointing.html Wed Jun 12 17:07:42 2019
@@ -227,6 +227,12 @@
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.2.0">1.2.0</a>
+
+
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.1.0">1.1.0</a>
+
+
<a class="side-navigation__group-item" data-match-active="" href="/releases/1.0.0">1.0.0</a>
@@ -514,6 +520,18 @@
+ <li class="hide"><a href="/learn/documentation/1.2/container/checkpointing">1.2</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.1/container/checkpointing">1.1</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.0/container/checkpointing">1.0</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/0.14/container/checkpointing">0.14</a></li>
@@ -534,10 +552,6 @@
- <li class="hide"><a href="/learn/documentation/1.0/container/checkpointing">1.0</a></li>
-
-
-
<li class="hide"><a href="/learn/documentation/0.9/container/checkpointing">0.9</a></li>
Modified: samza/site/learn/documentation/versioned/container/coordinator-stream.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/container/coordinator-stream.html?rev=1861168&r1=1861167&r2=1861168&view=diff
==============================================================================
--- samza/site/learn/documentation/versioned/container/coordinator-stream.html (original)
+++ samza/site/learn/documentation/versioned/container/coordinator-stream.html Wed Jun 12 17:07:42 2019
@@ -227,6 +227,12 @@
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.2.0">1.2.0</a>
+
+
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.1.0">1.1.0</a>
+
+
<a class="side-navigation__group-item" data-match-active="" href="/releases/1.0.0">1.0.0</a>
@@ -514,6 +520,18 @@
+ <li class="hide"><a href="/learn/documentation/1.2/container/coordinator-stream">1.2</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.1/container/coordinator-stream">1.1</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.0/container/coordinator-stream">1.0</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/0.14/container/coordinator-stream">0.14</a></li>
@@ -534,10 +552,6 @@
- <li class="hide"><a href="/learn/documentation/1.0/container/coordinator-stream">1.0</a></li>
-
-
-
<li class="hide"><a href="/learn/documentation/0.9/container/coordinator-stream">0.9</a></li>
Modified: samza/site/learn/documentation/versioned/container/event-loop.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/container/event-loop.html?rev=1861168&r1=1861167&r2=1861168&view=diff
==============================================================================
--- samza/site/learn/documentation/versioned/container/event-loop.html (original)
+++ samza/site/learn/documentation/versioned/container/event-loop.html Wed Jun 12 17:07:42 2019
@@ -227,6 +227,12 @@
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.2.0">1.2.0</a>
+
+
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.1.0">1.1.0</a>
+
+
<a class="side-navigation__group-item" data-match-active="" href="/releases/1.0.0">1.0.0</a>
@@ -514,6 +520,18 @@
+ <li class="hide"><a href="/learn/documentation/1.2/container/event-loop">1.2</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.1/container/event-loop">1.1</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.0/container/event-loop">1.0</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/0.14/container/event-loop">0.14</a></li>
@@ -534,10 +552,6 @@
- <li class="hide"><a href="/learn/documentation/1.0/container/event-loop">1.0</a></li>
-
-
-
<li class="hide"><a href="/learn/documentation/0.9/container/event-loop">0.9</a></li>
Modified: samza/site/learn/documentation/versioned/container/jmx.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/container/jmx.html?rev=1861168&r1=1861167&r2=1861168&view=diff
==============================================================================
--- samza/site/learn/documentation/versioned/container/jmx.html (original)
+++ samza/site/learn/documentation/versioned/container/jmx.html Wed Jun 12 17:07:42 2019
@@ -227,6 +227,12 @@
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.2.0">1.2.0</a>
+
+
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.1.0">1.1.0</a>
+
+
<a class="side-navigation__group-item" data-match-active="" href="/releases/1.0.0">1.0.0</a>
@@ -514,6 +520,18 @@
+ <li class="hide"><a href="/learn/documentation/1.2/container/jmx">1.2</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.1/container/jmx">1.1</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.0/container/jmx">1.0</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/0.14/container/jmx">0.14</a></li>
@@ -534,10 +552,6 @@
- <li class="hide"><a href="/learn/documentation/1.0/container/jmx">1.0</a></li>
-
-
-
<li class="hide"><a href="/learn/documentation/0.9/container/jmx">0.9</a></li>
Modified: samza/site/learn/documentation/versioned/container/metrics.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/container/metrics.html?rev=1861168&r1=1861167&r2=1861168&view=diff
==============================================================================
--- samza/site/learn/documentation/versioned/container/metrics.html (original)
+++ samza/site/learn/documentation/versioned/container/metrics.html Wed Jun 12 17:07:42 2019
@@ -227,6 +227,12 @@
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.2.0">1.2.0</a>
+
+
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.1.0">1.1.0</a>
+
+
<a class="side-navigation__group-item" data-match-active="" href="/releases/1.0.0">1.0.0</a>
@@ -514,6 +520,18 @@
+ <li class="hide"><a href="/learn/documentation/1.2/container/metrics">1.2</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.1/container/metrics">1.1</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.0/container/metrics">1.0</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/0.14/container/metrics">0.14</a></li>
@@ -534,10 +552,6 @@
- <li class="hide"><a href="/learn/documentation/1.0/container/metrics">1.0</a></li>
-
-
-
<li class="hide"><a href="/learn/documentation/0.9/container/metrics">0.9</a></li>
Modified: samza/site/learn/documentation/versioned/container/samza-container.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/container/samza-container.html?rev=1861168&r1=1861167&r2=1861168&view=diff
==============================================================================
--- samza/site/learn/documentation/versioned/container/samza-container.html (original)
+++ samza/site/learn/documentation/versioned/container/samza-container.html Wed Jun 12 17:07:42 2019
@@ -227,6 +227,12 @@
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.2.0">1.2.0</a>
+
+
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.1.0">1.1.0</a>
+
+
<a class="side-navigation__group-item" data-match-active="" href="/releases/1.0.0">1.0.0</a>
@@ -514,6 +520,18 @@
+ <li class="hide"><a href="/learn/documentation/1.2/container/samza-container">1.2</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.1/container/samza-container">1.1</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.0/container/samza-container">1.0</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/0.14/container/samza-container">0.14</a></li>
@@ -534,10 +552,6 @@
- <li class="hide"><a href="/learn/documentation/1.0/container/samza-container">1.0</a></li>
-
-
-
<li class="hide"><a href="/learn/documentation/0.9/container/samza-container">0.9</a></li>
Modified: samza/site/learn/documentation/versioned/container/serialization.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/container/serialization.html?rev=1861168&r1=1861167&r2=1861168&view=diff
==============================================================================
--- samza/site/learn/documentation/versioned/container/serialization.html (original)
+++ samza/site/learn/documentation/versioned/container/serialization.html Wed Jun 12 17:07:42 2019
@@ -227,6 +227,12 @@
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.2.0">1.2.0</a>
+
+
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.1.0">1.1.0</a>
+
+
<a class="side-navigation__group-item" data-match-active="" href="/releases/1.0.0">1.0.0</a>
@@ -514,6 +520,18 @@
+ <li class="hide"><a href="/learn/documentation/1.2/container/serialization">1.2</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.1/container/serialization">1.1</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.0/container/serialization">1.0</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/0.14/container/serialization">0.14</a></li>
@@ -534,10 +552,6 @@
- <li class="hide"><a href="/learn/documentation/1.0/container/serialization">1.0</a></li>
-
-
-
<li class="hide"><a href="/learn/documentation/0.9/container/serialization">0.9</a></li>
Modified: samza/site/learn/documentation/versioned/container/state-management.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/container/state-management.html?rev=1861168&r1=1861167&r2=1861168&view=diff
==============================================================================
--- samza/site/learn/documentation/versioned/container/state-management.html (original)
+++ samza/site/learn/documentation/versioned/container/state-management.html Wed Jun 12 17:07:42 2019
@@ -227,6 +227,12 @@
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.2.0">1.2.0</a>
+
+
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.1.0">1.1.0</a>
+
+
<a class="side-navigation__group-item" data-match-active="" href="/releases/1.0.0">1.0.0</a>
@@ -514,6 +520,18 @@
+ <li class="hide"><a href="/learn/documentation/1.2/container/state-management">1.2</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.1/container/state-management">1.1</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.0/container/state-management">1.0</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/0.14/container/state-management">0.14</a></li>
@@ -534,10 +552,6 @@
- <li class="hide"><a href="/learn/documentation/1.0/container/state-management">1.0</a></li>
-
-
-
<li class="hide"><a href="/learn/documentation/0.9/container/state-management">0.9</a></li>
Modified: samza/site/learn/documentation/versioned/container/streams.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/container/streams.html?rev=1861168&r1=1861167&r2=1861168&view=diff
==============================================================================
--- samza/site/learn/documentation/versioned/container/streams.html (original)
+++ samza/site/learn/documentation/versioned/container/streams.html Wed Jun 12 17:07:42 2019
@@ -227,6 +227,12 @@
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.2.0">1.2.0</a>
+
+
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.1.0">1.1.0</a>
+
+
<a class="side-navigation__group-item" data-match-active="" href="/releases/1.0.0">1.0.0</a>
@@ -514,6 +520,18 @@
+ <li class="hide"><a href="/learn/documentation/1.2/container/streams">1.2</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.1/container/streams">1.1</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.0/container/streams">1.0</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/0.14/container/streams">0.14</a></li>
@@ -534,10 +552,6 @@
- <li class="hide"><a href="/learn/documentation/1.0/container/streams">1.0</a></li>
-
-
-
<li class="hide"><a href="/learn/documentation/0.9/container/streams">0.9</a></li>
Modified: samza/site/learn/documentation/versioned/container/windowing.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/container/windowing.html?rev=1861168&r1=1861167&r2=1861168&view=diff
==============================================================================
--- samza/site/learn/documentation/versioned/container/windowing.html (original)
+++ samza/site/learn/documentation/versioned/container/windowing.html Wed Jun 12 17:07:42 2019
@@ -227,6 +227,12 @@
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.2.0">1.2.0</a>
+
+
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.1.0">1.1.0</a>
+
+
<a class="side-navigation__group-item" data-match-active="" href="/releases/1.0.0">1.0.0</a>
@@ -514,6 +520,18 @@
+ <li class="hide"><a href="/learn/documentation/1.2/container/windowing">1.2</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.1/container/windowing">1.1</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.0/container/windowing">1.0</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/0.14/container/windowing">0.14</a></li>
@@ -534,10 +552,6 @@
- <li class="hide"><a href="/learn/documentation/1.0/container/windowing">1.0</a></li>
-
-
-
<li class="hide"><a href="/learn/documentation/0.9/container/windowing">0.9</a></li>
Modified: samza/site/learn/documentation/versioned/core-concepts/core-concepts.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/core-concepts/core-concepts.html?rev=1861168&r1=1861167&r2=1861168&view=diff
==============================================================================
--- samza/site/learn/documentation/versioned/core-concepts/core-concepts.html (original)
+++ samza/site/learn/documentation/versioned/core-concepts/core-concepts.html Wed Jun 12 17:07:42 2019
@@ -227,6 +227,12 @@
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.2.0">1.2.0</a>
+
+
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.1.0">1.1.0</a>
+
+
<a class="side-navigation__group-item" data-match-active="" href="/releases/1.0.0">1.0.0</a>
@@ -514,6 +520,18 @@
+ <li class="hide"><a href="/learn/documentation/1.2/core-concepts/core-concepts">1.2</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.1/core-concepts/core-concepts">1.1</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.0/core-concepts/core-concepts">1.0</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/0.14/core-concepts/core-concepts">0.14</a></li>
@@ -534,10 +552,6 @@
- <li class="hide"><a href="/learn/documentation/1.0/core-concepts/core-concepts">1.0</a></li>
-
-
-
<li class="hide"><a href="/learn/documentation/0.9/core-concepts/core-concepts">0.9</a></li>
@@ -610,7 +624,7 @@
<p><em>Massive scale:</em> Battle-tested on applications that use several terabytes of state and run on thousands of cores. It <a href="/powered-by/">powers</a> multiple large companies including LinkedIn, Uber, TripAdvisor, Slack etc. </p>
-<p>Next, we will introduce Samzaâs terminology. You will realize that it is extremely easy to <a href="/quickstart/latest">get started</a> with building your first application. </p>
+<p>Next, we will introduce Samzaâs terminology. You will realize that it is extremely easy to <a href="/startup/quick-start/latest">get started</a> with building your first application. </p>
<h3 id="streams-partitions">Streams, Partitions</h3>
@@ -620,24 +634,25 @@
<br/>
A stream can have multiple producers that write data to it and multiple consumers that read data from it. Data in a stream can be unbounded (eg: a Kafka topic) or bounded (eg: a set of files on HDFS). </p>
-<p>A stream is sharded into multiple partitions for scaling how its data is processed. Each <em>partition</em> is an ordered, replayable sequence of records. When a message is written to a stream, it ends up in one its partitions. Each message in a partition is uniquely identified by an <em>offset</em>. </p>
+<p>A stream is sharded into multiple partitions for scaling how its data is processed. Each <em>partition</em> is an ordered, replayable sequence of records. When a message is written to a stream, it ends up in one of its partitions. Each message in a partition is uniquely identified by an <em>offset</em>. </p>
<p>Samza supports pluggable systems that can implement the stream abstraction. As an example, Kafka implements a stream as a topic while a database might implement a stream as a sequence of updates to its tables.</p>
<h3 id="stream-application">Stream Application</h3>
-<p>A <em>stream application</em> processes messages from input streams, transforms them and emits results to an output stream or a database. It is built by chaining multiple operators, each of which take in one or more streams and transform them.</p>
+<p>A <em>stream application</em> processes messages from input streams, transforms them and emits results to an output stream or a database. It is built by chaining multiple operators, each of which takes in one or more streams and transforms them.</p>
<p><img src="/img/latest/learn/documentation/core-concepts/stream-application.png" alt="diagram-medium"></p>
-<p>Samza offers three top-level APIs to help you build your stream applications: <br/>
-1. The <a href="/learn/documentation/latest/api/high-level-api.html">High Level Streams API</a>, which offers several built-in operators like map, filter etc. This is the recommended API for most use-cases. <br/>
+<p>Samza offers foure top-level APIs to help you build your stream applications: <br/>
+1. The <a href="/learn/documentation/latest/api/high-level-api.html">High Level Streams API</a>, which offers several built-in operators like map, filter, etc. This is the recommended API for most use-cases. <br/>
2. The <a href="/learn/documentation/latest/api/low-level-api.html">Low Level Task API</a>, which allows greater flexibility to define your processing-logic and offers greater control <br/>
-3. <a href="/learn/documentation/latest/api/samza-sql.html">Samza SQL</a>, which offers a declarative SQL interface to create your applications <br/></p>
+3. <a href="/learn/documentation/latest/api/samza-sql.html">Samza SQL</a>, which offers a declarative SQL interface to create your applications <br/>
+4. <a href="/learn/documentation/latest/api/beam-api.html">Apache Beam API</a>, which offers the full Java API from <a href="https://beam.apache.org/">Apache beam</a> while Python and Go are work-in-progress.</p>
<h3 id="state">State</h3>
-<p>Samza supports for both stateless and stateful stream processing. <em>Stateless processing</em>, as the name implies, does not retain any state associated with the current message after it has been processed. A good example of this is filtering an incoming stream of user-records by a field (eg:userId) and writing the filtered messages to their own stream. </p>
+<p>Samza supports both stateless and stateful stream processing. <em>Stateless processing</em>, as the name implies, does not retain any state associated with the current message after it has been processed. A good example of this is filtering an incoming stream of user-records by a field (eg:userId) and writing the filtered messages to their own stream. </p>
<p>In contrast, <em>stateful processing</em> requires you to record some state about a message even after processing it. Consider the example of counting the number of unique users to a website every five minutes. This requires you to store information about each user seen thus far for de-duplication. Samza offers a fault-tolerant, scalable state-store for this purpose.</p>
Modified: samza/site/learn/documentation/versioned/deployment/deployment-model.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/deployment/deployment-model.html?rev=1861168&r1=1861167&r2=1861168&view=diff
==============================================================================
--- samza/site/learn/documentation/versioned/deployment/deployment-model.html (original)
+++ samza/site/learn/documentation/versioned/deployment/deployment-model.html Wed Jun 12 17:07:42 2019
@@ -227,6 +227,12 @@
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.2.0">1.2.0</a>
+
+
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.1.0">1.1.0</a>
+
+
<a class="side-navigation__group-item" data-match-active="" href="/releases/1.0.0">1.0.0</a>
@@ -514,6 +520,18 @@
+ <li class="hide"><a href="/learn/documentation/1.2/deployment/deployment-model">1.2</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.1/deployment/deployment-model">1.1</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.0/deployment/deployment-model">1.0</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/0.14/deployment/deployment-model">0.14</a></li>
@@ -534,10 +552,6 @@
- <li class="hide"><a href="/learn/documentation/1.0/deployment/deployment-model">1.0</a></li>
-
-
-
<li class="hide"><a href="/learn/documentation/0.9/deployment/deployment-model">0.9</a></li>
Modified: samza/site/learn/documentation/versioned/deployment/standalone.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/deployment/standalone.html?rev=1861168&r1=1861167&r2=1861168&view=diff
==============================================================================
--- samza/site/learn/documentation/versioned/deployment/standalone.html (original)
+++ samza/site/learn/documentation/versioned/deployment/standalone.html Wed Jun 12 17:07:42 2019
@@ -227,6 +227,12 @@
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.2.0">1.2.0</a>
+
+
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.1.0">1.1.0</a>
+
+
<a class="side-navigation__group-item" data-match-active="" href="/releases/1.0.0">1.0.0</a>
@@ -514,6 +520,18 @@
+ <li class="hide"><a href="/learn/documentation/1.2/deployment/standalone">1.2</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.1/deployment/standalone">1.1</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.0/deployment/standalone">1.0</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/0.14/deployment/standalone">0.14</a></li>
@@ -534,10 +552,6 @@
- <li class="hide"><a href="/learn/documentation/1.0/deployment/standalone">1.0</a></li>
-
-
-
<li class="hide"><a href="/learn/documentation/0.9/deployment/standalone">0.9</a></li>
@@ -614,14 +628,14 @@
<p>We will use the <code>./bin/grid</code> script from the <code>hello-samza</code> project to setup up Zookeeper and Kafka locally.</p>
<div class="highlight"><pre><code class="language-bash" data-lang="bash"><span></span>./bin/grid start zookeeper
-./bin/grid start zookeeper
+./bin/grid start kafka
</code></pre></div>
<h4 id="building-the-binaries">Building the binaries</h4>
<p>Let us now build the <code>hello-samza</code> project from its sources.</p>
<div class="highlight"><pre><code class="language-bash" data-lang="bash"><span></span>mvn clean package
mkdir -p deploy/samza
-tar -xvf ./target/hello-samza-1.0.0-dist.tar.gz -C deploy/samza
+tar -xvf ./target/hello-samza-1.1.0-dist.tar.gz -C deploy/samza
</code></pre></div>
<h4 id="running-the-application">Running the application</h4>
Modified: samza/site/learn/documentation/versioned/deployment/yarn.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/deployment/yarn.html?rev=1861168&r1=1861167&r2=1861168&view=diff
==============================================================================
--- samza/site/learn/documentation/versioned/deployment/yarn.html (original)
+++ samza/site/learn/documentation/versioned/deployment/yarn.html Wed Jun 12 17:07:42 2019
@@ -227,6 +227,12 @@
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.2.0">1.2.0</a>
+
+
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.1.0">1.1.0</a>
+
+
<a class="side-navigation__group-item" data-match-active="" href="/releases/1.0.0">1.0.0</a>
@@ -514,6 +520,18 @@
+ <li class="hide"><a href="/learn/documentation/1.2/deployment/yarn">1.2</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.1/deployment/yarn">1.1</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.0/deployment/yarn">1.0</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/0.14/deployment/yarn">0.14</a></li>
@@ -534,10 +552,6 @@
- <li class="hide"><a href="/learn/documentation/1.0/deployment/yarn">1.0</a></li>
-
-
-
<li class="hide"><a href="/learn/documentation/0.9/deployment/yarn">0.9</a></li>
Modified: samza/site/learn/documentation/versioned/hadoop/consumer.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/hadoop/consumer.html?rev=1861168&r1=1861167&r2=1861168&view=diff
==============================================================================
--- samza/site/learn/documentation/versioned/hadoop/consumer.html (original)
+++ samza/site/learn/documentation/versioned/hadoop/consumer.html Wed Jun 12 17:07:42 2019
@@ -227,6 +227,12 @@
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.2.0">1.2.0</a>
+
+
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.1.0">1.1.0</a>
+
+
<a class="side-navigation__group-item" data-match-active="" href="/releases/1.0.0">1.0.0</a>
@@ -514,6 +520,18 @@
+ <li class="hide"><a href="/learn/documentation/1.2/hadoop/consumer">1.2</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.1/hadoop/consumer">1.1</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.0/hadoop/consumer">1.0</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/0.14/hadoop/consumer">0.14</a></li>
@@ -534,10 +552,6 @@
- <li class="hide"><a href="/learn/documentation/1.0/hadoop/consumer">1.0</a></li>
-
-
-
<li class="hide"><a href="/learn/documentation/0.9/hadoop/consumer">0.9</a></li>
Modified: samza/site/learn/documentation/versioned/hadoop/overview.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/hadoop/overview.html?rev=1861168&r1=1861167&r2=1861168&view=diff
==============================================================================
--- samza/site/learn/documentation/versioned/hadoop/overview.html (original)
+++ samza/site/learn/documentation/versioned/hadoop/overview.html Wed Jun 12 17:07:42 2019
@@ -227,6 +227,12 @@
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.2.0">1.2.0</a>
+
+
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.1.0">1.1.0</a>
+
+
<a class="side-navigation__group-item" data-match-active="" href="/releases/1.0.0">1.0.0</a>
@@ -514,6 +520,18 @@
+ <li class="hide"><a href="/learn/documentation/1.2/hadoop/overview">1.2</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.1/hadoop/overview">1.1</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.0/hadoop/overview">1.0</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/0.14/hadoop/overview">0.14</a></li>
@@ -534,10 +552,6 @@
- <li class="hide"><a href="/learn/documentation/1.0/hadoop/overview">1.0</a></li>
-
-
-
<li class="hide"><a href="/learn/documentation/0.9/hadoop/overview">0.9</a></li>
Modified: samza/site/learn/documentation/versioned/hadoop/producer.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/hadoop/producer.html?rev=1861168&r1=1861167&r2=1861168&view=diff
==============================================================================
--- samza/site/learn/documentation/versioned/hadoop/producer.html (original)
+++ samza/site/learn/documentation/versioned/hadoop/producer.html Wed Jun 12 17:07:42 2019
@@ -227,6 +227,12 @@
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.2.0">1.2.0</a>
+
+
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.1.0">1.1.0</a>
+
+
<a class="side-navigation__group-item" data-match-active="" href="/releases/1.0.0">1.0.0</a>
@@ -514,6 +520,18 @@
+ <li class="hide"><a href="/learn/documentation/1.2/hadoop/producer">1.2</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.1/hadoop/producer">1.1</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.0/hadoop/producer">1.0</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/0.14/hadoop/producer">0.14</a></li>
@@ -534,10 +552,6 @@
- <li class="hide"><a href="/learn/documentation/1.0/hadoop/producer">1.0</a></li>
-
-
-
<li class="hide"><a href="/learn/documentation/0.9/hadoop/producer">0.9</a></li>
Modified: samza/site/learn/documentation/versioned/index.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/index.html?rev=1861168&r1=1861167&r2=1861168&view=diff
==============================================================================
--- samza/site/learn/documentation/versioned/index.html (original)
+++ samza/site/learn/documentation/versioned/index.html Wed Jun 12 17:07:42 2019
@@ -227,6 +227,12 @@
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.2.0">1.2.0</a>
+
+
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.1.0">1.1.0</a>
+
+
<a class="side-navigation__group-item" data-match-active="" href="/releases/1.0.0">1.0.0</a>
@@ -514,6 +520,18 @@
+ <li class="hide"><a href="/learn/documentation/1.2/">1.2</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.1/">1.1</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.0/">1.0</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/0.14/">0.14</a></li>
@@ -534,10 +552,6 @@
- <li class="hide"><a href="/learn/documentation/1.0/">1.0</a></li>
-
-
-
<li class="hide"><a href="/learn/documentation/0.9/">0.9</a></li>
@@ -596,7 +610,7 @@
<li><a href="api/table-api.html">Table API</a></li>
<li><a href="api/test-framework.html">Testing Samza</a></li>
<li><a href="api/samza-sql.html">Samza SQL</a></li>
- <li><a href="https://beam.apache.org/documentation/runners/samza/">Apache BEAM</a></li>
+ <li><a href="api/beam-api.html">Apache BEAM</a></li>
</ul>
<h4>DEPLOYMENT</h4>
Modified: samza/site/learn/documentation/versioned/introduction/architecture.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/introduction/architecture.html?rev=1861168&r1=1861167&r2=1861168&view=diff
==============================================================================
--- samza/site/learn/documentation/versioned/introduction/architecture.html (original)
+++ samza/site/learn/documentation/versioned/introduction/architecture.html Wed Jun 12 17:07:42 2019
@@ -227,6 +227,12 @@
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.2.0">1.2.0</a>
+
+
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.1.0">1.1.0</a>
+
+
<a class="side-navigation__group-item" data-match-active="" href="/releases/1.0.0">1.0.0</a>
@@ -514,6 +520,18 @@
+ <li class="hide"><a href="/learn/documentation/1.2/introduction/architecture">1.2</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.1/introduction/architecture">1.1</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.0/introduction/architecture">1.0</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/0.14/introduction/architecture">0.14</a></li>
@@ -534,10 +552,6 @@
- <li class="hide"><a href="/learn/documentation/1.0/introduction/architecture">1.0</a></li>
-
-
-
<li class="hide"><a href="/learn/documentation/0.9/introduction/architecture">0.9</a></li>
Modified: samza/site/learn/documentation/versioned/introduction/background.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/introduction/background.html?rev=1861168&r1=1861167&r2=1861168&view=diff
==============================================================================
--- samza/site/learn/documentation/versioned/introduction/background.html (original)
+++ samza/site/learn/documentation/versioned/introduction/background.html Wed Jun 12 17:07:42 2019
@@ -227,6 +227,12 @@
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.2.0">1.2.0</a>
+
+
+ <a class="side-navigation__group-item" data-match-active="" href="/releases/1.1.0">1.1.0</a>
+
+
<a class="side-navigation__group-item" data-match-active="" href="/releases/1.0.0">1.0.0</a>
@@ -514,6 +520,18 @@
+ <li class="hide"><a href="/learn/documentation/1.2/introduction/background">1.2</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.1/introduction/background">1.1</a></li>
+
+
+
+ <li class="hide"><a href="/learn/documentation/1.0/introduction/background">1.0</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/0.14/introduction/background">0.14</a></li>
@@ -534,10 +552,6 @@
- <li class="hide"><a href="/learn/documentation/1.0/introduction/background">1.0</a></li>
-
-
-
<li class="hide"><a href="/learn/documentation/0.9/introduction/background">0.9</a></li>