You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by lh...@apache.org on 2019/12/09 18:28:07 UTC
svn commit: r1871092 [11/14] - in /samza/site: ./ archive/ blog/
case-studies/ community/ learn/documentation/latest/
learn/documentation/latest/api/ learn/documentation/latest/api/javadocs/
learn/documentation/latest/api/javadocs/org/apache/samza/ lea...
Modified: samza/site/learn/documentation/latest/api/low-level-api.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/low-level-api.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/low-level-api.html (original)
+++ samza/site/learn/documentation/latest/api/low-level-api.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/api/low-level-api">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/api/low-level-api">1.2</a></li>
@@ -848,6 +852,21 @@ whether they’re provided by the fr
<span class="o">}</span>
<span class="o">}</span></code></pre></figure>
+<h3 id="side-inputs-for-local-tables">Side Inputs for Local Tables</h3>
+
+<p>For populating a local <a href="javadocs/org/apache/samza/table/Table">Table</a> with secondary data sources, we can use side inputs to specify the source stream. Additionally, the table descriptor also takes
+in a <code>SideInputsProcessor</code> that will be applied before writing the entries to the table. The <code>TableDescriptor</code> that is registered with the <code>TaskApplicationDescriptor</code> can be used to specify side input properties.</p>
+
+<p>The following code snippet shows a sample <code>TableDescriptor</code> for a local table that is backed by side inputs.</p>
+
+<figure class="highlight"><pre><code class="language-java" data-lang="java"><span></span> <span class="n">RocksDbTableDescriptor</span><span class="o"><</span><span class="n">String</span><span class="o">,</span> <span class="n">Profile</span><span class="o">></span> <span class="n">tableDesc</span> <span class="o">=</span>
+ <span class="k">new</span> <span class="n">RocksDbTableDescriptor</span><span class="o">(</span><span class="err">â</span><span class="n">viewCounts</span><span class="err">â</span><span class="o">,</span> <span class="n">KVSerde</span><span class="o">.</span><span class="na">of</span><span class="o">(</span><span class="k">new</span> <span class="n">StringSerde</span><span class="o">(),</span> <span class="k">new</span> <span class="n">JsonSerdeV2</span><span class="o"><>(</span><span class="n">Profile</span><span class="o">.</span><span class="na">class</span><span class="o">)))</span>
+ <span class="o">.</span><span class="na">withSideInput</span><span class="o">(</span><span class="n">ImmutableList</span><span class="o">.</span><span class="na">of</span><span class="o">(</span><span class="s">"profile"</span><span class="o">))</span>
+ <span class="o">.</span><span class="na">withSideInputsProcessor</span><span class="o">((</span><span class="n">message</span><span class="o">,</span> <span class="n">store</span><span class="o">)</span> <span class="o">-></span> <span class="o">{</span>
+ <span class="o">...</span>
+ <span class="o">});</span></code></pre></figure>
+
+
<h3 id="legacy-applications">Legacy Applications</h3>
<p>For legacy Low Level API applications, you can continue specifying your system, stream and store properties along with your task.class in configuration. An incomplete example of configuration for legacy task application looks like this (see the <a href="../jobs/configuration.html">configuration</a> documentation for more detail):</p>
@@ -867,6 +886,13 @@ whether they’re provided by the fr
<span class="c"># Use the "json" serializer for messages in the "PageViewEvent" topic</span>
<span class="na"> systems.kafka.streams.PageViewEvent.samza.msg.serde</span><span class="o">=</span><span class="s">json</span>
+
+ <span class="c"># Use "ProfileEvent" from the "kafka" system for side inputs for "profile-store"</span>
+<span class="na"> stores.profile-store.side.inputs</span><span class="o">=</span><span class="s">kafka.ProfileEvent</span>
+
+ <span class="c"># Use "MySideInputsProcessorFactory" to instantiate the "SideInputsProcessor" </span>
+ <span class="c"># that will applied on the "ProfileEvent" before writing to "profile-store"</span>
+<span class="na"> stores.profile-store.side.inputs.processor.factory</span><span class="o">=</span><span class="s">org.apache.samza.MySideInputsProcessorFactory</span>
</code></pre></figure>
Modified: samza/site/learn/documentation/latest/api/programming-model.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/programming-model.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/programming-model.html (original)
+++ samza/site/learn/documentation/latest/api/programming-model.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/api/programming-model">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/api/programming-model">1.2</a></li>
@@ -651,7 +655,7 @@
<p><a href="javadocs/org/apache/samza/system/descriptors/InputDescriptor.html">InputDescriptor</a>s and <a href="javadocs/org/apache/samza/system/descriptors/OutputDescriptor.html">OutputDescriptor</a>s can be used for specifying Samza and implementation-specific properties of the streaming inputs and outputs for your application. You can obtain InputDescriptors and OutputDescriptors using a <a href="javadocs/org/apache/samza/system/descriptors/SystemDescriptor.html">SystemDescriptor</a> for your system. This SystemDescriptor can be used for specify Samza and implementation-specific properties of the producer and consumers for your I/O system. Most Samza system implementations come with their own SystemDescriptors, but if one isn’t available, you
can use the <a href="javadocs/org/apache/samza/system/descriptors/GenericSystemDescriptor.html">GenericSystemDescriptor</a>.</p>
-<p>A <a href="javadocs/org/apache/samza/table/descriptors/TableDescriptor.html">TableDescriptor</a> can be used for specifying Samza and implementation-specific properties of a <a href="javadocs/org/apache/samza/table/Table.html">Table</a>. You can use a Local TableDescriptor (e.g. <a href="javadocs/org/apache/samza/storage/kv/descriptors/RocksDbTableDescriptor.html">RocksDbTableDescriptor</a> or a <a href="javadocs/org/apache/samza/table/descriptors/RemoteTableDescriptor">RemoteTableDescriptor</a>.</p>
+<p>A <a href="javadocs/org/apache/samza/table/descriptors/TableDescriptor.html">TableDescriptor</a> can be used for specifying Samza and implementation-specific properties of a <a href="javadocs/org/apache/samza/table/Table.html">Table</a>. You can use a Local TableDescriptor (e.g. <a href="javadocs/org/apache/samza/storage/kv/descriptors/RocksDbTableDescriptor.html">RocksDbTableDescriptor</a> or a <a href="javadocs/org/apache/samza/table/descriptors/RemoteTableDescriptor">RemoteTableDescriptor</a>. </p>
<p>The following example illustrates how you can use input and output descriptors for a Kafka system, and a table descriptor for a local RocksDB table within your application:</p>
Modified: samza/site/learn/documentation/latest/api/samza-sql.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/samza-sql.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/samza-sql.html (original)
+++ samza/site/learn/documentation/latest/api/samza-sql.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/api/samza-sql">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/api/samza-sql">1.2</a></li>
Modified: samza/site/learn/documentation/latest/api/table-api.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/table-api.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/table-api.html (original)
+++ samza/site/learn/documentation/latest/api/table-api.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/api/table-api">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/api/table-api">1.2</a></li>
@@ -756,6 +760,62 @@ function defined in lines 30-39.</li>
<li>Line 12: writes the join result stream to another table</li>
</ol>
+<h1 id="using-table-with-samza-high-level-api-using-side-inputs">Using Table with Samza High Level API using Side Inputs</h1>
+
+<p>The code snippet below illustrates the usage of table in Samza high level API using side inputs.</p>
+
+<figure class="highlight"><pre><code class="language-java" data-lang="java"><span></span> <span class="mi">1</span> <span class="kd">class</span> <span class="nc">SamzaStreamApplication</span> <span class="kd">implements</span> <span class="n">StreamApplication</span> <span class="o">{</span>
+ <span class="mi">2</span> <span class="nd">@Override</span>
+ <span class="mi">3</span> <span class="kd">public</span> <span class="kt">void</span> <span class="nf">describe</span><span class="o">(</span><span class="n">StreamApplicationDescriptor</span> <span class="n">appDesc</span><span class="o">)</span> <span class="o">{</span>
+ <span class="mi">4</span> <span class="n">TableDescriptor</span><span class="o"><</span><span class="n">Integer</span><span class="o">,</span> <span class="n">Profile</span><span class="o">></span> <span class="n">desc</span> <span class="o">=</span> <span class="k">new</span> <span class="n">InMemoryTableDescriptor</span><span class="o">(</span>
+ <span class="mi">5</span> <span class="s">"t1"</span><span class="o">,</span> <span class="n">KVSerde</span><span class="o">.</span><span class="na">of</span><span class="o">(</span><span class="k">new</span> <span class="n">IntegerSerde</span><span class="o">(),</span> <span class="k">new</span> <span class="n">ProfileJsonSerde</span><span class="o">()))</span>
+ <span class="mi">6</span> <span class="o">.</span><span class="na">withSideInputs</span><span class="o">(</span><span class="n">ImmutableList</span><span class="o">.</span><span class="na">of</span><span class="o">(</span><span class="n">PROFILE_STREAM</span><span class="o">))</span>
+ <span class="mi">7</span> <span class="o">.</span><span class="na">withSideInputsProcessor</span><span class="o">((</span><span class="n">msg</span><span class="o">,</span> <span class="n">store</span><span class="o">)</span> <span class="o">-></span> <span class="o">{</span>
+ <span class="mi">8</span> <span class="n">Profile</span> <span class="n">profile</span> <span class="o">=</span> <span class="o">(</span><span class="n">Profile</span><span class="o">)</span> <span class="n">msg</span><span class="o">.</span><span class="na">getMessage</span><span class="o">();</span>
+ <span class="mi">9</span> <span class="kt">int</span> <span class="n">key</span> <span class="o">=</span> <span class="n">profile</span><span class="o">.</span><span class="na">getMemberId</span><span class="o">();</span>
+<span class="mi">10</span> <span class="k">return</span> <span class="n">ImmutableList</span><span class="o">.</span><span class="na">of</span><span class="o">(</span><span class="k">new</span> <span class="n">Entry</span><span class="o"><>(</span><span class="n">key</span><span class="o">,</span> <span class="n">profile</span><span class="o">));</span>
+<span class="mi">11</span> <span class="o">});</span>
+<span class="mi">12</span>
+<span class="mi">13</span> <span class="n">Table</span><span class="o"><</span><span class="n">KV</span><span class="o"><</span><span class="n">Integer</span><span class="o">,</span> <span class="n">Profile</span><span class="o">>></span> <span class="n">table</span> <span class="o">=</span> <span class="n">appDesc</span><span class="o">.</span><span class="na">getTable</span><span class="o">(</span><span class="n">desc</span><span class="o">);</span>
+<span class="mi">14</span>
+<span class="mi">15</span> <span class="n">appDesc</span><span class="o">.</span><span class="na">getInputStream</span><span class="o">(</span><span class="s">"PageView"</span><span class="o">,</span> <span class="k">new</span> <span class="n">NoOpSerde</span><span class="o"><</span><span class="n">PageView</span><span class="o">>())</span>
+<span class="mi">16</span> <span class="o">.</span><span class="na">map</span><span class="o">(</span><span class="k">new</span> <span class="n">MyMapFunc</span><span class="o">())</span>
+<span class="mi">17</span> <span class="o">.</span><span class="na">join</span><span class="o">(</span><span class="n">table</span><span class="o">,</span> <span class="k">new</span> <span class="n">MyJoinFunc</span><span class="o">())</span>
+<span class="mi">18</span> <span class="o">.</span><span class="na">sendTo</span><span class="o">(</span><span class="n">anotherTable</span><span class="o">);</span>
+<span class="mi">19</span> <span class="o">}</span>
+<span class="mi">21</span> <span class="o">}</span>
+<span class="mi">22</span>
+<span class="mi">23</span> <span class="kd">static</span> <span class="kd">class</span> <span class="nc">MyMapFunc</span> <span class="kd">implements</span> <span class="n">MapFunction</span><span class="o"><</span><span class="n">PageView</span><span class="o">,</span> <span class="n">KV</span><span class="o"><</span><span class="n">Integer</span><span class="o">,</span> <span class="n">PageView</span><span class="o">>></span> <span class="o">{</span>
+<span class="mi">24</span> <span class="kd">private</span> <span class="n">ReadableTable</span><span class="o"><</span><span class="n">Integer</span><span class="o">,</span> <span class="n">Profile</span><span class="o">></span> <span class="n">profileTable</span><span class="o">;</span>
+<span class="mi">25</span>
+<span class="mi">26</span> <span class="nd">@Override</span>
+<span class="mi">27</span> <span class="kd">public</span> <span class="kt">void</span> <span class="nf">init</span><span class="o">(</span><span class="n">Config</span> <span class="n">config</span><span class="o">,</span> <span class="n">TaskContext</span> <span class="n">context</span><span class="o">)</span> <span class="o">{</span>
+<span class="mi">28</span> <span class="n">profileTable</span> <span class="o">=</span> <span class="o">(</span><span class="n">ReadableTable</span><span class="o"><</span><span class="n">Integer</span><span class="o">,</span> <span class="n">Profile</span><span class="o">>)</span> <span class="n">context</span><span class="o">.</span><span class="na">getTable</span><span class="o">(</span><span class="s">"t1"</span><span class="o">);</span>
+<span class="mi">29</span> <span class="o">}</span>
+<span class="mi">30</span>
+<span class="mi">31</span> <span class="nd">@Override</span>
+<span class="mi">32</span> <span class="kd">public</span> <span class="n">KV</span><span class="o"><</span><span class="n">Integer</span><span class="o">,</span> <span class="n">PageView</span><span class="o">></span> <span class="nf">apply</span><span class="o">(</span><span class="n">PageView</span> <span class="n">message</span><span class="o">)</span> <span class="o">{</span>
+<span class="mi">33</span> <span class="k">return</span> <span class="k">new</span> <span class="n">KV</span><span class="o">.</span><span class="na">of</span><span class="o">(</span><span class="n">message</span><span class="o">.</span><span class="na">getId</span><span class="o">(),</span> <span class="n">message</span><span class="o">);</span>
+<span class="mi">34</span> <span class="o">}</span>
+<span class="mi">35</span> <span class="o">}</span>
+<span class="mi">36</span>
+<span class="mi">37</span> <span class="kd">static</span> <span class="kd">class</span> <span class="nc">MyJoinFunc</span> <span class="kd">implements</span> <span class="n">StreamTableJoinFunction</span>
+<span class="mi">38</span> <span class="o"><</span><span class="n">Integer</span><span class="o">,</span> <span class="n">KV</span><span class="o"><</span><span class="n">Integer</span><span class="o">,</span> <span class="n">PageView</span><span class="o">>,</span> <span class="n">KV</span><span class="o"><</span><span class="n">Integer</span><span class="o">,</span> <span class="n">Profile</span><span class="o">>,</span> <span class="n">EnrichedPageView</span><span class="o">></span> <span class="o">{</span>
+<span class="mi">39</span>
+<span class="mi">40</span> <span class="nd">@Override</span>
+<span class="mi">41</span> <span class="kd">public</span> <span class="n">EnrichedPageView</span> <span class="nf">apply</span><span class="o">(</span><span class="n">KV</span><span class="o"><</span><span class="n">Integer</span><span class="o">,</span> <span class="n">PageView</span><span class="o">></span> <span class="n">m</span><span class="o">,</span> <span class="n">KV</span><span class="o"><</span><span class="n">Integer</span><span class="o">,</span> <span class="n">Profile</span><span class="o">></span> <span class="n">r</span><span class="o">)</span> <span class="o">{</span>
+<span class="mi">42</span> <span class="n">counterPerJoinFn</span><span class="o">.</span><span class="na">get</span><span class="o">(</span><span class="k">this</span><span class="o">.</span><span class="na">currentSeqNo</span><span class="o">).</span><span class="na">incrementAndGet</span><span class="o">();</span>
+<span class="mi">43</span> <span class="k">return</span> <span class="n">r</span> <span class="o">==</span> <span class="kc">null</span> <span class="o">?</span> <span class="kc">null</span> <span class="o">:</span> <span class="k">new</span> <span class="n">EnrichedPageView</span><span class="o">(</span>
+<span class="mi">44</span> <span class="n">m</span><span class="o">.</span><span class="na">getValue</span><span class="o">().</span><span class="na">getPageKey</span><span class="o">(),</span> <span class="n">m</span><span class="o">.</span><span class="na">getKey</span><span class="o">(),</span> <span class="n">r</span><span class="o">.</span><span class="na">getValue</span><span class="o">().</span><span class="na">getCompany</span><span class="o">());</span>
+<span class="mi">45</span> <span class="o">}</span>
+<span class="mi">46</span> <span class="o">}</span></code></pre></figure>
+
+<p>The code above uses side inputs to populate the profile table.
+1. Line 6: Denotes the source stream for the profile table
+2. Line 7-11: Provides an implementation of <code>SideInputsProcessor</code> that reads from profile stream
+ and populates the table.
+3. Line 17: Incoming page views are joined against the profile table.</p>
+
<h1 id="using-table-with-samza-low-level-api">Using Table with Samza Low Level API</h1>
<p>The code snippet below illustrates the usage of table in Samza Low Level Task API.</p>
@@ -1141,7 +1201,11 @@ on the current implementation of in-memo
feature parity to existing in-memory and RocksDB-based stores. For more detailed
information please refer to
<a href="https://github.com/apache/samza/blob/master/samza-kv-rocksdb/src/main/java/org/apache/samza/storage/kv/RocksDbTableDescriptor.java"><code>RocksDbTableDescriptor</code></a> and
-<a href="https://github.com/apache/samza/blob/master/samza-kv-inmemory/src/main/java/org/apache/samza/storage/kv/inmemory/InMemoryTableDescriptor.java"><code>InMemoryTableDescriptor</code></a>. </p>
+<a href="https://github.com/apache/samza/blob/master/samza-kv-inmemory/src/main/java/org/apache/samza/storage/kv/inmemory/InMemoryTableDescriptor.java"><code>InMemoryTableDescriptor</code></a>.</p>
+
+<p>For local tables that are populated by secondary data sources, side inputs can be used to populate the data.
+The source streams will be used to bootstrap the data instead of a changelog in the event of failure. Side inputs and
+the processor implementation can be provided as properties to the <code>TableDescriptor</code>.</p>
<h2 id="hybrid-table">Hybrid Table</h2>
Modified: samza/site/learn/documentation/latest/api/test-framework.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/test-framework.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/test-framework.html (original)
+++ samza/site/learn/documentation/latest/api/test-framework.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/api/test-framework">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/api/test-framework">1.2</a></li>
Modified: samza/site/learn/documentation/latest/architecture/architecture-overview.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/architecture/architecture-overview.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/architecture/architecture-overview.html (original)
+++ samza/site/learn/documentation/latest/architecture/architecture-overview.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/architecture/architecture-overview">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/architecture/architecture-overview">1.2</a></li>
Modified: samza/site/learn/documentation/latest/architecture/kinesis.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/architecture/kinesis.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/architecture/kinesis.html (original)
+++ samza/site/learn/documentation/latest/architecture/kinesis.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/architecture/kinesis">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/architecture/kinesis">1.2</a></li>
Modified: samza/site/learn/documentation/latest/comparisons/introduction.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/comparisons/introduction.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/comparisons/introduction.html (original)
+++ samza/site/learn/documentation/latest/comparisons/introduction.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/comparisons/introduction">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/comparisons/introduction">1.2</a></li>
Modified: samza/site/learn/documentation/latest/comparisons/mupd8.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/comparisons/mupd8.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/comparisons/mupd8.html (original)
+++ samza/site/learn/documentation/latest/comparisons/mupd8.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/comparisons/mupd8">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/comparisons/mupd8">1.2</a></li>
Modified: samza/site/learn/documentation/latest/comparisons/spark-streaming.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/comparisons/spark-streaming.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/comparisons/spark-streaming.html (original)
+++ samza/site/learn/documentation/latest/comparisons/spark-streaming.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/comparisons/spark-streaming">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/comparisons/spark-streaming">1.2</a></li>
Modified: samza/site/learn/documentation/latest/comparisons/storm.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/comparisons/storm.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/comparisons/storm.html (original)
+++ samza/site/learn/documentation/latest/comparisons/storm.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/comparisons/storm">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/comparisons/storm">1.2</a></li>
Modified: samza/site/learn/documentation/latest/connectors/eventhubs.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/connectors/eventhubs.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/connectors/eventhubs.html (original)
+++ samza/site/learn/documentation/latest/connectors/eventhubs.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/connectors/eventhubs">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/connectors/eventhubs">1.2</a></li>
Modified: samza/site/learn/documentation/latest/connectors/hdfs.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/connectors/hdfs.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/connectors/hdfs.html (original)
+++ samza/site/learn/documentation/latest/connectors/hdfs.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/connectors/hdfs">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/connectors/hdfs">1.2</a></li>
Modified: samza/site/learn/documentation/latest/connectors/kafka.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/connectors/kafka.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/connectors/kafka.html (original)
+++ samza/site/learn/documentation/latest/connectors/kafka.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/connectors/kafka">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/connectors/kafka">1.2</a></li>
Modified: samza/site/learn/documentation/latest/connectors/kinesis.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/connectors/kinesis.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/connectors/kinesis.html (original)
+++ samza/site/learn/documentation/latest/connectors/kinesis.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/connectors/kinesis">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/connectors/kinesis">1.2</a></li>
Modified: samza/site/learn/documentation/latest/connectors/overview.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/connectors/overview.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/connectors/overview.html (original)
+++ samza/site/learn/documentation/latest/connectors/overview.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/connectors/overview">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/connectors/overview">1.2</a></li>
Modified: samza/site/learn/documentation/latest/container/checkpointing.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/container/checkpointing.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/container/checkpointing.html (original)
+++ samza/site/learn/documentation/latest/container/checkpointing.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/container/checkpointing">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/container/checkpointing">1.2</a></li>
Modified: samza/site/learn/documentation/latest/container/coordinator-stream.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/container/coordinator-stream.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/container/coordinator-stream.html (original)
+++ samza/site/learn/documentation/latest/container/coordinator-stream.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/container/coordinator-stream">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/container/coordinator-stream">1.2</a></li>
Modified: samza/site/learn/documentation/latest/container/event-loop.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/container/event-loop.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/container/event-loop.html (original)
+++ samza/site/learn/documentation/latest/container/event-loop.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/container/event-loop">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/container/event-loop">1.2</a></li>
Modified: samza/site/learn/documentation/latest/container/jmx.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/container/jmx.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/container/jmx.html (original)
+++ samza/site/learn/documentation/latest/container/jmx.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/container/jmx">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/container/jmx">1.2</a></li>
Modified: samza/site/learn/documentation/latest/container/metrics-table.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/container/metrics-table.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/container/metrics-table.html (original)
+++ samza/site/learn/documentation/latest/container/metrics-table.html Mon Dec 9 18:28:02 2019
@@ -555,7 +555,7 @@
</tr>
<tr>
<td>no-more-messages-SystemStreamPartition [<span class="system">system</span>, <span class="stream">stream</span>, <span class="partition">partition</span>]</td>
- <td>Indicates if kafka consumer is at head for particular partition</td>
+ <td>Indicates if kafka consumer is at head for particular partition. 1 if it is caught up, 0 otherwise.</td>
</tr>
<tr>
<td>blocking-poll-count-SystemStreamPartition [<span class="system">system</span>, <span class="stream">stream</span>, <span class="partition">partition</span>]</td>
@@ -938,7 +938,7 @@
</tr>
<tr>
<td>is-leader</td>
- <td>Denotes if the processor is a leader or not</td>
+ <td>Denotes if the processor is a leader or not. 1 if it is a leader, 0 otherwise.</td>
</tr>
<tr>
<td>barrier-creation</td>
Modified: samza/site/learn/documentation/latest/container/metrics.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/container/metrics.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/container/metrics.html (original)
+++ samza/site/learn/documentation/latest/container/metrics.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/container/metrics">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/container/metrics">1.2</a></li>
Modified: samza/site/learn/documentation/latest/container/samza-container.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/container/samza-container.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/container/samza-container.html (original)
+++ samza/site/learn/documentation/latest/container/samza-container.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/container/samza-container">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/container/samza-container">1.2</a></li>
Modified: samza/site/learn/documentation/latest/container/serialization.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/container/serialization.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/container/serialization.html (original)
+++ samza/site/learn/documentation/latest/container/serialization.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/container/serialization">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/container/serialization">1.2</a></li>
Modified: samza/site/learn/documentation/latest/container/state-management.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/container/state-management.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/container/state-management.html (original)
+++ samza/site/learn/documentation/latest/container/state-management.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/container/state-management">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/container/state-management">1.2</a></li>
Modified: samza/site/learn/documentation/latest/container/streams.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/container/streams.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/container/streams.html (original)
+++ samza/site/learn/documentation/latest/container/streams.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/container/streams">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/container/streams">1.2</a></li>
Modified: samza/site/learn/documentation/latest/container/windowing.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/container/windowing.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/container/windowing.html (original)
+++ samza/site/learn/documentation/latest/container/windowing.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/container/windowing">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/container/windowing">1.2</a></li>
Modified: samza/site/learn/documentation/latest/core-concepts/core-concepts.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/core-concepts/core-concepts.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/core-concepts/core-concepts.html (original)
+++ samza/site/learn/documentation/latest/core-concepts/core-concepts.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/core-concepts/core-concepts">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/core-concepts/core-concepts">1.2</a></li>
Modified: samza/site/learn/documentation/latest/deployment/deployment-model.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/deployment/deployment-model.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/deployment/deployment-model.html (original)
+++ samza/site/learn/documentation/latest/deployment/deployment-model.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/deployment/deployment-model">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/deployment/deployment-model">1.2</a></li>
@@ -603,13 +607,13 @@
<h3 id="running-samza-on-yarn">Running Samza on YARN</h3>
-<p>Samza integrates with <a href="learn/documentation/latest/deployment/yarn.html">Apache YARN</a> for running stream-processing as a managed service. We leverage YARN for isolation, multi-tenancy, resource-management and deployment for your applications. In this mode, you write your Samza application and submit it to be scheduled on a YARN cluster. You also specify its resource requirement - the number of containers needed, number of cores and memory required per-container. Samza then works with YARN to provision resources for your application and run it across a cluster of machines. It also handles failures of individual instances and automatically restarts them.</p>
+<p>Samza integrates with <a href="/learn/documentation/latest/deployment/yarn.html">Apache YARN</a> for running stream-processing as a managed service. We leverage YARN for isolation, multi-tenancy, resource-management and deployment for your applications. In this mode, you write your Samza application and submit it to be scheduled on a YARN cluster. You also specify its resource requirement - the number of containers needed, number of cores and memory required per-container. Samza then works with YARN to provision resources for your application and run it across a cluster of machines. It also handles failures of individual instances and automatically restarts them.</p>
<p>When multiple applications share the same YARN cluster, they need to be isolated from each other. For this purpose, Samza works with YARN to enforce cpu and memory limits. Any application that uses more than its requested share of memory or cpu is automatically terminated - thereby, allowing multi-tenancy. Just like you would for any YARN-based application, you can use YARN’s <a href="/learn/documentation/latest/deployment/yarn.html#application-master-ui">web UI</a> to manage your Samza jobs, view their logs etc.</p>
<h3 id="running-samza-in-standalone-mode">Running Samza in standalone mode</h3>
-<p>Often you want to embed and integrate Samza as a component within a larger application. To enable this, Samza supports a <a href="learn/documentation/latest/deployment/standalone.html">standalone mode</a> of deployment allowing greater control over your application’s life-cycle. In this model, Samza can be used just like any library you import within your Java application. This is identical to using a <a href="https://kafka.apache.org/">high-level Kafka consumer</a> to process your streams.</p>
+<p>Often you want to embed and integrate Samza as a component within a larger application. To enable this, Samza supports a <a href="/learn/documentation/latest/deployment/standalone.html">standalone mode</a> of deployment allowing greater control over your application’s life-cycle. In this model, Samza can be used just like any library you import within your Java application. This is identical to using a <a href="https://kafka.apache.org/">high-level Kafka consumer</a> to process your streams.</p>
<p>You can increase your application’s capacity by spinning up multiple instances. These instances will then dynamically coordinate with each other and distribute work among themselves. If an instance fails for some reason, the tasks running on it will be re-assigned to the remaining ones. By default, Samza uses <a href="https://zookeeper.apache.org/">Zookeeper</a> for coordination across individual instances. The coordination logic by itself is pluggable and hence, can integrate with other frameworks.</p>
Modified: samza/site/learn/documentation/latest/deployment/standalone.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/deployment/standalone.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/deployment/standalone.html (original)
+++ samza/site/learn/documentation/latest/deployment/standalone.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/deployment/standalone">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/deployment/standalone">1.2</a></li>
Modified: samza/site/learn/documentation/latest/deployment/yarn.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/deployment/yarn.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/deployment/yarn.html (original)
+++ samza/site/learn/documentation/latest/deployment/yarn.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/deployment/yarn">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/deployment/yarn">1.2</a></li>
Modified: samza/site/learn/documentation/latest/hadoop/consumer.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/hadoop/consumer.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/hadoop/consumer.html (original)
+++ samza/site/learn/documentation/latest/hadoop/consumer.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/hadoop/consumer">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/hadoop/consumer">1.2</a></li>
Modified: samza/site/learn/documentation/latest/hadoop/overview.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/hadoop/overview.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/hadoop/overview.html (original)
+++ samza/site/learn/documentation/latest/hadoop/overview.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/hadoop/overview">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/hadoop/overview">1.2</a></li>
Modified: samza/site/learn/documentation/latest/hadoop/producer.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/hadoop/producer.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/hadoop/producer.html (original)
+++ samza/site/learn/documentation/latest/hadoop/producer.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/hadoop/producer">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/hadoop/producer">1.2</a></li>
Modified: samza/site/learn/documentation/latest/index.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/index.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/index.html (original)
+++ samza/site/learn/documentation/latest/index.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/">1.2</a></li>
Modified: samza/site/learn/documentation/latest/introduction/architecture.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/introduction/architecture.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/introduction/architecture.html (original)
+++ samza/site/learn/documentation/latest/introduction/architecture.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/introduction/architecture">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/introduction/architecture">1.2</a></li>
Modified: samza/site/learn/documentation/latest/introduction/background.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/introduction/background.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/introduction/background.html (original)
+++ samza/site/learn/documentation/latest/introduction/background.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/introduction/background">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/introduction/background">1.2</a></li>
Modified: samza/site/learn/documentation/latest/introduction/concepts.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/introduction/concepts.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/introduction/concepts.html (original)
+++ samza/site/learn/documentation/latest/introduction/concepts.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/introduction/concepts">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/introduction/concepts">1.2</a></li>
Modified: samza/site/learn/documentation/latest/jobs/configuration-table.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/jobs/configuration-table.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/jobs/configuration-table.html (original)
+++ samza/site/learn/documentation/latest/jobs/configuration-table.html Mon Dec 9 18:28:02 2019
@@ -347,7 +347,7 @@
<strong>required</strong> configuration. Specify a comma separated list of range(s) to determine which
partition matches, and thus statically assigned to the Job. For example "2,3,11-20", statically assigns
partition 2, 3, and 11 to 20 for all the specified system and streams (topics in case of Kafka) to the job.
- A singel configuration value like "19" is valid as well. This statically assigns partition 19.
+ A single configuration value like "19" is valid as well. This statically assigns partition 19.
For config validation each element in the comma separated list much conform to one of the
following regex:
<ul>
@@ -1705,6 +1705,49 @@
</td>
</tr>
+ <tr>
+ <td class="property" id="stores-changelog-max-message-size-bytes">stores.<span class="store">store-name</span>.changelog.max.message.size.bytes</td>
+ <td class="default">1048576</td>
+ <td class="description">
+ This property sets the maximum size of the messages allowed in the changelog.
+ The default value is 1 MB.
+ </td>
+ </tr>
+
+ <tr>
+ <td class="property" id="stores-disallow-large-messages">stores.<span class="store">store-name</span>.disallow.large.messages</td>
+ <td class="default">false</td>
+ <td class="description">
+ This property, when turned on, tells the system to expect large messages to be put in the stores
+ and disallows them. It looks out for any large messages greater than
+ <a href="#stores-changelog-max-message-size-bytes" class="property">stores.*.changelog.max.message.size.bytes</a>
+ and throws a SamzaException when it finds one, stating that the record is too large.
+ In the case of using CachedStore, it will serialize the message first, validate
+ its size and then cache it if the size is under the permissible limit.
+ Note that if enabled retroactively, this may cause a performance regression due to the pre-caching serialization.
+ When this property is turned on, the <a href="#stores-drop-large-messages" class="property">stores.*.drop.large.messages</a>
+ configuration is ignored. The default value for this config is false. When this property is not set,
+ <a href="#stores-drop-large-messages" class="property">stores.*.drop.large.messages</a>
+ determines the large message handling behavior.
+ </td>
+ </tr>
+
+ <tr>
+ <td class="property" id="stores-drop-large-messages">stores.<span class="store">store-name</span>.drop.large.messages</td>
+ <td class="default">false</td>
+ <td class="description">
+ This property, when turned on, causes messages larger than
+ <a href="#stores-changelog-max-message-size-bytes" class="property">stores.*.changelog.max.message.size.bytes</a>
+ to be dropped from the underlying store and changelog. No exception is thrown when a large message is encountered.
+ For the case when storing messages in the cache is enabled along with this config being
+ turned on (look at the <a href="#stores-rocksdb-object-cache-size" class="property">stores.*.object.cache.size</a>
+ config), the large message is stored in the cache but is not written to the
+ changelog and underlying store, resulting in an inconsistent state temporarily.
+ When this property is turned off, large messages will be sent to the changelog topic as is,
+ and may cause the container to fail during commit.
+ </td>
+ </tr>
+
<tr>
<th colspan="3" class="section" id="keyvalue-rocksdb">
Using RocksDB for key-value storage<br>
Modified: samza/site/learn/documentation/latest/jobs/configuration.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/jobs/configuration.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/jobs/configuration.html (original)
+++ samza/site/learn/documentation/latest/jobs/configuration.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/jobs/configuration">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/jobs/configuration">1.2</a></li>
Modified: samza/site/learn/documentation/latest/jobs/job-runner.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/jobs/job-runner.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/jobs/job-runner.html (original)
+++ samza/site/learn/documentation/latest/jobs/job-runner.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/jobs/job-runner">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/jobs/job-runner">1.2</a></li>
Modified: samza/site/learn/documentation/latest/jobs/logging.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/jobs/logging.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/jobs/logging.html (original)
+++ samza/site/learn/documentation/latest/jobs/logging.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/jobs/logging">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/jobs/logging">1.2</a></li>
Modified: samza/site/learn/documentation/latest/jobs/packaging.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/jobs/packaging.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/jobs/packaging.html (original)
+++ samza/site/learn/documentation/latest/jobs/packaging.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/jobs/packaging">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/jobs/packaging">1.2</a></li>
Modified: samza/site/learn/documentation/latest/jobs/reprocessing.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/jobs/reprocessing.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/jobs/reprocessing.html (original)
+++ samza/site/learn/documentation/latest/jobs/reprocessing.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/jobs/reprocessing">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/jobs/reprocessing">1.2</a></li>
Modified: samza/site/learn/documentation/latest/jobs/samza-configurations.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/jobs/samza-configurations.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/jobs/samza-configurations.html (original)
+++ samza/site/learn/documentation/latest/jobs/samza-configurations.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/jobs/samza-configurations">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/jobs/samza-configurations">1.2</a></li>
@@ -797,7 +801,7 @@
<tr>
<td>job.systemstreampartition.<br>matcher.config.<br>range</td>
<td></td>
-<td>If <code>job.systemstreampartition.matcher.class</code> is specified, and the value of this property is <code>org.apache.samza.system.RangeSystemStreamPartitionMatcher</code>, then this property is a required configuration. Specify a comma separated list of range(s) to determine which partition matches, and thus statically assigned to the Job. For example "2,3,11-20”, statically assigns partition 2, 3, and 11 to 20 for all the specified system and streams (topics in case of Kafka) to the job. A singel configuration value like “19” is valid as well. This statically assigns partition 19. For config validation each element in the comma separated list much conform to one of the following regex:<br>“<code>(\\d+)</code>” or “<code>(\\d+-\\d+)</code>”</td>
+<td>If <code>job.systemstreampartition.matcher.class</code> is specified, and the value of this property is <code>org.apache.samza.system.RangeSystemStreamPartitionMatcher</code>, then this property is a required configuration. Specify a comma separated list of range(s) to determine which partition matches, and thus statically assigned to the Job. For example "2,3,11-20”, statically assigns partition 2, 3, and 11 to 20 for all the specified system and streams (topics in case of Kafka) to the job. A single configuration value like “19” is valid as well. This statically assigns partition 19. For config validation each element in the comma separated list much conform to one of the following regex:<br>“<code>(\\d+)</code>” or “<code>(\\d+-\\d+)</code>”</td>
</tr>
<tr>
<td>job.systemstreampartition.<br>matcher.config.<br>regex</td>
@@ -810,6 +814,11 @@
<td>This configuration can be used to specify the Java supported regex to match the StreamJobFactory for which the static partition assignment should be enabled. This configuration enables the partition assignment feature to be used for custom StreamJobFactory(ies) as well.<br>This config defaults to the following value: “<em>org\.apache\.samza\.job\.local(.<em>ProcessJobFactory | .</em>ThreadJobFactory)</em>”, which enables static partition assignment when job.factory.class is set to <code>org.apache.samza.job.local.ProcessJobFactory</code> or <code>org.apache.samza.job.local.ThreadJobFactory</code>.</td>
</tr>
<tr>
+<td>job.systemstreampartition.<br>input.expansion.enabled</td>
+<td>true</td>
+<td>When enabled, this allows stateful jobs to expand or contract their partition count by a multiple of the previous count so that events from an input stream partition are processed on the same task as before. This will prevent erroneous results. This feature is disabled if the configuration is set to false or if the job is stateless. See <a href="https://cwiki.apache.org/confluence/display/SAMZA/SEP-5%3A+Enable+partition+expansion+of+input+streams">SEP-5</a> for more details.</td>
+</tr>
+<tr>
<td>job.security.manager.<br>factory</td>
<td>(none)</td>
<td>This is the factory class used to create the proper SecurityManager to handle security for Samza containers when running in a secure environment, such as Yarn with Kerberos eanbled. Samza ships with one security manager by default:<br><br><code>org.apache.samza.job.yarn.SamzaYarnSecurityManagerFactory</code><br>Supports Samza containers to run properly in a Kerberos enabled Yarn cluster. Each Samza container, once started, will create a SamzaContainerSecurityManager. SamzaContainerSecurityManager runs on its separate thread and update user’s delegation tokens at the interval specified by yarn.token.renewal.interval.seconds. See Yarn Security for details.</td>
@@ -1425,7 +1434,7 @@ Documentation and samples found <a href=
<h3 id="4-state-storage"><a name="state-storage"></a><a href="#state-storage">4. State Storage</a></h3>
-<p>These properties define Samza’s storage mechanism for efficient <a href="../container/state-management.html">stateful stream processing</a>.</p>
+<p>These properties define Samza’s storage mechanism for efficient <a href="../container/state-management.html">stateful stream processing</a>. Stateful applications should configure base directories for durable and non-durable stores using <code>job.logged.store.base.dir</code> and <code>job.non.logged.store.base.dir</code> respectively.</p>
<table><thead>
<tr>
@@ -1455,10 +1464,35 @@ Documentation and samples found <a href=
<td>Samza stores are local to a container. If the container fails, the contents of the store are lost. To prevent loss of data, you need to set this property to configure a changelog stream: Samza then ensures that writes to the store are replicated to this stream, and the store is restored from this stream after a failure. The value of this property is given in the form system-name.stream-name. The “system-name” part is optional. If it is omitted you must specify the system in job.changelog.system config. Any output stream can be used as changelog, but you must ensure that only one job ever writes to a given changelog stream (each instance of a job and each store needs its own changelog stream).</td>
</tr>
<tr>
+<td>stores.<strong><em>store-name</em></strong>.changelog.max.message.size.bytes</td>
+<td>1048576</td>
+<td>This property sets the maximum size of the messages allowed in the changelog. The default value is 1 MB.</td>
+</tr>
+<tr>
+<td>stores.<strong><em>store-name</em></strong>.disallow.large.messages</td>
+<td>false</td>
+<td>This property, when turned on, tells the system to expect large messages to be put in the stores and disallows them. It looks out for any large messages greater than <code>stores.*.changelog.max.message.size.bytes</code> and throws a SamzaException when it finds one, stating that the record is too large. In the case of using CachedStore, it will serialize the message first, validate its size and then cache it if the size is under the permissible limit. Note that if enabled retroactively, this may cause a performance regression due to the pre-caching serialization. When this property is turned on, the <code>stores.*.drop.large.messages</code> configuration is ignored. The default value for this config is false. When this property is not set, <code>stores.*.drop.large.messages</code> determines the large message handling behavior.</td>
+</tr>
+<tr>
+<td>stores.<strong><em>store-name</em></strong>.drop.large.messages</td>
+<td>false</td>
+<td>This property, when turned on, causes messages larger than <code>stores.*.changelog.max.message.size.bytes</code> to be dropped from the underlying store and changelog. No exception is thrown when a large message is encountered. For the case when storing messages in the cache is enabled along with this config being turned on (look at the <code>stores.*.object.cache.size</code> config for reference), the large message is stored in the cache but is not written to the changelog and underlying store, resulting in an inconsistent state temporarily. When this property is turned off, large messages will be sent to the changelog topic as is, and may cause the container to fail during commit.</td>
+</tr>
+<tr>
<td>stores.<strong><em>store-name</em></strong>.rocksdb.ttl.ms</td>
<td></td>
<td><strong>For RocksDB:</strong> The time-to-live of the store. Please note it’s not a strict TTL limit (removed only after compaction). Please use caution opening a database with and without TTL, as it might corrupt the database. Please make sure to read the <a href="https://github.com/facebook/rocksdb/wiki/Time-to-Live">constraints</a> before using.</td>
</tr>
+<tr>
+<td>job.logged.store.base.dir</td>
+<td><em>user.dir</em> environment property if set, else current working directory of the process</td>
+<td>The base directory for changelog stores used by Samza application. Another way to configure the base directory is by setting environment variable <code>LOGGED_STORE_BASE_DIR</code>. <strong>Note:</strong> The environment variable takes precedence over <code>job.logged.store.base.dir</code>. <br>By opting in, users are responsible for cleaning up the store directories if necessary. Jobs using host affinity should ensure that the stores are persisted across application/container restarts. This means that the location and cleanup of this directory should be separate from the container lifecycle and resource cleanup.</td>
+</tr>
+<tr>
+<td>job.non-logged.store.base.dir</td>
+<td><em>user.dir</em> environment property if set, else current working directory of the process</td>
+<td>The base directory for non-changelog stores used by Samza application. <br>In YARN, the default behaviour without the configuration is to create non-changelog store directories in CWD which happens to be the YARN container directory. This gets cleaned up periodically as part of NodeManager’s deletion service, which is controlled by the YARN config <code>yarn.nodemanager.delete.debug-delay-sec</code>. <br>In non-YARN deployment models or when using a different directory other than YARN container directory, stores need to be cleaned up periodically.</td>
+</tr>
</tbody></table>
<h5 id="4-1-advanced-storage-configurations"><a name="advanced-storage-configurations"></a><a href="#advanced-storage-configurations">4.1 Advanced Storage Configurations</a></h5>
@@ -1471,16 +1505,6 @@ Documentation and samples found <a href=
</tr>
</thead><tbody>
<tr>
-<td>job.logged.store.base.dir</td>
-<td><em>user.dir</em> environment property if set, else current working directory of the process</td>
-<td>The base directory for changelog stores used by Samza application. Another way to configure the base directory is by setting environment variable <code>LOGGED_STORE_BASE_DIR</code>. <strong>Note:</strong> The environment variable takes precedence over <code>job.logged.store.base.dir</code>. <br>By opting in, users are responsible for cleaning up the store directories if necessary. Jobs using host affinity should ensure that the stores are persisted across application/container restarts. This means that the location and cleanup of this directory should be separate from the container lifecycle and resource cleanup.</td>
-</tr>
-<tr>
-<td>job.non-logged.store.base.dir</td>
-<td><em>user.dir</em> environment property if set, else current working directory of the process</td>
-<td>The base directory for non-changelog stores used by Samza application. <br>In YARN, the default behaviour without the configuration is to create non-changelog store directories in CWD which happens to be the YARN container directory. This gets cleaned up periodically as part of NodeManager’s deletion service, which is controlled by the YARN config <code>yarn.nodemanager.delete.debug-delay-sec</code>. <br>In non-YARN deployment models or when using a different directory other than YARN container directory, stores need to be cleaned up periodically.</td>
-</tr>
-<tr>
<td>stores.default.changelog.<br>replication.factor</td>
<td>2</td>
<td>This property defines the default number of replicas to use for the change log stream.</td>
@@ -1550,6 +1574,26 @@ Documentation and samples found <a href=
<td>(none)</td>
<td>A list of <a href="https://github.com/facebook/rocksdb/blob/master/include/rocksdb/db.h#L409">RocksDB properties</a> to expose as metrics (gauges).</td>
</tr>
+<tr>
+<td>stores.<strong><em>store-name</em></strong>.<br>rocksdb.delete.obsolete.files.period.micros</td>
+<td>21600000000</td>
+<td>This property specifies the period in microseconds to delete obsolete files regardless of files removed during compaction. Allowed range is up to 9223372036854775807.</td>
+</tr>
+<tr>
+<td>stores.<strong><em>store-name</em></strong>.<br>rocksdb.max.manifest.file.size</td>
+<td>18446744073709551615</td>
+<td>This property specifies the maximum size of the MANIFEST data file, after which it is rotated. Default value is also the maximum, making it practically unlimited: only one manifest file is used.</td>
+</tr>
+<tr>
+<td>stores.<strong><em>store-name</em></strong>.<br>side.inputs</td>
+<td>(none)</td>
+<td>Samza applications with stores that are populated by a secondary data sources such as HDFS, but otherwise ready-only, can leverage side inputs. Stores configured with side inputs use the the source streams to bootstrap data in the absence of local copy thereby, reducing additional copy of the data in changelog. It is also recommended to enable host affinity feature when turning on side inputs to prevent bootstrapping of the data during container restarts. The value is a comma-separated list of streams.<br> Each stream is of the format <code>system-name.stream-name</code>. Additionally, applications should add the side inputs to job inputs (<code>task.inputs</code>) and configure side input processor (<code>stores.store-name.side.inputs.processor.factory</code>).</td>
+</tr>
+<tr>
+<td>stores.<strong><em>store-name</em></strong>.<br>side.inputs.processor.factory</td>
+<td>(none)</td>
+<td>The value is a fully-qualified name of a Java class that implements <a href="../api/javadocs/org/apache/samza/storage/SideInputProcessorFactory.html">SideInputProcessorFactory</a>. It is a required configuration for stores with side inputs (<code>stores.store-name.side.inputs</code>).</td>
+</tr>
</tbody></table>
<h3 id="5-deployment"><a name="deployment"></a><a href="#deployment">5. Deployment</a></h3>
@@ -1607,6 +1651,16 @@ Documentation and samples found <a href=
<td>This property determines how frequently a container is allowed to fail before we give up and fail the job. If the same container has failed more than <code>cluster-manager.container.retry.count</code> times, and the time between failures was less than this property <code>cluster-manager.container.retry.window.ms</code> (in milliseconds), then we fail the job. There is no limit to the number of times we will restart a container if the time between failures is greater than <code>cluster-manager.container.retry.window.ms</code>.</td>
</tr>
<tr>
+<td>cluster-manager.container.preferred-host.last.retry.delay.ms</td>
+<td>360000</td>
+<td>The delay added to the last retry for a failing container after all but one of cluster-manager.container.retry.count retries have been exhausted. The delay is only added when <code>job.host-affinity.enabled</code> is true and the retried request is for a preferred host. This addresses the issue where there may be a delay when a preferred host is marked invalid and the container continuously attempts to restart and fail on the invalid preferred host. This property is useful to prevent the <code>cluster-manager.container.retry.count</code> from being exceeded too quickly for such scenarios.</td>
+</tr>
+<tr>
+<td>cluster-manager.container.fail.job.after.retries</td>
+<td>true</td>
+<td>This configuration sets the behavior of the job after all <code>cluster-manager.container.retry.count</code>s are exhausted and each retry is within the <code>cluster-manager.container.retry.window.ms</code> period on any single container. If set to true, the whole job will fail if any container fails after the last retry. If set to false, the job will continue to run without the failed container. The typical use cases of setting this to false is to aid in debugging the cluster manager when containers fail unexpectedly and also to allow other healthy containers to continue to run so that lag does not accumulate across all containers. Samza job operators should diligent in monitoring the <code>job-healthy</code> and <code>failed-containers</code> metrics when setting this configuration to false. A full restart of the job is required if another attempt to restart the container is needed after the container failure.</td>
+</tr>
+<tr>
<td>cluster-manager.jobcoordinator.jmx.enabled</td>
<td>true</td>
<td>This is deprecated in favor of <code>job.jmx.enabled</code></td>
Modified: samza/site/learn/documentation/latest/jobs/web-ui-rest-api.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/jobs/web-ui-rest-api.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/jobs/web-ui-rest-api.html (original)
+++ samza/site/learn/documentation/latest/jobs/web-ui-rest-api.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/jobs/web-ui-rest-api">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/jobs/web-ui-rest-api">1.2</a></li>
Modified: samza/site/learn/documentation/latest/jobs/yarn-jobs.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/jobs/yarn-jobs.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/jobs/yarn-jobs.html (original)
+++ samza/site/learn/documentation/latest/jobs/yarn-jobs.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/jobs/yarn-jobs">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/jobs/yarn-jobs">1.2</a></li>
Modified: samza/site/learn/documentation/latest/operations/kafka.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/operations/kafka.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/operations/kafka.html (original)
+++ samza/site/learn/documentation/latest/operations/kafka.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/operations/kafka">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/operations/kafka">1.2</a></li>
Modified: samza/site/learn/documentation/latest/operations/monitoring.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/operations/monitoring.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/operations/monitoring.html (original)
+++ samza/site/learn/documentation/latest/operations/monitoring.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/operations/monitoring">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/operations/monitoring">1.2</a></li>
@@ -1504,7 +1508,7 @@ in the metrics reference sheet.</p>
<tr>
<td></td>
<td>no-more-messages-SystemStreamPartition [<system>, <stream>, <partition>]</td>
-<td>Indicates if the Kafka consumer is at the head for particular partition.</td>
+<td>Indicates if the Kafka consumer is at the head for particular partition. 1 if it is caught up, 0 otherwise.</td>
</tr>
<tr>
<td></td>
Modified: samza/site/learn/documentation/latest/operations/security.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/operations/security.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/operations/security.html (original)
+++ samza/site/learn/documentation/latest/operations/security.html Mon Dec 9 18:28:02 2019
@@ -520,6 +520,10 @@
+ <li class="hide"><a href="/learn/documentation/1.3/operations/security">1.3</a></li>
+
+
+
<li class="hide"><a href="/learn/documentation/1.2/operations/security">1.2</a></li>
Modified: samza/site/learn/documentation/latest/rest/javadocs/allclasses-frame.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/rest/javadocs/allclasses-frame.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/rest/javadocs/allclasses-frame.html (original)
+++ samza/site/learn/documentation/latest/rest/javadocs/allclasses-frame.html Mon Dec 9 18:28:02 2019
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_121) on Wed Jun 12 11:47:58 PDT 2019 -->
-<title>All Classes (samza-rest_2.11 1.3.0-SNAPSHOT API)</title>
-<meta name="date" content="2019-06-12">
+<!-- Generated by javadoc (1.8.0_212) on Mon Dec 09 10:02:23 PST 2019 -->
+<title>All Classes (samza-rest_2.11 1.4.0-SNAPSHOT API)</title>
+<meta name="date" content="2019-12-09">
<link rel="stylesheet" type="text/css" href="stylesheet.css" title="Style">
<script type="text/javascript" src="script.js"></script>
</head>
Modified: samza/site/learn/documentation/latest/rest/javadocs/allclasses-noframe.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/rest/javadocs/allclasses-noframe.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/rest/javadocs/allclasses-noframe.html (original)
+++ samza/site/learn/documentation/latest/rest/javadocs/allclasses-noframe.html Mon Dec 9 18:28:02 2019
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_121) on Wed Jun 12 11:47:58 PDT 2019 -->
-<title>All Classes (samza-rest_2.11 1.3.0-SNAPSHOT API)</title>
-<meta name="date" content="2019-06-12">
+<!-- Generated by javadoc (1.8.0_212) on Mon Dec 09 10:02:23 PST 2019 -->
+<title>All Classes (samza-rest_2.11 1.4.0-SNAPSHOT API)</title>
+<meta name="date" content="2019-12-09">
<link rel="stylesheet" type="text/css" href="stylesheet.css" title="Style">
<script type="text/javascript" src="script.js"></script>
</head>
Modified: samza/site/learn/documentation/latest/rest/javadocs/constant-values.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/rest/javadocs/constant-values.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/rest/javadocs/constant-values.html (original)
+++ samza/site/learn/documentation/latest/rest/javadocs/constant-values.html Mon Dec 9 18:28:02 2019
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_121) on Wed Jun 12 11:47:58 PDT 2019 -->
-<title>Constant Field Values (samza-rest_2.11 1.3.0-SNAPSHOT API)</title>
-<meta name="date" content="2019-06-12">
+<!-- Generated by javadoc (1.8.0_212) on Mon Dec 09 10:02:23 PST 2019 -->
+<title>Constant Field Values (samza-rest_2.11 1.4.0-SNAPSHOT API)</title>
+<meta name="date" content="2019-12-09">
<link rel="stylesheet" type="text/css" href="stylesheet.css" title="Style">
<script type="text/javascript" src="script.js"></script>
</head>
@@ -12,7 +12,7 @@
<script type="text/javascript"><!--
try {
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="Constant Field Values (samza-rest_2.11 1.3.0-SNAPSHOT API)";
+ parent.document.title="Constant Field Values (samza-rest_2.11 1.4.0-SNAPSHOT API)";
}
}
catch(err) {
Modified: samza/site/learn/documentation/latest/rest/javadocs/deprecated-list.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/rest/javadocs/deprecated-list.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/rest/javadocs/deprecated-list.html (original)
+++ samza/site/learn/documentation/latest/rest/javadocs/deprecated-list.html Mon Dec 9 18:28:02 2019
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_121) on Wed Jun 12 11:47:58 PDT 2019 -->
-<title>Deprecated List (samza-rest_2.11 1.3.0-SNAPSHOT API)</title>
-<meta name="date" content="2019-06-12">
+<!-- Generated by javadoc (1.8.0_212) on Mon Dec 09 10:02:23 PST 2019 -->
+<title>Deprecated List (samza-rest_2.11 1.4.0-SNAPSHOT API)</title>
+<meta name="date" content="2019-12-09">
<link rel="stylesheet" type="text/css" href="stylesheet.css" title="Style">
<script type="text/javascript" src="script.js"></script>
</head>
@@ -12,7 +12,7 @@
<script type="text/javascript"><!--
try {
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="Deprecated List (samza-rest_2.11 1.3.0-SNAPSHOT API)";
+ parent.document.title="Deprecated List (samza-rest_2.11 1.4.0-SNAPSHOT API)";
}
}
catch(err) {
Modified: samza/site/learn/documentation/latest/rest/javadocs/help-doc.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/rest/javadocs/help-doc.html?rev=1871092&r1=1871091&r2=1871092&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/rest/javadocs/help-doc.html (original)
+++ samza/site/learn/documentation/latest/rest/javadocs/help-doc.html Mon Dec 9 18:28:02 2019
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_121) on Wed Jun 12 11:47:58 PDT 2019 -->
-<title>API Help (samza-rest_2.11 1.3.0-SNAPSHOT API)</title>
-<meta name="date" content="2019-06-12">
+<!-- Generated by javadoc (1.8.0_212) on Mon Dec 09 10:02:23 PST 2019 -->
+<title>API Help (samza-rest_2.11 1.4.0-SNAPSHOT API)</title>
+<meta name="date" content="2019-12-09">
<link rel="stylesheet" type="text/css" href="stylesheet.css" title="Style">
<script type="text/javascript" src="script.js"></script>
</head>
@@ -12,7 +12,7 @@
<script type="text/javascript"><!--
try {
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="API Help (samza-rest_2.11 1.3.0-SNAPSHOT API)";
+ parent.document.title="API Help (samza-rest_2.11 1.4.0-SNAPSHOT API)";
}
}
catch(err) {