http://git-wip-us.apache.org/repos/asf/storm-site/blob/a7a19afb/content/releases/1.0.4/storm-cassandra.html
----------------------------------------------------------------------
diff --git a/content/releases/1.0.4/storm-cassandra.html 
b/content/releases/1.0.4/storm-cassandra.html
index 8afbd2a..b7aad22 100644
--- a/content/releases/1.0.4/storm-cassandra.html
+++ b/content/releases/1.0.4/storm-cassandra.html
@@ -82,18 +82,16 @@
                         
                       
                         
-                          <li><a 
href="/releases/1.1.0/index.html">1.1.0</a></li>
-                        
                       
                         
+                          <li><a 
href="/releases/1.1.0/index.html">1.1.0</a></li>
+                        
                       
                         
                           <li><a 
href="/releases/1.0.4/index.html">1.0.4</a></li>
                         
                       
                         
-                      
-                        
                           <li><a 
href="/releases/1.0.3/index.html">1.0.3</a></li>
                         
                       
@@ -104,6 +102,8 @@
                         
                       
                         
+                      
+                        
                           <li><a 
href="/releases/0.10.2/index.html">0.10.2</a></li>
                         
                       
@@ -144,7 +144,7 @@
                         <li><a href="/contribute/BYLAWS.html">ByLaws</a></li>
                     </ul>
                 </li>
-                <li><a href="/2017/09/15/storm105-released.html" 
id="news">News</a></li>
+                <li><a href="/2018/02/14/storm106-released.html" 
id="news">News</a></li>
             </ul>
         </nav>
     </div>
@@ -239,7 +239,7 @@ Provides simple DSL to map storm <em>Tuple</em> to 
Cassandra Query Language <em>
 
 <h5 id="insert-query-including-only-the-specified-tuple-fields">Insert query 
including only the specified tuple fields.</h5>
 <div class="highlight"><pre><code class="language-java" data-lang="java">
-    <span class="k">new</span> <span 
class="nf">CassandraWriterBolt</span><span class="p">(</span>
+    <span class="k">new</span> <span 
class="nf">CassandraWriterBolt</span><span class="o">(</span>
         <span class="n">async</span><span class="o">(</span>
             <span class="n">simpleQuery</span><span class="o">(</span><span 
class="s">"INSERT INTO album (title,year,performer,genre,tracks) VALUES (?, ?, 
?, ?, ?);"</span><span class="o">)</span>
                 <span class="o">.</span><span class="na">with</span><span 
class="o">(</span>
@@ -250,7 +250,7 @@ Provides simple DSL to map storm <em>Tuple</em> to 
Cassandra Query Language <em>
 </code></pre></div>
 <h5 id="insert-query-including-all-tuple-fields">Insert query including all 
tuple fields.</h5>
 <div class="highlight"><pre><code class="language-java" data-lang="java">
-    <span class="k">new</span> <span 
class="nf">CassandraWriterBolt</span><span class="p">(</span>
+    <span class="k">new</span> <span 
class="nf">CassandraWriterBolt</span><span class="o">(</span>
         <span class="n">async</span><span class="o">(</span>
             <span class="n">simpleQuery</span><span class="o">(</span><span 
class="s">"INSERT INTO album (title,year,performer,genre,tracks) VALUES (?, ?, 
?, ?, ?);"</span><span class="o">)</span>
                 <span class="o">.</span><span class="na">with</span><span 
class="o">(</span> <span class="n">all</span><span class="o">()</span> <span 
class="o">)</span>
@@ -259,7 +259,7 @@ Provides simple DSL to map storm <em>Tuple</em> to 
Cassandra Query Language <em>
 </code></pre></div>
 <h5 id="insert-multiple-queries-from-one-input-tuple">Insert multiple queries 
from one input tuple.</h5>
 <div class="highlight"><pre><code class="language-java" data-lang="java">
-    <span class="k">new</span> <span 
class="nf">CassandraWriterBolt</span><span class="p">(</span>
+    <span class="k">new</span> <span 
class="nf">CassandraWriterBolt</span><span class="o">(</span>
         <span class="n">async</span><span class="o">(</span>
             <span class="n">simpleQuery</span><span class="o">(</span><span 
class="s">"INSERT INTO titles_per_album (title,year,performer,genre,tracks) 
VALUES (?, ?, ?, ?, ?);"</span><span class="o">).</span><span 
class="na">with</span><span class="o">(</span><span class="n">all</span><span 
class="o">())),</span>
             <span class="n">simpleQuery</span><span class="o">(</span><span 
class="s">"INSERT INTO titles_per_performer (title,year,performer,genre,tracks) 
VALUES (?, ?, ?, ?, ?);"</span><span class="o">).</span><span 
class="na">with</span><span class="o">(</span><span class="n">all</span><span 
class="o">()))</span>
@@ -268,7 +268,7 @@ Provides simple DSL to map storm <em>Tuple</em> to 
Cassandra Query Language <em>
 </code></pre></div>
 <h5 id="insert-query-using-querybuilder">Insert query using QueryBuilder</h5>
 <div class="highlight"><pre><code class="language-java" data-lang="java">
-    <span class="k">new</span> <span 
class="nf">CassandraWriterBolt</span><span class="p">(</span>
+    <span class="k">new</span> <span 
class="nf">CassandraWriterBolt</span><span class="o">(</span>
         <span class="n">async</span><span class="o">(</span>
             <span class="n">simpleQuery</span><span class="o">(</span><span 
class="s">"INSERT INTO album (title,year,perfomer,genre,tracks) VALUES (?, ?, 
?, ?, ?);"</span><span class="o">)</span>
                 <span class="o">.</span><span class="na">with</span><span 
class="o">(</span><span class="n">all</span><span class="o">()))</span>
@@ -277,7 +277,7 @@ Provides simple DSL to map storm <em>Tuple</em> to 
Cassandra Query Language <em>
 </code></pre></div>
 <h5 id="insert-query-with-static-bound-query">Insert query with static bound 
query</h5>
 <div class="highlight"><pre><code class="language-java" data-lang="java">
-    <span class="k">new</span> <span 
class="nf">CassandraWriterBolt</span><span class="p">(</span>
+    <span class="k">new</span> <span 
class="nf">CassandraWriterBolt</span><span class="o">(</span>
          <span class="n">async</span><span class="o">(</span>
             <span class="n">boundQuery</span><span class="o">(</span><span 
class="s">"INSERT INTO album (title,year,performer,genre,tracks) VALUES (?, ?, 
?, ?, ?);"</span><span class="o">)</span>
                 <span class="o">.</span><span class="na">bind</span><span 
class="o">(</span><span class="n">all</span><span class="o">());</span>
@@ -286,7 +286,7 @@ Provides simple DSL to map storm <em>Tuple</em> to 
Cassandra Query Language <em>
 </code></pre></div>
 <h5 
id="insert-query-with-static-bound-query-using-named-setters-and-aliases">Insert
 query with static bound query using named setters and aliases</h5>
 <div class="highlight"><pre><code class="language-java" data-lang="java">
-    <span class="k">new</span> <span 
class="nf">CassandraWriterBolt</span><span class="p">(</span>
+    <span class="k">new</span> <span 
class="nf">CassandraWriterBolt</span><span class="o">(</span>
          <span class="n">async</span><span class="o">(</span>
             <span class="n">boundQuery</span><span class="o">(</span><span 
class="s">"INSERT INTO album (title,year,performer,genre,tracks) VALUES (:ti, 
:ye, :pe, :ge, :tr);"</span><span class="o">)</span>
                 <span class="o">.</span><span class="na">bind</span><span 
class="o">(</span>
@@ -301,26 +301,26 @@ Provides simple DSL to map storm <em>Tuple</em> to 
Cassandra Query Language <em>
 </code></pre></div>
 <h5 
id="insert-query-with-bound-statement-load-from-storm-configuration">Insert 
query with bound statement load from storm configuration</h5>
 <div class="highlight"><pre><code class="language-java" data-lang="java">
-    <span class="k">new</span> <span 
class="nf">CassandraWriterBolt</span><span class="p">(</span>
+    <span class="k">new</span> <span 
class="nf">CassandraWriterBolt</span><span class="o">(</span>
          <span class="n">boundQuery</span><span class="o">(</span><span 
class="n">named</span><span class="o">(</span><span 
class="s">"insertIntoAlbum"</span><span class="o">))</span>
             <span class="o">.</span><span class="na">bind</span><span 
class="o">(</span><span class="n">all</span><span class="o">());</span>
 </code></pre></div>
 <h5 id="insert-query-with-bound-statement-load-from-tuple-field">Insert query 
with bound statement load from tuple field</h5>
 <div class="highlight"><pre><code class="language-java" data-lang="java">
-    <span class="k">new</span> <span 
class="nf">CassandraWriterBolt</span><span class="p">(</span>
+    <span class="k">new</span> <span 
class="nf">CassandraWriterBolt</span><span class="o">(</span>
          <span class="n">boundQuery</span><span class="o">(</span><span 
class="n">namedByField</span><span class="o">(</span><span 
class="s">"cql"</span><span class="o">))</span>
             <span class="o">.</span><span class="na">bind</span><span 
class="o">(</span><span class="n">all</span><span class="o">());</span>
 </code></pre></div>
 <h5 id="insert-query-with-batch-statement">Insert query with batch 
statement</h5>
 <div class="highlight"><pre><code class="language-java" data-lang="java">
     <span class="c1">// Logged</span>
-    <span class="k">new</span> <span class="n">CassandraWriterBolt</span><span 
class="o">(</span><span class="n">loggedBatch</span><span class="o">(</span>
+    <span class="k">new</span> <span 
class="nf">CassandraWriterBolt</span><span class="o">(</span><span 
class="n">loggedBatch</span><span class="o">(</span>
             <span class="n">simpleQuery</span><span class="o">(</span><span 
class="s">"INSERT INTO titles_per_album (title,year,performer,genre,tracks) 
VALUES (?, ?, ?, ?, ?);"</span><span class="o">).</span><span 
class="na">with</span><span class="o">(</span><span class="n">all</span><span 
class="o">())),</span>
             <span class="n">simpleQuery</span><span class="o">(</span><span 
class="s">"INSERT INTO titles_per_performer (title,year,performer,genre,tracks) 
VALUES (?, ?, ?, ?, ?);"</span><span class="o">).</span><span 
class="na">with</span><span class="o">(</span><span class="n">all</span><span 
class="o">()))</span>
         <span class="o">)</span>
     <span class="o">);</span>
 <span class="c1">// UnLogged</span>
-    <span class="k">new</span> <span class="n">CassandraWriterBolt</span><span 
class="o">(</span><span class="n">unLoggedBatch</span><span class="o">(</span>
+    <span class="k">new</span> <span 
class="nf">CassandraWriterBolt</span><span class="o">(</span><span 
class="n">unLoggedBatch</span><span class="o">(</span>
             <span class="n">simpleQuery</span><span class="o">(</span><span 
class="s">"INSERT INTO titles_per_album (title,year,performer,genre,tracks) 
VALUES (?, ?, ?, ?, ?);"</span><span class="o">).</span><span 
class="na">with</span><span class="o">(</span><span class="n">all</span><span 
class="o">())),</span>
             <span class="n">simpleQuery</span><span class="o">(</span><span 
class="s">"INSERT INTO titles_per_performer (title,year,performer,genre,tracks) 
VALUES (?, ?, ?, ?, ?);"</span><span class="o">).</span><span 
class="na">with</span><span class="o">(</span><span class="n">all</span><span 
class="o">()))</span>
         <span class="o">)</span>
@@ -330,32 +330,32 @@ Provides simple DSL to map storm <em>Tuple</em> to 
Cassandra Query Language <em>
 
 <p>The interface <em>ExecutionResultHandler</em> can be used to custom how an 
execution result should be handle.</p>
 <div class="highlight"><pre><code class="language-java" data-lang="java"><span 
class="kd">public</span> <span class="kd">interface</span> <span 
class="nc">ExecutionResultHandler</span> <span class="kd">extends</span> <span 
class="n">Serializable</span> <span class="o">{</span>
-    <span class="kt">void</span> <span 
class="n">onQueryValidationException</span><span class="o">(</span><span 
class="n">QueryValidationException</span> <span class="n">e</span><span 
class="o">,</span> <span class="n">OutputCollector</span> <span 
class="n">collector</span><span class="o">,</span> <span class="n">Tuple</span> 
<span class="n">tuple</span><span class="o">);</span>
+    <span class="kt">void</span> <span 
class="nf">onQueryValidationException</span><span class="o">(</span><span 
class="n">QueryValidationException</span> <span class="n">e</span><span 
class="o">,</span> <span class="n">OutputCollector</span> <span 
class="n">collector</span><span class="o">,</span> <span class="n">Tuple</span> 
<span class="n">tuple</span><span class="o">);</span>
 
-    <span class="kt">void</span> <span 
class="n">onReadTimeoutException</span><span class="o">(</span><span 
class="n">ReadTimeoutException</span> <span class="n">e</span><span 
class="o">,</span> <span class="n">OutputCollector</span> <span 
class="n">collector</span><span class="o">,</span> <span class="n">Tuple</span> 
<span class="n">tuple</span><span class="o">);</span>
+    <span class="kt">void</span> <span 
class="nf">onReadTimeoutException</span><span class="o">(</span><span 
class="n">ReadTimeoutException</span> <span class="n">e</span><span 
class="o">,</span> <span class="n">OutputCollector</span> <span 
class="n">collector</span><span class="o">,</span> <span class="n">Tuple</span> 
<span class="n">tuple</span><span class="o">);</span>
 
-    <span class="kt">void</span> <span 
class="n">onWriteTimeoutException</span><span class="o">(</span><span 
class="n">WriteTimeoutException</span> <span class="n">e</span><span 
class="o">,</span> <span class="n">OutputCollector</span> <span 
class="n">collector</span><span class="o">,</span> <span class="n">Tuple</span> 
<span class="n">tuple</span><span class="o">);</span>
+    <span class="kt">void</span> <span 
class="nf">onWriteTimeoutException</span><span class="o">(</span><span 
class="n">WriteTimeoutException</span> <span class="n">e</span><span 
class="o">,</span> <span class="n">OutputCollector</span> <span 
class="n">collector</span><span class="o">,</span> <span class="n">Tuple</span> 
<span class="n">tuple</span><span class="o">);</span>
 
-    <span class="kt">void</span> <span 
class="n">onUnavailableException</span><span class="o">(</span><span 
class="n">UnavailableException</span> <span class="n">e</span><span 
class="o">,</span> <span class="n">OutputCollector</span> <span 
class="n">collector</span><span class="o">,</span> <span class="n">Tuple</span> 
<span class="n">tuple</span><span class="o">);</span>
+    <span class="kt">void</span> <span 
class="nf">onUnavailableException</span><span class="o">(</span><span 
class="n">UnavailableException</span> <span class="n">e</span><span 
class="o">,</span> <span class="n">OutputCollector</span> <span 
class="n">collector</span><span class="o">,</span> <span class="n">Tuple</span> 
<span class="n">tuple</span><span class="o">);</span>
 
-    <span class="kt">void</span> <span class="n">onQuerySuccess</span><span 
class="o">(</span><span class="n">OutputCollector</span> <span 
class="n">collector</span><span class="o">,</span> <span class="n">Tuple</span> 
<span class="n">tuple</span><span class="o">);</span>
+    <span class="kt">void</span> <span class="nf">onQuerySuccess</span><span 
class="o">(</span><span class="n">OutputCollector</span> <span 
class="n">collector</span><span class="o">,</span> <span class="n">Tuple</span> 
<span class="n">tuple</span><span class="o">);</span>
 <span class="o">}</span>
 </code></pre></div>
 <p>By default, the CassandraBolt fails a tuple on all Cassandra Exception (see 
<a 
href="https://github.com/apache/storm/tree/master/external/storm-cassandra/blob/master/src/main/java/org/apache/storm/cassandra/BaseExecutionResultHandler.java";>BaseExecutionResultHandler</a>)
 .</p>
-<div class="highlight"><pre><code class="language-java" data-lang="java">    
<span class="k">new</span> <span class="nf">CassandraWriterBolt</span><span 
class="p">(</span><span class="n">insertInto</span><span 
class="o">(</span><span class="s">"album"</span><span class="o">).</span><span 
class="na">values</span><span class="o">(</span><span 
class="n">with</span><span class="o">(</span><span class="n">all</span><span 
class="o">()).</span><span class="na">build</span><span class="o">())</span>
+<div class="highlight"><pre><code class="language-java" data-lang="java">    
<span class="k">new</span> <span class="n">CassandraWriterBolt</span><span 
class="o">(</span><span class="n">insertInto</span><span 
class="o">(</span><span class="s">"album"</span><span class="o">).</span><span 
class="na">values</span><span class="o">(</span><span 
class="n">with</span><span class="o">(</span><span class="n">all</span><span 
class="o">()).</span><span class="na">build</span><span class="o">())</span>
             <span class="o">.</span><span 
class="na">withResultHandler</span><span class="o">(</span><span 
class="k">new</span> <span class="n">MyCustomResultHandler</span><span 
class="o">());</span>
 </code></pre></div>
 <h3 id="declare-output-fields">Declare Output fields</h3>
 
 <p>A CassandraBolt can declare output fields / stream output fields.
 For instance, this may be used to remit a new tuple on error, or to chain 
queries.</p>
-<div class="highlight"><pre><code class="language-java" data-lang="java">    
<span class="k">new</span> <span class="nf">CassandraWriterBolt</span><span 
class="p">(</span><span class="n">insertInto</span><span 
class="o">(</span><span class="s">"album"</span><span class="o">).</span><span 
class="na">values</span><span class="o">(</span><span 
class="n">withFields</span><span class="o">(</span><span 
class="n">all</span><span class="o">()).</span><span 
class="na">build</span><span class="o">())</span>
+<div class="highlight"><pre><code class="language-java" data-lang="java">    
<span class="k">new</span> <span class="n">CassandraWriterBolt</span><span 
class="o">(</span><span class="n">insertInto</span><span 
class="o">(</span><span class="s">"album"</span><span class="o">).</span><span 
class="na">values</span><span class="o">(</span><span 
class="n">withFields</span><span class="o">(</span><span 
class="n">all</span><span class="o">()).</span><span 
class="na">build</span><span class="o">())</span>
             <span class="o">.</span><span 
class="na">withResultHandler</span><span class="o">(</span><span 
class="k">new</span> <span 
class="n">EmitOnDriverExceptionResultHandler</span><span class="o">());</span>
             <span class="o">.</span><span 
class="na">withStreamOutputFields</span><span class="o">(</span><span 
class="s">"stream_error"</span><span class="o">,</span> <span 
class="k">new</span> <span class="n">Fields</span><span class="o">(</span><span 
class="s">"message"</span><span class="o">);</span>
 
     <span class="kd">public</span> <span class="kd">static</span> <span 
class="kd">class</span> <span 
class="nc">EmitOnDriverExceptionResultHandler</span> <span 
class="kd">extends</span> <span class="n">BaseExecutionResultHandler</span> 
<span class="o">{</span>
         <span class="nd">@Override</span>
-        <span class="kd">protected</span> <span class="kt">void</span> <span 
class="n">onDriverException</span><span class="o">(</span><span 
class="n">DriverException</span> <span class="n">e</span><span 
class="o">,</span> <span class="n">OutputCollector</span> <span 
class="n">collector</span><span class="o">,</span> <span class="n">Tuple</span> 
<span class="n">tuple</span><span class="o">)</span> <span class="o">{</span>
+        <span class="kd">protected</span> <span class="kt">void</span> <span 
class="nf">onDriverException</span><span class="o">(</span><span 
class="n">DriverException</span> <span class="n">e</span><span 
class="o">,</span> <span class="n">OutputCollector</span> <span 
class="n">collector</span><span class="o">,</span> <span class="n">Tuple</span> 
<span class="n">tuple</span><span class="o">)</span> <span class="o">{</span>
             <span class="n">LOG</span><span class="o">.</span><span 
class="na">error</span><span class="o">(</span><span class="s">"An error 
occurred while executing cassandra statement"</span><span class="o">,</span> 
<span class="n">e</span><span class="o">);</span>
             <span class="n">collector</span><span class="o">.</span><span 
class="na">emit</span><span class="o">(</span><span 
class="s">"stream_error"</span><span class="o">,</span> <span 
class="k">new</span> <span class="n">Values</span><span class="o">(</span><span 
class="n">e</span><span class="o">.</span><span 
class="na">getMessage</span><span class="o">()));</span>
             <span class="n">collector</span><span class="o">.</span><span 
class="na">ack</span><span class="o">(</span><span class="n">tuple</span><span 
class="o">);</span>

http://git-wip-us.apache.org/repos/asf/storm-site/blob/a7a19afb/content/releases/1.0.4/storm-elasticsearch.html
----------------------------------------------------------------------
diff --git a/content/releases/1.0.4/storm-elasticsearch.html 
b/content/releases/1.0.4/storm-elasticsearch.html
index 4aa10a3..83a2f9a 100644
--- a/content/releases/1.0.4/storm-elasticsearch.html
+++ b/content/releases/1.0.4/storm-elasticsearch.html
@@ -82,18 +82,16 @@
                         
                       
                         
-                          <li><a 
href="/releases/1.1.0/index.html">1.1.0</a></li>
-                        
                       
                         
+                          <li><a 
href="/releases/1.1.0/index.html">1.1.0</a></li>
+                        
                       
                         
                           <li><a 
href="/releases/1.0.4/index.html">1.0.4</a></li>
                         
                       
                         
-                      
-                        
                           <li><a 
href="/releases/1.0.3/index.html">1.0.3</a></li>
                         
                       
@@ -104,6 +102,8 @@
                         
                       
                         
+                      
+                        
                           <li><a 
href="/releases/0.10.2/index.html">0.10.2</a></li>
                         
                       
@@ -144,7 +144,7 @@
                         <li><a href="/contribute/BYLAWS.html">ByLaws</a></li>
                     </ul>
                 </li>
-                <li><a href="/2017/09/15/storm105-released.html" 
id="news">News</a></li>
+                <li><a href="/2018/02/14/storm106-released.html" 
id="news">News</a></li>
             </ul>
         </nav>
     </div>
@@ -160,7 +160,7 @@
 
 <p class="post-meta"></p>
 
-<h1 id="storm-elasticsearch-bolt-amp-trident-state">Storm Elasticsearch Bolt 
&amp; Trident State</h1>
+<h1 id="storm-elasticsearch-bolt-trident-state">Storm Elasticsearch Bolt &amp; 
Trident State</h1>
 
 <p>EsIndexBolt, EsPercolateBolt and EsState allows users to stream data from 
storm into Elasticsearch directly.
   For detailed description, please refer to the following.</p>

http://git-wip-us.apache.org/repos/asf/storm-site/blob/a7a19afb/content/releases/1.0.4/storm-eventhubs.html
----------------------------------------------------------------------
diff --git a/content/releases/1.0.4/storm-eventhubs.html 
b/content/releases/1.0.4/storm-eventhubs.html
index 3ff0eab..9ebb45b 100644
--- a/content/releases/1.0.4/storm-eventhubs.html
+++ b/content/releases/1.0.4/storm-eventhubs.html
@@ -82,18 +82,16 @@
                         
                       
                         
-                          <li><a 
href="/releases/1.1.0/index.html">1.1.0</a></li>
-                        
                       
                         
+                          <li><a 
href="/releases/1.1.0/index.html">1.1.0</a></li>
+                        
                       
                         
                           <li><a 
href="/releases/1.0.4/index.html">1.0.4</a></li>
                         
                       
                         
-                      
-                        
                           <li><a 
href="/releases/1.0.3/index.html">1.0.3</a></li>
                         
                       
@@ -104,6 +102,8 @@
                         
                       
                         
+                      
+                        
                           <li><a 
href="/releases/0.10.2/index.html">0.10.2</a></li>
                         
                       
@@ -144,7 +144,7 @@
                         <li><a href="/contribute/BYLAWS.html">ByLaws</a></li>
                     </ul>
                 </li>
-                <li><a href="/2017/09/15/storm105-released.html" 
id="news">News</a></li>
+                <li><a href="/2018/02/14/storm106-released.html" 
id="news">News</a></li>
             </ul>
         </nav>
     </div>

http://git-wip-us.apache.org/repos/asf/storm-site/blob/a7a19afb/content/releases/1.0.4/storm-hbase.html
----------------------------------------------------------------------
diff --git a/content/releases/1.0.4/storm-hbase.html 
b/content/releases/1.0.4/storm-hbase.html
index 1b6db9e..3394ab0 100644
--- a/content/releases/1.0.4/storm-hbase.html
+++ b/content/releases/1.0.4/storm-hbase.html
@@ -82,18 +82,16 @@
                         
                       
                         
-                          <li><a 
href="/releases/1.1.0/index.html">1.1.0</a></li>
-                        
                       
                         
+                          <li><a 
href="/releases/1.1.0/index.html">1.1.0</a></li>
+                        
                       
                         
                           <li><a 
href="/releases/1.0.4/index.html">1.0.4</a></li>
                         
                       
                         
-                      
-                        
                           <li><a 
href="/releases/1.0.3/index.html">1.0.3</a></li>
                         
                       
@@ -104,6 +102,8 @@
                         
                       
                         
+                      
+                        
                           <li><a 
href="/releases/0.10.2/index.html">0.10.2</a></li>
                         
                       
@@ -144,7 +144,7 @@
                         <li><a href="/contribute/BYLAWS.html">ByLaws</a></li>
                     </ul>
                 </li>
-                <li><a href="/2017/09/15/storm105-released.html" 
id="news">News</a></li>
+                <li><a href="/2018/02/14/storm106-released.html" 
id="news">News</a></li>
             </ul>
         </nav>
     </div>
@@ -167,9 +167,9 @@
 <p>The main API for interacting with HBase is the 
<code>org.apache.storm.hbase.bolt.mapper.HBaseMapper</code>
 interface:</p>
 <div class="highlight"><pre><code class="language-java" data-lang="java"><span 
class="kd">public</span> <span class="kd">interface</span> <span 
class="nc">HBaseMapper</span> <span class="kd">extends</span> <span 
class="n">Serializable</span> <span class="o">{</span>
-    <span class="kt">byte</span><span class="o">[]</span> <span 
class="n">rowKey</span><span class="o">(</span><span class="n">Tuple</span> 
<span class="n">tuple</span><span class="o">);</span>
+    <span class="kt">byte</span><span class="o">[]</span> <span 
class="nf">rowKey</span><span class="o">(</span><span class="n">Tuple</span> 
<span class="n">tuple</span><span class="o">);</span>
 
-    <span class="n">ColumnList</span> <span class="n">columns</span><span 
class="o">(</span><span class="n">Tuple</span> <span 
class="n">tuple</span><span class="o">);</span>
+    <span class="n">ColumnList</span> <span class="nf">columns</span><span 
class="o">(</span><span class="n">Tuple</span> <span 
class="n">tuple</span><span class="o">);</span>
 <span class="o">}</span>
 </code></pre></div>
 <p>The <code>rowKey()</code> method is straightforward: given a Storm tuple, 
return a byte array representing the
@@ -263,8 +263,8 @@ tuples to both regular HBase columns as well as counter 
columns.</p>
 
 <p>This class allows you to transform the HBase lookup result into storm 
Values that will be emitted by the <code>HBaseLookupBolt</code>.</p>
 <div class="highlight"><pre><code class="language-java" data-lang="java"><span 
class="kd">public</span> <span class="kd">interface</span> <span 
class="nc">HBaseValueMapper</span> <span class="kd">extends</span> <span 
class="n">Serializable</span> <span class="o">{</span>
-    <span class="kd">public</span> <span class="n">List</span><span 
class="o">&lt;</span><span class="n">Values</span><span class="o">&gt;</span> 
<span class="n">toTuples</span><span class="o">(</span><span 
class="n">Result</span> <span class="n">result</span><span class="o">)</span> 
<span class="kd">throws</span> <span class="n">Exception</span><span 
class="o">;</span>
-    <span class="kt">void</span> <span 
class="n">declareOutputFields</span><span class="o">(</span><span 
class="n">OutputFieldsDeclarer</span> <span class="n">declarer</span><span 
class="o">);</span>
+    <span class="kd">public</span> <span class="n">List</span><span 
class="o">&lt;</span><span class="n">Values</span><span class="o">&gt;</span> 
<span class="nf">toTuples</span><span class="o">(</span><span 
class="n">Result</span> <span class="n">result</span><span class="o">)</span> 
<span class="kd">throws</span> <span class="n">Exception</span><span 
class="o">;</span>
+    <span class="kt">void</span> <span 
class="nf">declareOutputFields</span><span class="o">(</span><span 
class="n">OutputFieldsDeclarer</span> <span class="n">declarer</span><span 
class="o">);</span>
 <span class="o">}</span>
 </code></pre></div>
 <p>The <code>toTuples</code> method takes in a HBase <code>Result</code> 
instance and expects a List of <code>Values</code> instant. 
@@ -279,8 +279,8 @@ Each of the value returned by this function will be emitted 
by the <code>HBaseLo
 <p>This class allows you to specify the projection criteria for your HBase Get 
function. This is optional parameter
 for the lookupBolt and if you do not specify this instance all the columns 
will be returned by <code>HBaseLookupBolt</code>.</p>
 <div class="highlight"><pre><code class="language-java" data-lang="java"><span 
class="kd">public</span> <span class="kd">class</span> <span 
class="nc">HBaseProjectionCriteria</span> <span class="kd">implements</span> 
<span class="n">Serializable</span> <span class="o">{</span>
-    <span class="kd">public</span> <span 
class="n">HBaseProjectionCriteria</span> <span 
class="n">addColumnFamily</span><span class="o">(</span><span 
class="n">String</span> <span class="n">columnFamily</span><span 
class="o">);</span>
-    <span class="kd">public</span> <span 
class="n">HBaseProjectionCriteria</span> <span class="n">addColumn</span><span 
class="o">(</span><span class="n">ColumnMetaData</span> <span 
class="n">column</span><span class="o">);</span>
+    <span class="kd">public</span> <span 
class="n">HBaseProjectionCriteria</span> <span 
class="nf">addColumnFamily</span><span class="o">(</span><span 
class="n">String</span> <span class="n">columnFamily</span><span 
class="o">);</span>
+    <span class="kd">public</span> <span 
class="n">HBaseProjectionCriteria</span> <span class="nf">addColumn</span><span 
class="o">(</span><span class="n">ColumnMetaData</span> <span 
class="n">column</span><span class="o">);</span>
 </code></pre></div>
 <p><code>addColumnFamily</code> takes in columnFamily. Setting this parameter 
means all columns for this family will be included
  in the projection.</p>
@@ -339,7 +339,7 @@ Word: 'watermelon', Count: 6806
     <span class="kd">private</span> <span class="kd">static</span> <span 
class="kd">final</span> <span class="n">String</span> <span 
class="n">HBASE_BOLT</span> <span class="o">=</span> <span 
class="s">"HBASE_BOLT"</span><span class="o">;</span>
 
 
-    <span class="kd">public</span> <span class="kd">static</span> <span 
class="kt">void</span> <span class="n">main</span><span class="o">(</span><span 
class="n">String</span><span class="o">[]</span> <span 
class="n">args</span><span class="o">)</span> <span class="kd">throws</span> 
<span class="n">Exception</span> <span class="o">{</span>
+    <span class="kd">public</span> <span class="kd">static</span> <span 
class="kt">void</span> <span class="nf">main</span><span 
class="o">(</span><span class="n">String</span><span class="o">[]</span> <span 
class="n">args</span><span class="o">)</span> <span class="kd">throws</span> 
<span class="n">Exception</span> <span class="o">{</span>
         <span class="n">Config</span> <span class="n">config</span> <span 
class="o">=</span> <span class="k">new</span> <span 
class="n">Config</span><span class="o">();</span>
 
         <span class="n">WordSpout</span> <span class="n">spout</span> <span 
class="o">=</span> <span class="k">new</span> <span 
class="n">WordSpout</span><span class="o">();</span>

http://git-wip-us.apache.org/repos/asf/storm-site/blob/a7a19afb/content/releases/1.0.4/storm-hdfs.html
----------------------------------------------------------------------
diff --git a/content/releases/1.0.4/storm-hdfs.html 
b/content/releases/1.0.4/storm-hdfs.html
index 4892453..d56c1a2 100644
--- a/content/releases/1.0.4/storm-hdfs.html
+++ b/content/releases/1.0.4/storm-hdfs.html
@@ -82,18 +82,16 @@
                         
                       
                         
-                          <li><a 
href="/releases/1.1.0/index.html">1.1.0</a></li>
-                        
                       
                         
+                          <li><a 
href="/releases/1.1.0/index.html">1.1.0</a></li>
+                        
                       
                         
                           <li><a 
href="/releases/1.0.4/index.html">1.0.4</a></li>
                         
                       
                         
-                      
-                        
                           <li><a 
href="/releases/1.0.3/index.html">1.0.3</a></li>
                         
                       
@@ -104,6 +102,8 @@
                         
                       
                         
+                      
+                        
                           <li><a 
href="/releases/0.10.2/index.html">0.10.2</a></li>
                         
                       
@@ -144,7 +144,7 @@
                         <li><a href="/contribute/BYLAWS.html">ByLaws</a></li>
                     </ul>
                 </li>
-                <li><a href="/2017/09/15/storm105-released.html" 
id="news">News</a></li>
+                <li><a href="/2018/02/14/storm106-released.html" 
id="news">News</a></li>
             </ul>
         </nav>
     </div>
@@ -269,7 +269,7 @@ and add the dependencies for your preferred version in your 
pom.</p>
 <p>Record format can be controlled by providing an implementation of the 
<code>org.apache.storm.hdfs.format.RecordFormat</code>
 interface:</p>
 <div class="highlight"><pre><code class="language-java" data-lang="java"><span 
class="kd">public</span> <span class="kd">interface</span> <span 
class="nc">RecordFormat</span> <span class="kd">extends</span> <span 
class="n">Serializable</span> <span class="o">{</span>
-    <span class="kt">byte</span><span class="o">[]</span> <span 
class="n">format</span><span class="o">(</span><span class="n">Tuple</span> 
<span class="n">tuple</span><span class="o">);</span>
+    <span class="kt">byte</span><span class="o">[]</span> <span 
class="nf">format</span><span class="o">(</span><span class="n">Tuple</span> 
<span class="n">tuple</span><span class="o">);</span>
 <span class="o">}</span>
 </code></pre></div>
 <p>The provided 
<code>org.apache.storm.hdfs.format.DelimitedRecordFormat</code> is capable of 
producing formats such as CSV and
@@ -280,14 +280,14 @@ tab-delimited files.</p>
 <p>File naming can be controlled by providing an implementation of the 
<code>org.apache.storm.hdfs.format.FileNameFormat</code>
 interface:</p>
 <div class="highlight"><pre><code class="language-java" data-lang="java"><span 
class="kd">public</span> <span class="kd">interface</span> <span 
class="nc">FileNameFormat</span> <span class="kd">extends</span> <span 
class="n">Serializable</span> <span class="o">{</span>
-    <span class="kt">void</span> <span class="n">prepare</span><span 
class="o">(</span><span class="n">Map</span> <span class="n">conf</span><span 
class="o">,</span> <span class="n">TopologyContext</span> <span 
class="n">topologyContext</span><span class="o">);</span>
-    <span class="n">String</span> <span class="n">getName</span><span 
class="o">(</span><span class="kt">long</span> <span 
class="n">rotation</span><span class="o">,</span> <span class="kt">long</span> 
<span class="n">timeStamp</span><span class="o">);</span>
-    <span class="n">String</span> <span class="n">getPath</span><span 
class="o">();</span>
+    <span class="kt">void</span> <span class="nf">prepare</span><span 
class="o">(</span><span class="n">Map</span> <span class="n">conf</span><span 
class="o">,</span> <span class="n">TopologyContext</span> <span 
class="n">topologyContext</span><span class="o">);</span>
+    <span class="n">String</span> <span class="nf">getName</span><span 
class="o">(</span><span class="kt">long</span> <span 
class="n">rotation</span><span class="o">,</span> <span class="kt">long</span> 
<span class="n">timeStamp</span><span class="o">);</span>
+    <span class="n">String</span> <span class="nf">getPath</span><span 
class="o">();</span>
 <span class="o">}</span>
 </code></pre></div>
 <p>The provided 
<code>org.apache.storm.hdfs.format.DefaultFileNameFormat</code>  will create 
file names with the following format:</p>
-<div class="highlight"><pre><code class="language-" data-lang=""><span 
class="w"> </span><span class="p">{</span><span class="err">prefix</span><span 
class="p">}{</span><span class="err">componentId</span><span 
class="p">}</span><span class="err">-</span><span class="p">{</span><span 
class="err">taskId</span><span class="p">}</span><span 
class="err">-</span><span class="p">{</span><span 
class="err">rotationNum</span><span class="p">}</span><span 
class="err">-</span><span class="p">{</span><span 
class="err">timestamp</span><span class="p">}{</span><span 
class="err">extension</span><span class="p">}</span><span class="w">
-</span></code></pre></div>
+<div class="highlight"><pre><code class="language-" data-lang=""> 
{prefix}{componentId}-{taskId}-{rotationNum}-{timestamp}{extension}
+</code></pre></div>
 <p>For example:</p>
 <div class="highlight"><pre><code class="language-" data-lang=""> 
MyBolt-5-7-1390579837830.txt
 </code></pre></div>
@@ -298,8 +298,8 @@ interface:</p>
 <p>Sync policies allow you to control when buffered data is flushed to the 
underlying filesystem (thus making it available
 to clients reading the data) by implementing the 
<code>org.apache.storm.hdfs.sync.SyncPolicy</code> interface:</p>
 <div class="highlight"><pre><code class="language-java" data-lang="java"><span 
class="kd">public</span> <span class="kd">interface</span> <span 
class="nc">SyncPolicy</span> <span class="kd">extends</span> <span 
class="n">Serializable</span> <span class="o">{</span>
-    <span class="kt">boolean</span> <span class="n">mark</span><span 
class="o">(</span><span class="n">Tuple</span> <span 
class="n">tuple</span><span class="o">,</span> <span class="kt">long</span> 
<span class="n">offset</span><span class="o">);</span>
-    <span class="kt">void</span> <span class="n">reset</span><span 
class="o">();</span>
+    <span class="kt">boolean</span> <span class="nf">mark</span><span 
class="o">(</span><span class="n">Tuple</span> <span 
class="n">tuple</span><span class="o">,</span> <span class="kt">long</span> 
<span class="n">offset</span><span class="o">);</span>
+    <span class="kt">void</span> <span class="nf">reset</span><span 
class="o">();</span>
 <span class="o">}</span>
 </code></pre></div>
 <p>The <code>HdfsBolt</code> will call the <code>mark()</code> method for 
every tuple it processes. Returning <code>true</code> will trigger the 
<code>HdfsBolt</code>
@@ -313,8 +313,8 @@ been processed.</p>
 <p>Similar to sync policies, file rotation policies allow you to control when 
data files are rotated by providing a
 <code>org.apache.storm.hdfs.rotation.FileRotation</code> interface:</p>
 <div class="highlight"><pre><code class="language-java" data-lang="java"><span 
class="kd">public</span> <span class="kd">interface</span> <span 
class="nc">FileRotationPolicy</span> <span class="kd">extends</span> <span 
class="n">Serializable</span> <span class="o">{</span>
-    <span class="kt">boolean</span> <span class="n">mark</span><span 
class="o">(</span><span class="n">Tuple</span> <span 
class="n">tuple</span><span class="o">,</span> <span class="kt">long</span> 
<span class="n">offset</span><span class="o">);</span>
-    <span class="kt">void</span> <span class="n">reset</span><span 
class="o">();</span>
+    <span class="kt">boolean</span> <span class="nf">mark</span><span 
class="o">(</span><span class="n">Tuple</span> <span 
class="n">tuple</span><span class="o">,</span> <span class="kt">long</span> 
<span class="n">offset</span><span class="o">);</span>
+    <span class="kt">void</span> <span class="nf">reset</span><span 
class="o">();</span>
 <span class="o">}</span>
 </code></pre></div>
 <p>The <code>org.apache.storm.hdfs.rotation.FileSizeRotationPolicy</code> 
implementation allows you to trigger file rotation when
@@ -327,7 +327,7 @@ data files reach a specific file size:</p>
 What <code>RotationAction</code>s do is provide a hook to allow you to perform 
some action right after a file is rotated. For
 example, moving a file to a different location or renaming it.</p>
 <div class="highlight"><pre><code class="language-java" data-lang="java"><span 
class="kd">public</span> <span class="kd">interface</span> <span 
class="nc">RotationAction</span> <span class="kd">extends</span> <span 
class="n">Serializable</span> <span class="o">{</span>
-    <span class="kt">void</span> <span class="n">execute</span><span 
class="o">(</span><span class="n">FileSystem</span> <span 
class="n">fileSystem</span><span class="o">,</span> <span class="n">Path</span> 
<span class="n">filePath</span><span class="o">)</span> <span 
class="kd">throws</span> <span class="n">IOException</span><span 
class="o">;</span>
+    <span class="kt">void</span> <span class="nf">execute</span><span 
class="o">(</span><span class="n">FileSystem</span> <span 
class="n">fileSystem</span><span class="o">,</span> <span class="n">Path</span> 
<span class="n">filePath</span><span class="o">)</span> <span 
class="kd">throws</span> <span class="n">IOException</span><span 
class="o">;</span>
 <span class="o">}</span>
 </code></pre></div>
 <p>Storm-HDFS includes a simple action that will move a file after 
rotation:</p>
@@ -336,13 +336,13 @@ example, moving a file to a different location or 
renaming it.</p>
 
     <span class="kd">private</span> <span class="n">String</span> <span 
class="n">destination</span><span class="o">;</span>
 
-    <span class="kd">public</span> <span class="n">MoveFileAction</span> <span 
class="n">withDestination</span><span class="o">(</span><span 
class="n">String</span> <span class="n">destDir</span><span class="o">){</span>
+    <span class="kd">public</span> <span class="n">MoveFileAction</span> <span 
class="nf">withDestination</span><span class="o">(</span><span 
class="n">String</span> <span class="n">destDir</span><span class="o">){</span>
         <span class="n">destination</span> <span class="o">=</span> <span 
class="n">destDir</span><span class="o">;</span>
         <span class="k">return</span> <span class="k">this</span><span 
class="o">;</span>
     <span class="o">}</span>
 
     <span class="nd">@Override</span>
-    <span class="kd">public</span> <span class="kt">void</span> <span 
class="n">execute</span><span class="o">(</span><span 
class="n">FileSystem</span> <span class="n">fileSystem</span><span 
class="o">,</span> <span class="n">Path</span> <span 
class="n">filePath</span><span class="o">)</span> <span 
class="kd">throws</span> <span class="n">IOException</span> <span 
class="o">{</span>
+    <span class="kd">public</span> <span class="kt">void</span> <span 
class="nf">execute</span><span class="o">(</span><span 
class="n">FileSystem</span> <span class="n">fileSystem</span><span 
class="o">,</span> <span class="n">Path</span> <span 
class="n">filePath</span><span class="o">)</span> <span 
class="kd">throws</span> <span class="n">IOException</span> <span 
class="o">{</span>
         <span class="n">Path</span> <span class="n">destPath</span> <span 
class="o">=</span> <span class="k">new</span> <span class="n">Path</span><span 
class="o">(</span><span class="n">destination</span><span class="o">,</span> 
<span class="n">filePath</span><span class="o">.</span><span 
class="na">getName</span><span class="o">());</span>
         <span class="n">LOG</span><span class="o">.</span><span 
class="na">info</span><span class="o">(</span><span class="s">"Moving file {} 
to {}"</span><span class="o">,</span> <span class="n">filePath</span><span 
class="o">,</span> <span class="n">destPath</span><span class="o">);</span>
         <span class="kt">boolean</span> <span class="n">success</span> <span 
class="o">=</span> <span class="n">fileSystem</span><span 
class="o">.</span><span class="na">rename</span><span class="o">(</span><span 
class="n">filePath</span><span class="o">,</span> <span 
class="n">destPath</span><span class="o">);</span>
@@ -386,11 +386,11 @@ example, moving a file to a different location or 
renaming it.</p>
 <p>The <code>SequenceFileBolt</code> requires that you provide a 
<code>org.apache.storm.hdfs.bolt.format.SequenceFormat</code> that maps tuples 
to
 key/value pairs:</p>
 <div class="highlight"><pre><code class="language-java" data-lang="java"><span 
class="kd">public</span> <span class="kd">interface</span> <span 
class="nc">SequenceFormat</span> <span class="kd">extends</span> <span 
class="n">Serializable</span> <span class="o">{</span>
-    <span class="n">Class</span> <span class="n">keyClass</span><span 
class="o">();</span>
-    <span class="n">Class</span> <span class="n">valueClass</span><span 
class="o">();</span>
+    <span class="n">Class</span> <span class="nf">keyClass</span><span 
class="o">();</span>
+    <span class="n">Class</span> <span class="nf">valueClass</span><span 
class="o">();</span>
 
-    <span class="n">Writable</span> <span class="n">key</span><span 
class="o">(</span><span class="n">Tuple</span> <span 
class="n">tuple</span><span class="o">);</span>
-    <span class="n">Writable</span> <span class="n">value</span><span 
class="o">(</span><span class="n">Tuple</span> <span 
class="n">tuple</span><span class="o">);</span>
+    <span class="n">Writable</span> <span class="nf">key</span><span 
class="o">(</span><span class="n">Tuple</span> <span 
class="n">tuple</span><span class="o">);</span>
+    <span class="n">Writable</span> <span class="nf">value</span><span 
class="o">(</span><span class="n">Tuple</span> <span 
class="n">tuple</span><span class="o">);</span>
 <span class="o">}</span>
 </code></pre></div>
 <h2 id="trident-api">Trident API</h2>

http://git-wip-us.apache.org/repos/asf/storm-site/blob/a7a19afb/content/releases/1.0.4/storm-hive.html
----------------------------------------------------------------------
diff --git a/content/releases/1.0.4/storm-hive.html 
b/content/releases/1.0.4/storm-hive.html
index 8e35b05..83864d2 100644
--- a/content/releases/1.0.4/storm-hive.html
+++ b/content/releases/1.0.4/storm-hive.html
@@ -82,18 +82,16 @@
                         
                       
                         
-                          <li><a 
href="/releases/1.1.0/index.html">1.1.0</a></li>
-                        
                       
                         
+                          <li><a 
href="/releases/1.1.0/index.html">1.1.0</a></li>
+                        
                       
                         
                           <li><a 
href="/releases/1.0.4/index.html">1.0.4</a></li>
                         
                       
                         
-                      
-                        
                           <li><a 
href="/releases/1.0.3/index.html">1.0.3</a></li>
                         
                       
@@ -104,6 +102,8 @@
                         
                       
                         
+                      
+                        
                           <li><a 
href="/releases/0.10.2/index.html">0.10.2</a></li>
                         
                       
@@ -144,7 +144,7 @@
                         <li><a href="/contribute/BYLAWS.html">ByLaws</a></li>
                     </ul>
                 </li>
-                <li><a href="/2017/09/15/storm105-released.html" 
id="news">News</a></li>
+                <li><a href="/2018/02/14/storm106-released.html" 
id="news">News</a></li>
             </ul>
         </nav>
     </div>

http://git-wip-us.apache.org/repos/asf/storm-site/blob/a7a19afb/content/releases/1.0.4/storm-jdbc.html
----------------------------------------------------------------------
diff --git a/content/releases/1.0.4/storm-jdbc.html 
b/content/releases/1.0.4/storm-jdbc.html
index 3dce5e8..32a4373 100644
--- a/content/releases/1.0.4/storm-jdbc.html
+++ b/content/releases/1.0.4/storm-jdbc.html
@@ -82,18 +82,16 @@
                         
                       
                         
-                          <li><a 
href="/releases/1.1.0/index.html">1.1.0</a></li>
-                        
                       
                         
+                          <li><a 
href="/releases/1.1.0/index.html">1.1.0</a></li>
+                        
                       
                         
                           <li><a 
href="/releases/1.0.4/index.html">1.0.4</a></li>
                         
                       
                         
-                      
-                        
                           <li><a 
href="/releases/1.0.3/index.html">1.0.3</a></li>
                         
                       
@@ -104,6 +102,8 @@
                         
                       
                         
+                      
+                        
                           <li><a 
href="/releases/0.10.2/index.html">0.10.2</a></li>
                         
                       
@@ -144,7 +144,7 @@
                         <li><a href="/contribute/BYLAWS.html">ByLaws</a></li>
                     </ul>
                 </li>
-                <li><a href="/2017/09/15/storm105-released.html" 
id="news">News</a></li>
+                <li><a href="/2018/02/14/storm106-released.html" 
id="news">News</a></li>
             </ul>
         </nav>
     </div>
@@ -177,18 +177,18 @@ in a storm topology.</p>
     <span class="cm">/**
      * method must be idempotent.
      */</span>
-    <span class="kt">void</span> <span class="n">prepare</span><span 
class="o">();</span>
+    <span class="kt">void</span> <span class="nf">prepare</span><span 
class="o">();</span>
 
     <span class="cm">/**
      *
      * @return a DB connection over which the queries can be executed.
      */</span>
-    <span class="n">Connection</span> <span 
class="n">getConnection</span><span class="o">();</span>
+    <span class="n">Connection</span> <span 
class="nf">getConnection</span><span class="o">();</span>
 
     <span class="cm">/**
      * called once when the system is shutting down, should be idempotent.
      */</span>
-    <span class="kt">void</span> <span class="n">cleanup</span><span 
class="o">();</span>
+    <span class="kt">void</span> <span class="nf">cleanup</span><span 
class="o">();</span>
 <span class="o">}</span>
 </code></pre></div>
 <p>Out of the box we support 
<code>org.apache.storm.jdbc.common.HikariCPConnectionProvider</code> which is 
an implementation that uses HikariCP.</p>
@@ -197,7 +197,7 @@ in a storm topology.</p>
 
 <p>The main API for inserting data in a table using JDBC is the 
<code>org.apache.storm.jdbc.mapper.JdbcMapper</code> interface:</p>
 <div class="highlight"><pre><code class="language-java" data-lang="java"><span 
class="kd">public</span> <span class="kd">interface</span> <span 
class="nc">JdbcMapper</span>  <span class="kd">extends</span> <span 
class="n">Serializable</span> <span class="o">{</span>
-    <span class="n">List</span><span class="o">&lt;</span><span 
class="n">Column</span><span class="o">&gt;</span> <span 
class="n">getColumns</span><span class="o">(</span><span 
class="n">ITuple</span> <span class="n">tuple</span><span class="o">);</span>
+    <span class="n">List</span><span class="o">&lt;</span><span 
class="n">Column</span><span class="o">&gt;</span> <span 
class="nf">getColumns</span><span class="o">(</span><span 
class="n">ITuple</span> <span class="n">tuple</span><span class="o">);</span>
 <span class="o">}</span>
 </code></pre></div>
 <p>The <code>getColumns()</code> method defines how a storm tuple maps to a 
list of columns representing a row in a database. 
@@ -276,9 +276,9 @@ JdbcMapper simpleJdbcMapper = new 
SimpleJdbcMapper(columnSchema);
 In this table the create_time column has a default value. To ensure only the 
columns with no default values are inserted 
 you can initialize the <code>jdbcMapper</code> as below:</p>
 <div class="highlight"><pre><code class="language-java" data-lang="java"><span 
class="n">List</span><span class="o">&lt;</span><span 
class="n">Column</span><span class="o">&gt;</span> <span 
class="n">columnSchema</span> <span class="o">=</span> <span 
class="n">Lists</span><span class="o">.</span><span 
class="na">newArrayList</span><span class="o">(</span>
-    <span class="k">new</span> <span class="n">Column</span><span 
class="o">(</span><span class="s">"user_id"</span><span class="o">,</span> 
<span class="n">java</span><span class="o">.</span><span 
class="na">sql</span><span class="o">.</span><span class="na">Types</span><span 
class="o">.</span><span class="na">INTEGER</span><span class="o">),</span>
-    <span class="k">new</span> <span class="n">Column</span><span 
class="o">(</span><span class="s">"user_name"</span><span class="o">,</span> 
<span class="n">java</span><span class="o">.</span><span 
class="na">sql</span><span class="o">.</span><span class="na">Types</span><span 
class="o">.</span><span class="na">VARCHAR</span><span class="o">),</span>
-    <span class="k">new</span> <span class="n">Column</span><span 
class="o">(</span><span class="s">"dept_name"</span><span class="o">,</span> 
<span class="n">java</span><span class="o">.</span><span 
class="na">sql</span><span class="o">.</span><span class="na">Types</span><span 
class="o">.</span><span class="na">VARCHAR</span><span class="o">));</span>
+    <span class="k">new</span> <span class="nf">Column</span><span 
class="o">(</span><span class="s">"user_id"</span><span class="o">,</span> 
<span class="n">java</span><span class="o">.</span><span 
class="na">sql</span><span class="o">.</span><span class="na">Types</span><span 
class="o">.</span><span class="na">INTEGER</span><span class="o">),</span>
+    <span class="k">new</span> <span class="nf">Column</span><span 
class="o">(</span><span class="s">"user_name"</span><span class="o">,</span> 
<span class="n">java</span><span class="o">.</span><span 
class="na">sql</span><span class="o">.</span><span class="na">Types</span><span 
class="o">.</span><span class="na">VARCHAR</span><span class="o">),</span>
+    <span class="k">new</span> <span class="nf">Column</span><span 
class="o">(</span><span class="s">"dept_name"</span><span class="o">,</span> 
<span class="n">java</span><span class="o">.</span><span 
class="na">sql</span><span class="o">.</span><span class="na">Types</span><span 
class="o">.</span><span class="na">VARCHAR</span><span class="o">));</span>
 <span class="n">JdbcMapper</span> <span class="n">simpleJdbcMapper</span> 
<span class="o">=</span> <span class="k">new</span> <span 
class="n">SimpleJdbcMapper</span><span class="o">(</span><span 
class="n">columnSchema</span><span class="o">);</span>
 </code></pre></div>
 <h3 id="jdbctridentstate">JdbcTridentState</h3>
@@ -299,9 +299,9 @@ See the example below:</p>
 
 <p>We support <code>select</code> queries from databases to allow enrichment 
of storm tuples in a topology. The main API for 
 executing select queries against a database using JDBC is the 
<code>org.apache.storm.jdbc.mapper.JdbcLookupMapper</code> interface:</p>
-<div class="highlight"><pre><code class="language-java" data-lang="java">    
<span class="kt">void</span> <span class="nf">declareOutputFields</span><span 
class="p">(</span><span class="n">OutputFieldsDeclarer</span> <span 
class="n">declarer</span><span class="o">);</span>
-    <span class="n">List</span><span class="o">&lt;</span><span 
class="n">Column</span><span class="o">&gt;</span> <span 
class="n">getColumns</span><span class="o">(</span><span 
class="n">ITuple</span> <span class="n">tuple</span><span class="o">);</span>
-    <span class="n">List</span><span class="o">&lt;</span><span 
class="n">Values</span><span class="o">&gt;</span> <span 
class="n">toTuple</span><span class="o">(</span><span class="n">ITuple</span> 
<span class="n">input</span><span class="o">,</span> <span 
class="n">List</span><span class="o">&lt;</span><span 
class="n">Column</span><span class="o">&gt;</span> <span 
class="n">columns</span><span class="o">);</span>
+<div class="highlight"><pre><code class="language-java" data-lang="java">    
<span class="kt">void</span> <span class="nf">declareOutputFields</span><span 
class="o">(</span><span class="n">OutputFieldsDeclarer</span> <span 
class="n">declarer</span><span class="o">);</span>
+    <span class="n">List</span><span class="o">&lt;</span><span 
class="n">Column</span><span class="o">&gt;</span> <span 
class="nf">getColumns</span><span class="o">(</span><span 
class="n">ITuple</span> <span class="n">tuple</span><span class="o">);</span>
+    <span class="n">List</span><span class="o">&lt;</span><span 
class="n">Values</span><span class="o">&gt;</span> <span 
class="nf">toTuple</span><span class="o">(</span><span class="n">ITuple</span> 
<span class="n">input</span><span class="o">,</span> <span 
class="n">List</span><span class="o">&lt;</span><span 
class="n">Column</span><span class="o">&gt;</span> <span 
class="n">columns</span><span class="o">);</span>
 </code></pre></div>
 <p>The <code>declareOutputFields</code> method is used to indicate what fields 
will be emitted as part of output tuple of processing a storm 
 tuple. </p>

http://git-wip-us.apache.org/repos/asf/storm-site/blob/a7a19afb/content/releases/1.0.4/storm-jms-example.html
----------------------------------------------------------------------
diff --git a/content/releases/1.0.4/storm-jms-example.html 
b/content/releases/1.0.4/storm-jms-example.html
index c33f4d2..7632933 100644
--- a/content/releases/1.0.4/storm-jms-example.html
+++ b/content/releases/1.0.4/storm-jms-example.html
@@ -82,18 +82,16 @@
                         
                       
                         
-                          <li><a 
href="/releases/1.1.0/index.html">1.1.0</a></li>
-                        
                       
                         
+                          <li><a 
href="/releases/1.1.0/index.html">1.1.0</a></li>
+                        
                       
                         
                           <li><a 
href="/releases/1.0.4/index.html">1.0.4</a></li>
                         
                       
                         
-                      
-                        
                           <li><a 
href="/releases/1.0.3/index.html">1.0.3</a></li>
                         
                       
@@ -104,6 +102,8 @@
                         
                       
                         
+                      
+                        
                           <li><a 
href="/releases/0.10.2/index.html">0.10.2</a></li>
                         
                       
@@ -144,7 +144,7 @@
                         <li><a href="/contribute/BYLAWS.html">ByLaws</a></li>
                     </ul>
                 </li>
-                <li><a href="/2017/09/15/storm105-released.html" 
id="news">News</a></li>
+                <li><a href="/2018/02/14/storm106-released.html" 
id="news">News</a></li>
             </ul>
         </nav>
     </div>
@@ -235,7 +235,7 @@ backtype.storm.contrib.example.topic
 
 <ol>
 <li>Open the ActiveMQ Queue admin console: <a 
href="http://localhost:8161/admin/queues.jsp";>http://localhost:8161/admin/queues.jsp</a></li>
-<li>Click the <a 
href="http://localhost:8161/admin/send.jsp?JMSDestination=backtype.storm.contrib.example.queue&amp;JMSDestinationType=queue";>Send
 To</a>
+<li>Click the <a 
href="http://localhost:8161/admin/send.jsp?JMSDestination=backtype.storm.contrib.example.queue&JMSDestinationType=queue";>Send
 To</a>
 link for the <code>backtupe.storm.example.queue</code> queue entry.</li>
 <li>On the &quot;Send a JMS Message&quot; form, select the &quot;Persistent 
Delivery&quot; checkbox, enter
 some text for the message body, and click &quot;Send&quot;.</li>

http://git-wip-us.apache.org/repos/asf/storm-site/blob/a7a19afb/content/releases/1.0.4/storm-jms-spring.html
----------------------------------------------------------------------
diff --git a/content/releases/1.0.4/storm-jms-spring.html 
b/content/releases/1.0.4/storm-jms-spring.html
index 1941591..cdf2e60 100644
--- a/content/releases/1.0.4/storm-jms-spring.html
+++ b/content/releases/1.0.4/storm-jms-spring.html
@@ -82,18 +82,16 @@
                         
                       
                         
-                          <li><a 
href="/releases/1.1.0/index.html">1.1.0</a></li>
-                        
                       
                         
+                          <li><a 
href="/releases/1.1.0/index.html">1.1.0</a></li>
+                        
                       
                         
                           <li><a 
href="/releases/1.0.4/index.html">1.0.4</a></li>
                         
                       
                         
-                      
-                        
                           <li><a 
href="/releases/1.0.3/index.html">1.0.3</a></li>
                         
                       
@@ -104,6 +102,8 @@
                         
                       
                         
+                      
+                        
                           <li><a 
href="/releases/0.10.2/index.html">0.10.2</a></li>
                         
                       
@@ -144,7 +144,7 @@
                         <li><a href="/contribute/BYLAWS.html">ByLaws</a></li>
                     </ul>
                 </li>
-                <li><a href="/2017/09/15/storm105-released.html" 
id="news">News</a></li>
+                <li><a href="/2018/02/14/storm106-released.html" 
id="news">News</a></li>
             </ul>
         </nav>
     </div>
@@ -160,7 +160,7 @@
 
 <p class="post-meta"></p>
 
-<h3 id="connecting-to-jms-using-spring-39-s-jms-support">Connecting to JMS 
Using Spring&#39;s JMS Support</h3>
+<h3 id="connecting-to-jms-using-springs-jms-support">Connecting to JMS Using 
Spring&#39;s JMS Support</h3>
 
 <p>Create a Spring applicationContext.xml file that defines one or more 
destination (topic/queue) beans, as well as a connecton factory.</p>
 <div class="highlight"><pre><code class="language-" data-lang=""><span 
class="cp">&lt;?xml version="1.0" encoding="UTF-8"?&gt;</span>
@@ -168,8 +168,8 @@
   <span class="na">xmlns=</span><span 
class="s">"http://www.springframework.org/schema/beans";</span> 
   <span class="na">xmlns:amq=</span><span 
class="s">"http://activemq.apache.org/schema/core";</span>
   <span class="na">xmlns:xsi=</span><span 
class="s">"http://www.w3.org/2001/XMLSchema-instance";</span>
-  <span class="na">xsi:schemaLocation=</span><span 
class="s">"http://www.springframework.org/schema/beans</span> <span 
class="err">http://www.springframework.org/schema/beans/spring-beans-2.0.xsd</span>
-  <span class="err">http://activemq.apache.org/schema/core</span> <span 
class="err">http://activemq.apache.org/schema/core/activemq-core.xsd";</span><span
 class="nt">&gt;</span>
+  <span class="na">xsi:schemaLocation=</span><span 
class="s">"http://www.springframework.org/schema/beans 
http://www.springframework.org/schema/beans/spring-beans-2.0.xsd
+  http://activemq.apache.org/schema/core 
http://activemq.apache.org/schema/core/activemq-core.xsd";</span><span 
class="nt">&gt;</span>
 
     <span class="nt">&lt;amq:queue</span> <span class="na">id=</span><span 
class="s">"notificationQueue"</span> <span class="na">physicalName=</span><span 
class="s">"backtype.storm.contrib.example.queue"</span> <span 
class="nt">/&gt;</span>
 

http://git-wip-us.apache.org/repos/asf/storm-site/blob/a7a19afb/content/releases/1.0.4/storm-jms.html
----------------------------------------------------------------------
diff --git a/content/releases/1.0.4/storm-jms.html 
b/content/releases/1.0.4/storm-jms.html
index eafb36d..bb3db44 100644
--- a/content/releases/1.0.4/storm-jms.html
+++ b/content/releases/1.0.4/storm-jms.html
@@ -82,18 +82,16 @@
                         
                       
                         
-                          <li><a 
href="/releases/1.1.0/index.html">1.1.0</a></li>
-                        
                       
                         
+                          <li><a 
href="/releases/1.1.0/index.html">1.1.0</a></li>
+                        
                       
                         
                           <li><a 
href="/releases/1.0.4/index.html">1.0.4</a></li>
                         
                       
                         
-                      
-                        
                           <li><a 
href="/releases/1.0.3/index.html">1.0.3</a></li>
                         
                       
@@ -104,6 +102,8 @@
                         
                       
                         
+                      
+                        
                           <li><a 
href="/releases/0.10.2/index.html">0.10.2</a></li>
                         
                       
@@ -144,7 +144,7 @@
                         <li><a href="/contribute/BYLAWS.html">ByLaws</a></li>
                     </ul>
                 </li>
-                <li><a href="/2017/09/15/storm105-released.html" 
id="news">News</a></li>
+                <li><a href="/2018/02/14/storm106-released.html" 
id="news">News</a></li>
             </ul>
         </nav>
     </div>

http://git-wip-us.apache.org/repos/asf/storm-site/blob/a7a19afb/content/releases/1.0.4/storm-kafka.html
----------------------------------------------------------------------
diff --git a/content/releases/1.0.4/storm-kafka.html 
b/content/releases/1.0.4/storm-kafka.html
index 184d91c..b0b0104 100644
--- a/content/releases/1.0.4/storm-kafka.html
+++ b/content/releases/1.0.4/storm-kafka.html
@@ -82,18 +82,16 @@
                         
                       
                         
-                          <li><a 
href="/releases/1.1.0/index.html">1.1.0</a></li>
-                        
                       
                         
+                          <li><a 
href="/releases/1.1.0/index.html">1.1.0</a></li>
+                        
                       
                         
                           <li><a 
href="/releases/1.0.4/index.html">1.0.4</a></li>
                         
                       
                         
-                      
-                        
                           <li><a 
href="/releases/1.0.3/index.html">1.0.3</a></li>
                         
                       
@@ -104,6 +102,8 @@
                         
                       
                         
+                      
+                        
                           <li><a 
href="/releases/0.10.2/index.html">0.10.2</a></li>
                         
                       
@@ -144,7 +144,7 @@
                         <li><a href="/contribute/BYLAWS.html">ByLaws</a></li>
                     </ul>
                 </li>
-                <li><a href="/2017/09/15/storm105-released.html" 
id="news">News</a></li>
+                <li><a href="/2018/02/14/storm106-released.html" 
id="news">News</a></li>
             </ul>
         </nav>
     </div>
@@ -217,9 +217,9 @@ behavior specific to KafkaSpout.
 The clientId will be used to identify requests which are made using the Kafka 
Protocol.
 The zkRoot will be used as root to store your consumer&#39;s offset.
 The id should uniquely identify your spout.</p>
-<div class="highlight"><pre><code class="language-java" data-lang="java"><span 
class="kd">public</span> <span class="nf">SpoutConfig</span><span 
class="p">(</span><span class="n">BrokerHosts</span> <span 
class="n">hosts</span><span class="o">,</span> <span class="n">String</span> 
<span class="n">topic</span><span class="o">,</span> <span 
class="n">String</span> <span class="n">clientId</span><span class="o">,</span> 
<span class="n">String</span> <span class="n">zkRoot</span><span 
class="o">,</span> <span class="n">String</span> <span class="n">id</span><span 
class="o">);</span>
-<span class="kd">public</span> <span class="nf">SpoutConfig</span><span 
class="p">(</span><span class="n">BrokerHosts</span> <span 
class="n">hosts</span><span class="o">,</span> <span class="n">String</span> 
<span class="n">topic</span><span class="o">,</span> <span 
class="n">String</span> <span class="n">zkRoot</span><span class="o">,</span> 
<span class="n">String</span> <span class="n">id</span><span class="o">);</span>
-<span class="kd">public</span> <span class="nf">SpoutConfig</span><span 
class="p">(</span><span class="n">BrokerHosts</span> <span 
class="n">hosts</span><span class="o">,</span> <span class="n">String</span> 
<span class="n">topic</span><span class="o">,</span> <span 
class="n">String</span> <span class="n">id</span><span class="o">);</span>
+<div class="highlight"><pre><code class="language-java" data-lang="java"><span 
class="kd">public</span> <span class="nf">SpoutConfig</span><span 
class="o">(</span><span class="n">BrokerHosts</span> <span 
class="n">hosts</span><span class="o">,</span> <span class="n">String</span> 
<span class="n">topic</span><span class="o">,</span> <span 
class="n">String</span> <span class="n">clientId</span><span class="o">,</span> 
<span class="n">String</span> <span class="n">zkRoot</span><span 
class="o">,</span> <span class="n">String</span> <span class="n">id</span><span 
class="o">);</span>
+<span class="kd">public</span> <span class="nf">SpoutConfig</span><span 
class="o">(</span><span class="n">BrokerHosts</span> <span 
class="n">hosts</span><span class="o">,</span> <span class="n">String</span> 
<span class="n">topic</span><span class="o">,</span> <span 
class="n">String</span> <span class="n">zkRoot</span><span class="o">,</span> 
<span class="n">String</span> <span class="n">id</span><span class="o">);</span>
+<span class="kd">public</span> <span class="nf">SpoutConfig</span><span 
class="o">(</span><span class="n">BrokerHosts</span> <span 
class="n">hosts</span><span class="o">,</span> <span class="n">String</span> 
<span class="n">topic</span><span class="o">,</span> <span 
class="n">String</span> <span class="n">id</span><span class="o">);</span>
 </code></pre></div>
 <p>In addition to these parameters, SpoutConfig contains the following fields 
that control how KafkaSpout behaves:
 ```java
@@ -262,14 +262,14 @@ The KafkaConfig class also has bunch of public variables 
that controls your appl
 
 <p>MultiScheme is an interface that dictates how the ByteBuffer consumed from 
Kafka gets transformed into a storm tuple. It
 also controls the naming of your output field.</p>
-<div class="highlight"><pre><code class="language-java" data-lang="java">  
<span class="kd">public</span> <span class="n">Iterable</span><span 
class="o">&lt;</span><span class="n">List</span><span 
class="o">&lt;</span><span class="n">Object</span><span 
class="o">&gt;&gt;</span> <span class="n">deserialize</span><span 
class="o">(</span><span class="n">ByteBuffer</span> <span 
class="n">ser</span><span class="o">);</span>
-  <span class="kd">public</span> <span class="n">Fields</span> <span 
class="n">getOutputFields</span><span class="o">();</span>
+<div class="highlight"><pre><code class="language-java" data-lang="java">  
<span class="kd">public</span> <span class="n">Iterable</span><span 
class="o">&lt;</span><span class="n">List</span><span 
class="o">&lt;</span><span class="n">Object</span><span 
class="o">&gt;&gt;</span> <span class="nf">deserialize</span><span 
class="o">(</span><span class="n">ByteBuffer</span> <span 
class="n">ser</span><span class="o">);</span>
+  <span class="kd">public</span> <span class="n">Fields</span> <span 
class="nf">getOutputFields</span><span class="o">();</span>
 </code></pre></div>
 <p>The default <code>RawMultiScheme</code> just takes the 
<code>ByteBuffer</code> and returns a tuple with the ByteBuffer converted to a 
<code>byte[]</code>. The name of the outputField is &quot;bytes&quot;. There 
are alternative implementations like <code>SchemeAsMultiScheme</code> and 
<code>KeyValueSchemeAsMultiScheme</code> which can convert the 
<code>ByteBuffer</code> to <code>String</code>.</p>
 
 <p>There is also an extension of <code>SchemeAsMultiScheme</code>, 
<code>MessageMetadataSchemeAsMultiScheme</code>,
 which has an additional deserialize method that accepts the message 
<code>ByteBuffer</code> in addition to the <code>Partition</code> and 
<code>offset</code> associated with the message.</p>
-<div class="highlight"><pre><code class="language-java" data-lang="java"><span 
class="kd">public</span> <span class="n">Iterable</span><span 
class="o">&lt;</span><span class="n">List</span><span 
class="o">&lt;</span><span class="n">Object</span><span 
class="o">&gt;&gt;</span> <span 
class="n">deserializeMessageWithMetadata</span><span class="o">(</span><span 
class="n">ByteBuffer</span> <span class="n">message</span><span 
class="o">,</span> <span class="n">Partition</span> <span 
class="n">partition</span><span class="o">,</span> <span class="kt">long</span> 
<span class="n">offset</span><span class="o">)</span>
+<div class="highlight"><pre><code class="language-java" data-lang="java"><span 
class="kd">public</span> <span class="n">Iterable</span><span 
class="o">&lt;</span><span class="n">List</span><span 
class="o">&lt;</span><span class="n">Object</span><span 
class="o">&gt;&gt;</span> <span 
class="nf">deserializeMessageWithMetadata</span><span class="o">(</span><span 
class="n">ByteBuffer</span> <span class="n">message</span><span 
class="o">,</span> <span class="n">Partition</span> <span 
class="n">partition</span><span class="o">,</span> <span class="kt">long</span> 
<span class="n">offset</span><span class="o">)</span>
 
 </code></pre></div>
 <p>This is useful for auditing/replaying messages from arbitrary points on a 
Kafka topic, saving the partition and offset of each message of a discrete 
stream instead of persisting the entire message.</p>
@@ -280,38 +280,38 @@ which has an additional deserialize method that accepts 
the message <code>ByteBu
 between consecutive retries. To use a custom implementation, set 
SpoutConfig.failedMsgRetryManagerClass to the full classname
 of implementation. Here is the interface </p>
 <div class="highlight"><pre><code class="language-java" data-lang="java">    
<span class="c1">// Spout initialization can go here. This can be called 
multiple times during lifecycle of a worker. </span>
-    <span class="kt">void</span> <span class="n">prepare</span><span 
class="o">(</span><span class="n">SpoutConfig</span> <span 
class="n">spoutConfig</span><span class="o">,</span> <span class="n">Map</span> 
<span class="n">stormConf</span><span class="o">);</span>
+    <span class="kt">void</span> <span class="nf">prepare</span><span 
class="o">(</span><span class="n">SpoutConfig</span> <span 
class="n">spoutConfig</span><span class="o">,</span> <span class="n">Map</span> 
<span class="n">stormConf</span><span class="o">);</span>
 
     <span class="c1">// Message corresponding to offset has failed. This 
method is called only if retryFurther returns true for offset.</span>
-    <span class="kt">void</span> <span class="n">failed</span><span 
class="o">(</span><span class="n">Long</span> <span 
class="n">offset</span><span class="o">);</span>
+    <span class="kt">void</span> <span class="nf">failed</span><span 
class="o">(</span><span class="n">Long</span> <span 
class="n">offset</span><span class="o">);</span>
 
     <span class="c1">// Message corresponding to offset has been acked.  
</span>
-    <span class="kt">void</span> <span class="n">acked</span><span 
class="o">(</span><span class="n">Long</span> <span 
class="n">offset</span><span class="o">);</span>
+    <span class="kt">void</span> <span class="nf">acked</span><span 
class="o">(</span><span class="n">Long</span> <span 
class="n">offset</span><span class="o">);</span>
 
     <span class="c1">// Message corresponding to the offset, has been 
re-emitted and under transit.</span>
-    <span class="kt">void</span> <span class="n">retryStarted</span><span 
class="o">(</span><span class="n">Long</span> <span 
class="n">offset</span><span class="o">);</span>
+    <span class="kt">void</span> <span class="nf">retryStarted</span><span 
class="o">(</span><span class="n">Long</span> <span 
class="n">offset</span><span class="o">);</span>
 
     <span class="cm">/**
      * The offset of message, which is to be re-emitted. Spout will fetch 
messages starting from this offset
      * and resend them, except completed messages.
      */</span>
-    <span class="n">Long</span> <span 
class="n">nextFailedMessageToRetry</span><span class="o">();</span>
+    <span class="n">Long</span> <span 
class="nf">nextFailedMessageToRetry</span><span class="o">();</span>
 
     <span class="cm">/**
      * @return True if the message corresponding to the offset should be 
emitted NOW. False otherwise.
      */</span>
-    <span class="kt">boolean</span> <span 
class="n">shouldReEmitMsg</span><span class="o">(</span><span 
class="n">Long</span> <span class="n">offset</span><span class="o">);</span>
+    <span class="kt">boolean</span> <span 
class="nf">shouldReEmitMsg</span><span class="o">(</span><span 
class="n">Long</span> <span class="n">offset</span><span class="o">);</span>
 
     <span class="cm">/**
      * Spout will clean up the state for this offset if false is returned. If 
retryFurther is set to true,
      * spout will called failed(offset) in next call and acked(offset) 
otherwise 
      */</span>
-    <span class="kt">boolean</span> <span class="n">retryFurther</span><span 
class="o">(</span><span class="n">Long</span> <span 
class="n">offset</span><span class="o">);</span>
+    <span class="kt">boolean</span> <span class="nf">retryFurther</span><span 
class="o">(</span><span class="n">Long</span> <span 
class="n">offset</span><span class="o">);</span>
 
     <span class="cm">/**
      * Clear any offsets before kafkaOffset. These offsets are no longer 
available in kafka.
      */</span>
-    <span class="n">Set</span><span class="o">&lt;</span><span 
class="n">Long</span><span class="o">&gt;</span> <span 
class="n">clearOffsetsBefore</span><span class="o">(</span><span 
class="n">Long</span> <span class="n">kafkaOffset</span><span 
class="o">);</span>
+    <span class="n">Set</span><span class="o">&lt;</span><span 
class="n">Long</span><span class="o">&gt;</span> <span 
class="nf">clearOffsetsBefore</span><span class="o">(</span><span 
class="n">Long</span> <span class="n">kafkaOffset</span><span 
class="o">);</span>
 </code></pre></div>
 <h4 id="version-incompatibility">Version incompatibility</h4>
 
@@ -411,8 +411,8 @@ org.apache.storm.kafka.trident.TridentKafkaUpdater.</p>
 <h3 id="tupletokafkamapper-and-tridenttupletokafkamapper">TupleToKafkaMapper 
and TridentTupleToKafkaMapper</h3>
 
 <p>These interfaces have 2 methods defined:</p>
-<div class="highlight"><pre><code class="language-java" data-lang="java">    
<span class="n">K</span> <span class="nf">getKeyFromTuple</span><span 
class="p">(</span><span class="n">Tuple</span><span class="o">/</span><span 
class="n">TridentTuple</span> <span class="n">tuple</span><span 
class="o">);</span>
-    <span class="n">V</span> <span class="n">getMessageFromTuple</span><span 
class="o">(</span><span class="n">Tuple</span><span class="o">/</span><span 
class="n">TridentTuple</span> <span class="n">tuple</span><span 
class="o">);</span>
+<div class="highlight"><pre><code class="language-java" data-lang="java">    
<span class="n">K</span> <span class="nf">getKeyFromTuple</span><span 
class="o">(</span><span class="n">Tuple</span><span class="o">/</span><span 
class="n">TridentTuple</span> <span class="n">tuple</span><span 
class="o">);</span>
+    <span class="n">V</span> <span class="nf">getMessageFromTuple</span><span 
class="o">(</span><span class="n">Tuple</span><span class="o">/</span><span 
class="n">TridentTuple</span> <span class="n">tuple</span><span 
class="o">);</span>
 </code></pre></div>
 <p>As the name suggests, these methods are called to map a tuple to Kafka key 
and Kafka message. If you just want one field
 as key and one field as value, then you can use the provided 
FieldNameBasedTupleToKafkaMapper.java
@@ -484,10 +484,10 @@ For the bolt :
 <p>For Trident:</p>
 <div class="highlight"><pre><code class="language-java" data-lang="java">      
  <span class="n">Fields</span> <span class="n">fields</span> <span 
class="o">=</span> <span class="k">new</span> <span 
class="n">Fields</span><span class="o">(</span><span 
class="s">"word"</span><span class="o">,</span> <span 
class="s">"count"</span><span class="o">);</span>
         <span class="n">FixedBatchSpout</span> <span class="n">spout</span> 
<span class="o">=</span> <span class="k">new</span> <span 
class="n">FixedBatchSpout</span><span class="o">(</span><span 
class="n">fields</span><span class="o">,</span> <span class="mi">4</span><span 
class="o">,</span>
-                <span class="k">new</span> <span class="n">Values</span><span 
class="o">(</span><span class="s">"storm"</span><span class="o">,</span> <span 
class="s">"1"</span><span class="o">),</span>
-                <span class="k">new</span> <span class="n">Values</span><span 
class="o">(</span><span class="s">"trident"</span><span class="o">,</span> 
<span class="s">"1"</span><span class="o">),</span>
-                <span class="k">new</span> <span class="n">Values</span><span 
class="o">(</span><span class="s">"needs"</span><span class="o">,</span> <span 
class="s">"1"</span><span class="o">),</span>
-                <span class="k">new</span> <span class="n">Values</span><span 
class="o">(</span><span class="s">"javadoc"</span><span class="o">,</span> 
<span class="s">"1"</span><span class="o">)</span>
+                <span class="k">new</span> <span class="nf">Values</span><span 
class="o">(</span><span class="s">"storm"</span><span class="o">,</span> <span 
class="s">"1"</span><span class="o">),</span>
+                <span class="k">new</span> <span class="nf">Values</span><span 
class="o">(</span><span class="s">"trident"</span><span class="o">,</span> 
<span class="s">"1"</span><span class="o">),</span>
+                <span class="k">new</span> <span class="nf">Values</span><span 
class="o">(</span><span class="s">"needs"</span><span class="o">,</span> <span 
class="s">"1"</span><span class="o">),</span>
+                <span class="k">new</span> <span class="nf">Values</span><span 
class="o">(</span><span class="s">"javadoc"</span><span class="o">,</span> 
<span class="s">"1"</span><span class="o">)</span>
         <span class="o">);</span>
         <span class="n">spout</span><span class="o">.</span><span 
class="na">setCycle</span><span class="o">(</span><span 
class="kc">true</span><span class="o">);</span>
 

http://git-wip-us.apache.org/repos/asf/storm-site/blob/a7a19afb/content/releases/1.0.4/storm-metrics-profiling-internal-actions.html
----------------------------------------------------------------------
diff --git 
a/content/releases/1.0.4/storm-metrics-profiling-internal-actions.html 
b/content/releases/1.0.4/storm-metrics-profiling-internal-actions.html
index ec9ecf9..80a6e70 100644
--- a/content/releases/1.0.4/storm-metrics-profiling-internal-actions.html
+++ b/content/releases/1.0.4/storm-metrics-profiling-internal-actions.html
@@ -82,18 +82,16 @@
                         
                       
                         
-                          <li><a 
href="/releases/1.1.0/index.html">1.1.0</a></li>
-                        
                       
                         
+                          <li><a 
href="/releases/1.1.0/index.html">1.1.0</a></li>
+                        
                       
                         
                           <li><a 
href="/releases/1.0.4/index.html">1.0.4</a></li>
                         
                       
                         
-                      
-                        
                           <li><a 
href="/releases/1.0.3/index.html">1.0.3</a></li>
                         
                       
@@ -104,6 +102,8 @@
                         
                       
                         
+                      
+                        
                           <li><a 
href="/releases/0.10.2/index.html">0.10.2</a></li>
                         
                       
@@ -144,7 +144,7 @@
                         <li><a href="/contribute/BYLAWS.html">ByLaws</a></li>
                     </ul>
                 </li>
-                <li><a href="/2017/09/15/storm105-released.html" 
id="news">News</a></li>
+                <li><a href="/2018/02/14/storm106-released.html" 
id="news">News</a></li>
             </ul>
         </nav>
     </div>

Reply via email to