http://git-wip-us.apache.org/repos/asf/storm-site/blob/a7a19afb/content/releases/0.10.2/Serialization-(prior-to-0.6.0).html
----------------------------------------------------------------------
diff --git a/content/releases/0.10.2/Serialization-(prior-to-0.6.0).html 
b/content/releases/0.10.2/Serialization-(prior-to-0.6.0).html
index 5f320fb..3f9cfef 100644
--- a/content/releases/0.10.2/Serialization-(prior-to-0.6.0).html
+++ b/content/releases/0.10.2/Serialization-(prior-to-0.6.0).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>
@@ -182,9 +182,9 @@
 
 <p>The interface looks like this:</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">ISerialization</span><span class="o">&lt;</span><span 
class="n">T</span><span class="o">&gt;</span> <span class="o">{</span>
-    <span class="kd">public</span> <span class="kt">boolean</span> <span 
class="n">accept</span><span class="o">(</span><span class="n">Class</span> 
<span class="n">c</span><span class="o">);</span>
-    <span class="kd">public</span> <span class="kt">void</span> <span 
class="n">serialize</span><span class="o">(</span><span class="n">T</span> 
<span class="n">object</span><span class="o">,</span> <span 
class="n">DataOutputStream</span> <span class="n">stream</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="n">T</span> <span 
class="n">deserialize</span><span class="o">(</span><span 
class="n">DataInputStream</span> <span class="n">stream</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">boolean</span> <span 
class="nf">accept</span><span class="o">(</span><span class="n">Class</span> 
<span class="n">c</span><span class="o">);</span>
+    <span class="kd">public</span> <span class="kt">void</span> <span 
class="nf">serialize</span><span class="o">(</span><span class="n">T</span> 
<span class="n">object</span><span class="o">,</span> <span 
class="n">DataOutputStream</span> <span class="n">stream</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="n">T</span> <span 
class="nf">deserialize</span><span class="o">(</span><span 
class="n">DataInputStream</span> <span class="n">stream</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 uses the <code>accept</code> method to determine if a type can be 
serialized by this serializer. Remember, Storm&#39;s tuples are dynamically 
typed so Storm determines what serializer to use at runtime.</p>

http://git-wip-us.apache.org/repos/asf/storm-site/blob/a7a19afb/content/releases/0.10.2/Serialization.html
----------------------------------------------------------------------
diff --git a/content/releases/0.10.2/Serialization.html 
b/content/releases/0.10.2/Serialization.html
index 62e8a3d..67d7148 100644
--- a/content/releases/0.10.2/Serialization.html
+++ b/content/releases/0.10.2/Serialization.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/0.10.2/Serializers.html
----------------------------------------------------------------------
diff --git a/content/releases/0.10.2/Serializers.html 
b/content/releases/0.10.2/Serializers.html
index da458e1..cfef4da 100644
--- a/content/releases/0.10.2/Serializers.html
+++ b/content/releases/0.10.2/Serializers.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/0.10.2/Setting-up-a-Storm-cluster.html
----------------------------------------------------------------------
diff --git a/content/releases/0.10.2/Setting-up-a-Storm-cluster.html 
b/content/releases/0.10.2/Setting-up-a-Storm-cluster.html
index 75b6703..b051b5c 100644
--- a/content/releases/0.10.2/Setting-up-a-Storm-cluster.html
+++ b/content/releases/0.10.2/Setting-up-a-Storm-cluster.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>
@@ -252,7 +252,7 @@ The time to allow any given healthcheck script to run 
before it is marked failed
 
 <p>If you need support from external libraries or custom plugins, you can 
place such jars into the extlib/ and extlib-daemon/ directories. Note that the 
extlib-daemon/ directory stores jars used only by daemons (Nimbus, Supervisor, 
DRPC, UI, Logviewer), e.g., HDFS and customized scheduling libraries. 
Accordingly, two environmental variables STORM_EXT_CLASSPATH and 
STORM_EXT_CLASSPATH_DAEMON can be configured by users for including the 
external classpath and daemon-only external classpath.</p>
 
-<h3 
id="launch-daemons-under-supervision-using-quot-storm-quot-script-and-a-supervisor-of-your-choice">Launch
 daemons under supervision using &quot;storm&quot; script and a supervisor of 
your choice</h3>
+<h3 
id="launch-daemons-under-supervision-using-storm-script-and-a-supervisor-of-your-choice">Launch
 daemons under supervision using &quot;storm&quot; script and a supervisor of 
your choice</h3>
 
 <p>The last step is to launch all the Storm daemons. It is critical that you 
run each of these daemons under supervision. Storm is a 
<strong>fail-fast</strong> system which means the processes will halt whenever 
an unexpected error is encountered. Storm is designed so that it can safely 
halt at any point and recover correctly when the process is restarted. This is 
why Storm keeps no state in-process -- if Nimbus or the Supervisors restart, 
the running topologies are unaffected. Here&#39;s how to run the Storm 
daemons:</p>
 

http://git-wip-us.apache.org/repos/asf/storm-site/blob/a7a19afb/content/releases/0.10.2/Setting-up-development-environment.html
----------------------------------------------------------------------
diff --git a/content/releases/0.10.2/Setting-up-development-environment.html 
b/content/releases/0.10.2/Setting-up-development-environment.html
index 6019d7a..5bc1606 100644
--- a/content/releases/0.10.2/Setting-up-development-environment.html
+++ b/content/releases/0.10.2/Setting-up-development-environment.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/0.10.2/Spout-implementations.html
----------------------------------------------------------------------
diff --git a/content/releases/0.10.2/Spout-implementations.html 
b/content/releases/0.10.2/Spout-implementations.html
index b42926d..7b1e504 100644
--- a/content/releases/0.10.2/Spout-implementations.html
+++ b/content/releases/0.10.2/Spout-implementations.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/0.10.2/Storm-multi-language-protocol-(versions-0.7.0-and-below).html
----------------------------------------------------------------------
diff --git 
a/content/releases/0.10.2/Storm-multi-language-protocol-(versions-0.7.0-and-below).html
 
b/content/releases/0.10.2/Storm-multi-language-protocol-(versions-0.7.0-and-below).html
index 86a8782..344aa96 100644
--- 
a/content/releases/0.10.2/Storm-multi-language-protocol-(versions-0.7.0-and-below).html
+++ 
b/content/releases/0.10.2/Storm-multi-language-protocol-(versions-0.7.0-and-below).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>
@@ -210,56 +210,56 @@ file lets the supervisor know the PID so it can shutdown 
the process later on.</
 <li>The rest happens in a while(true) loop</li>
 <li>STDIN: A tuple! This is a JSON encoded structure like this:</li>
 </ul>
-<div class="highlight"><pre><code class="language-" data-lang=""><span 
class="p">{</span><span class="w">
-    </span><span class="err">//</span><span class="w"> </span><span 
class="err">The</span><span class="w"> </span><span 
class="err">tuple's</span><span class="w"> </span><span 
class="err">id</span><span class="w">
-    </span><span class="nt">"id"</span><span class="p">:</span><span 
class="w"> </span><span class="mi">-6955786537413359385</span><span 
class="p">,</span><span class="w">
-    </span><span class="err">//</span><span class="w"> </span><span 
class="err">The</span><span class="w"> </span><span class="err">id</span><span 
class="w"> </span><span class="err">of</span><span class="w"> </span><span 
class="err">the</span><span class="w"> </span><span 
class="err">component</span><span class="w"> </span><span 
class="err">that</span><span class="w"> </span><span 
class="err">created</span><span class="w"> </span><span 
class="err">this</span><span class="w"> </span><span 
class="err">tuple</span><span class="w">
-    </span><span class="nt">"comp"</span><span class="p">:</span><span 
class="w"> </span><span class="mi">1</span><span class="p">,</span><span 
class="w">
-    </span><span class="err">//</span><span class="w"> </span><span 
class="err">The</span><span class="w"> </span><span class="err">id</span><span 
class="w"> </span><span class="err">of</span><span class="w"> </span><span 
class="err">the</span><span class="w"> </span><span 
class="err">stream</span><span class="w"> </span><span 
class="err">this</span><span class="w"> </span><span 
class="err">tuple</span><span class="w"> </span><span 
class="err">was</span><span class="w"> </span><span 
class="err">emitted</span><span class="w"> </span><span 
class="err">to</span><span class="w">
-    </span><span class="nt">"stream"</span><span class="p">:</span><span 
class="w"> </span><span class="mi">1</span><span class="p">,</span><span 
class="w">
-    </span><span class="err">//</span><span class="w"> </span><span 
class="err">The</span><span class="w"> </span><span class="err">id</span><span 
class="w"> </span><span class="err">of</span><span class="w"> </span><span 
class="err">the</span><span class="w"> </span><span 
class="err">task</span><span class="w"> </span><span 
class="err">that</span><span class="w"> </span><span 
class="err">created</span><span class="w"> </span><span 
class="err">this</span><span class="w"> </span><span 
class="err">tuple</span><span class="w">
-    </span><span class="nt">"task"</span><span class="p">:</span><span 
class="w"> </span><span class="mi">9</span><span class="p">,</span><span 
class="w">
-    </span><span class="err">//</span><span class="w"> </span><span 
class="err">All</span><span class="w"> </span><span class="err">the</span><span 
class="w"> </span><span class="err">values</span><span class="w"> </span><span 
class="err">in</span><span class="w"> </span><span class="err">this</span><span 
class="w"> </span><span class="err">tuple</span><span class="w">
-    </span><span class="nt">"tuple"</span><span class="p">:</span><span 
class="w"> </span><span class="p">[</span><span class="s2">"snow white and the 
seven dwarfs"</span><span class="p">,</span><span class="w"> </span><span 
class="s2">"field2"</span><span class="p">,</span><span class="w"> </span><span 
class="mi">3</span><span class="p">]</span><span class="w">
-</span><span class="p">}</span><span class="w">
-</span></code></pre></div>
+<div class="highlight"><pre><code class="language-" data-lang="">{
+    // The tuple's id
+    "id": -6955786537413359385,
+    // The id of the component that created this tuple
+    "comp": 1,
+    // The id of the stream this tuple was emitted to
+    "stream": 1,
+    // The id of the task that created this tuple
+    "task": 9,
+    // All the values in this tuple
+    "tuple": ["snow white and the seven dwarfs", "field2", 3]
+}
+</code></pre></div>
 <ul>
 <li>STDOUT: The results of your bolt, JSON encoded. This can be a sequence of 
acks, fails, emits, and/or logs. Emits look like:</li>
 </ul>
-<div class="highlight"><pre><code class="language-" data-lang=""><span 
class="p">{</span><span class="w">
-    </span><span class="nt">"command"</span><span class="p">:</span><span 
class="w"> </span><span class="s2">"emit"</span><span class="p">,</span><span 
class="w">
-    </span><span class="err">//</span><span class="w"> </span><span 
class="err">The</span><span class="w"> </span><span class="err">ids</span><span 
class="w"> </span><span class="err">of</span><span class="w"> </span><span 
class="err">the</span><span class="w"> </span><span 
class="err">tuples</span><span class="w"> </span><span 
class="err">this</span><span class="w"> </span><span 
class="err">output</span><span class="w"> </span><span 
class="err">tuples</span><span class="w"> </span><span 
class="err">should</span><span class="w"> </span><span 
class="err">be</span><span class="w"> </span><span 
class="err">anchored</span><span class="w"> </span><span 
class="err">to</span><span class="w">
-    </span><span class="nt">"anchors"</span><span class="p">:</span><span 
class="w"> </span><span class="p">[</span><span class="mi">1231231</span><span 
class="p">,</span><span class="w"> </span><span 
class="mi">-234234234</span><span class="p">],</span><span class="w">
-    </span><span class="err">//</span><span class="w"> </span><span 
class="err">The</span><span class="w"> </span><span class="err">id</span><span 
class="w"> </span><span class="err">of</span><span class="w"> </span><span 
class="err">the</span><span class="w"> </span><span 
class="err">stream</span><span class="w"> </span><span 
class="err">this</span><span class="w"> </span><span 
class="err">tuple</span><span class="w"> </span><span 
class="err">was</span><span class="w"> </span><span 
class="err">emitted</span><span class="w"> </span><span 
class="err">to.</span><span class="w"> </span><span 
class="err">Leave</span><span class="w"> </span><span 
class="err">this</span><span class="w"> </span><span 
class="err">empty</span><span class="w"> </span><span 
class="err">to</span><span class="w"> </span><span class="err">emit</span><span 
class="w"> </span><span class="err">to</span><span class="w"> </span><span 
class="err">default</span><span class="w"> </span><span 
class="err">stream.</span><sp
 an class="w">
-    </span><span class="nt">"stream"</span><span class="p">:</span><span 
class="w"> </span><span class="mi">1</span><span class="p">,</span><span 
class="w">
-    </span><span class="err">//</span><span class="w"> </span><span 
class="err">If</span><span class="w"> </span><span 
class="err">doing</span><span class="w"> </span><span 
class="err">an</span><span class="w"> </span><span class="err">emit</span><span 
class="w"> </span><span class="err">direct,</span><span class="w"> </span><span 
class="err">indicate</span><span class="w"> </span><span 
class="err">the</span><span class="w"> </span><span 
class="err">task</span><span class="w"> </span><span class="err">to</span><span 
class="w"> </span><span class="err">sent</span><span class="w"> </span><span 
class="err">the</span><span class="w"> </span><span 
class="err">tuple</span><span class="w"> </span><span 
class="err">to</span><span class="w">
-    </span><span class="nt">"task"</span><span class="p">:</span><span 
class="w"> </span><span class="mi">9</span><span class="p">,</span><span 
class="w">
-    </span><span class="err">//</span><span class="w"> </span><span 
class="err">All</span><span class="w"> </span><span class="err">the</span><span 
class="w"> </span><span class="err">values</span><span class="w"> </span><span 
class="err">in</span><span class="w"> </span><span class="err">this</span><span 
class="w"> </span><span class="err">tuple</span><span class="w">
-    </span><span class="nt">"tuple"</span><span class="p">:</span><span 
class="w"> </span><span class="p">[</span><span class="s2">"field1"</span><span 
class="p">,</span><span class="w"> </span><span class="mi">2</span><span 
class="p">,</span><span class="w"> </span><span class="mi">3</span><span 
class="p">]</span><span class="w">
-</span><span class="p">}</span><span class="w">
-</span></code></pre></div>
+<div class="highlight"><pre><code class="language-" data-lang="">{
+    "command": "emit",
+    // The ids of the tuples this output tuples should be anchored to
+    "anchors": [1231231, -234234234],
+    // The id of the stream this tuple was emitted to. Leave this empty to 
emit to default stream.
+    "stream": 1,
+    // If doing an emit direct, indicate the task to sent the tuple to
+    "task": 9,
+    // All the values in this tuple
+    "tuple": ["field1", 2, 3]
+}
+</code></pre></div>
 <p>An ack looks like:</p>
-<div class="highlight"><pre><code class="language-" data-lang=""><span 
class="p">{</span><span class="w">
-    </span><span class="nt">"command"</span><span class="p">:</span><span 
class="w"> </span><span class="s2">"ack"</span><span class="p">,</span><span 
class="w">
-    </span><span class="err">//</span><span class="w"> </span><span 
class="err">the</span><span class="w"> </span><span class="err">id</span><span 
class="w"> </span><span class="err">of</span><span class="w"> </span><span 
class="err">the</span><span class="w"> </span><span 
class="err">tuple</span><span class="w"> </span><span 
class="err">to</span><span class="w"> </span><span class="err">ack</span><span 
class="w">
-    </span><span class="nt">"id"</span><span class="p">:</span><span 
class="w"> </span><span class="mi">123123</span><span class="w">
-</span><span class="p">}</span><span class="w">
-</span></code></pre></div>
+<div class="highlight"><pre><code class="language-" data-lang="">{
+    "command": "ack",
+    // the id of the tuple to ack
+    "id": 123123
+}
+</code></pre></div>
 <p>A fail looks like:</p>
-<div class="highlight"><pre><code class="language-" data-lang=""><span 
class="p">{</span><span class="w">
-    </span><span class="nt">"command"</span><span class="p">:</span><span 
class="w"> </span><span class="s2">"fail"</span><span class="p">,</span><span 
class="w">
-    </span><span class="err">//</span><span class="w"> </span><span 
class="err">the</span><span class="w"> </span><span class="err">id</span><span 
class="w"> </span><span class="err">of</span><span class="w"> </span><span 
class="err">the</span><span class="w"> </span><span 
class="err">tuple</span><span class="w"> </span><span 
class="err">to</span><span class="w"> </span><span class="err">fail</span><span 
class="w">
-    </span><span class="nt">"id"</span><span class="p">:</span><span 
class="w"> </span><span class="mi">123123</span><span class="w">
-</span><span class="p">}</span><span class="w">
-</span></code></pre></div>
+<div class="highlight"><pre><code class="language-" data-lang="">{
+    "command": "fail",
+    // the id of the tuple to fail
+    "id": 123123
+}
+</code></pre></div>
 <p>A &quot;log&quot; will log a message in the worker log. It looks like:</p>
-<div class="highlight"><pre><code class="language-" data-lang=""><span 
class="p">{</span><span class="w">
-    </span><span class="nt">"command"</span><span class="p">:</span><span 
class="w"> </span><span class="s2">"log"</span><span class="p">,</span><span 
class="w">
-    </span><span class="err">//</span><span class="w"> </span><span 
class="err">the</span><span class="w"> </span><span 
class="err">message</span><span class="w"> </span><span 
class="err">to</span><span class="w"> </span><span class="err">log</span><span 
class="w">
-    </span><span class="nt">"msg"</span><span class="p">:</span><span 
class="w"> </span><span class="s2">"hello world!"</span><span class="w">
+<div class="highlight"><pre><code class="language-" data-lang="">{
+    "command": "log",
+    // the message to log
+    "msg": "hello world!"
 
-</span><span class="p">}</span><span class="w">
-</span></code></pre></div>
+}
+</code></pre></div>
 <ul>
 <li>STDOUT: emit &quot;sync&quot; as a single line by itself when the bolt has 
finished emitting/acking/failing and is ready for the next input</li>
 </ul>

http://git-wip-us.apache.org/repos/asf/storm-site/blob/a7a19afb/content/releases/0.10.2/Structure-of-the-codebase.html
----------------------------------------------------------------------
diff --git a/content/releases/0.10.2/Structure-of-the-codebase.html 
b/content/releases/0.10.2/Structure-of-the-codebase.html
index 9636120..280ef2c 100644
--- a/content/releases/0.10.2/Structure-of-the-codebase.html
+++ b/content/releases/0.10.2/Structure-of-the-codebase.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/0.10.2/Support-for-non-java-languages.html
----------------------------------------------------------------------
diff --git a/content/releases/0.10.2/Support-for-non-java-languages.html 
b/content/releases/0.10.2/Support-for-non-java-languages.html
index d14de50..e5367cb 100644
--- a/content/releases/0.10.2/Support-for-non-java-languages.html
+++ b/content/releases/0.10.2/Support-for-non-java-languages.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/0.10.2/Transactional-topologies.html
----------------------------------------------------------------------
diff --git a/content/releases/0.10.2/Transactional-topologies.html 
b/content/releases/0.10.2/Transactional-topologies.html
index ffc9a59..bfa9ec3 100644
--- a/content/releases/0.10.2/Transactional-topologies.html
+++ b/content/releases/0.10.2/Transactional-topologies.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>
@@ -211,7 +211,7 @@
 
 <p>After bolt 1 finishes its portion of the processing, it will be idle until 
the rest of the bolts finish and the next batch can be emitted from the 
spout.</p>
 
-<h3 id="design-3-storm-39-s-design">Design 3 (Storm&#39;s design)</h3>
+<h3 id="design-3-storms-design">Design 3 (Storm&#39;s design)</h3>
 
 <p>A key realization is that not all the work for processing batches of tuples 
needs to be strongly ordered. For example, when computing a global count, 
there&#39;s two parts to the computation:</p>
 
@@ -268,23 +268,23 @@
     <span class="kt">int</span> <span class="n">_count</span> <span 
class="o">=</span> <span class="mi">0</span><span class="o">;</span>
 
     <span class="nd">@Override</span>
-    <span class="kd">public</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">context</span><span 
class="o">,</span> <span class="n">BatchOutputCollector</span> <span 
class="n">collector</span><span class="o">,</span> <span 
class="n">Object</span> <span class="n">id</span><span class="o">)</span> <span 
class="o">{</span>
+    <span class="kd">public</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">context</span><span 
class="o">,</span> <span class="n">BatchOutputCollector</span> <span 
class="n">collector</span><span class="o">,</span> <span 
class="n">Object</span> <span class="n">id</span><span class="o">)</span> <span 
class="o">{</span>
         <span class="n">_collector</span> <span class="o">=</span> <span 
class="n">collector</span><span class="o">;</span>
         <span class="n">_id</span> <span class="o">=</span> <span 
class="n">id</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">Tuple</span> 
<span class="n">tuple</span><span class="o">)</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">Tuple</span> 
<span class="n">tuple</span><span class="o">)</span> <span class="o">{</span>
         <span class="n">_count</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">finishBatch</span><span class="o">()</span> <span class="o">{</span>
+    <span class="kd">public</span> <span class="kt">void</span> <span 
class="nf">finishBatch</span><span class="o">()</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="k">new</span> <span 
class="n">Values</span><span class="o">(</span><span class="n">_id</span><span 
class="o">,</span> <span class="n">_count</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">declareOutputFields</span><span class="o">(</span><span 
class="n">OutputFieldsDeclarer</span> <span class="n">declarer</span><span 
class="o">)</span> <span class="o">{</span>
+    <span class="kd">public</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>
         <span class="n">declarer</span><span class="o">.</span><span 
class="na">declare</span><span class="o">(</span><span class="k">new</span> 
<span class="n">Fields</span><span class="o">(</span><span 
class="s">"id"</span><span class="o">,</span> <span 
class="s">"count"</span><span class="o">));</span>
     <span class="o">}</span>
 <span class="o">}</span>
@@ -313,18 +313,18 @@
     <span class="kt">int</span> <span class="n">_sum</span> <span 
class="o">=</span> <span class="mi">0</span><span class="o">;</span>
 
     <span class="nd">@Override</span>
-    <span class="kd">public</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">context</span><span 
class="o">,</span> <span class="n">BatchOutputCollector</span> <span 
class="n">collector</span><span class="o">,</span> <span 
class="n">TransactionAttempt</span> <span class="n">attempt</span><span 
class="o">)</span> <span class="o">{</span>
+    <span class="kd">public</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">context</span><span 
class="o">,</span> <span class="n">BatchOutputCollector</span> <span 
class="n">collector</span><span class="o">,</span> <span 
class="n">TransactionAttempt</span> <span class="n">attempt</span><span 
class="o">)</span> <span class="o">{</span>
         <span class="n">_collector</span> <span class="o">=</span> <span 
class="n">collector</span><span class="o">;</span>
         <span class="n">_attempt</span> <span class="o">=</span> <span 
class="n">attempt</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">Tuple</span> 
<span class="n">tuple</span><span class="o">)</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">Tuple</span> 
<span class="n">tuple</span><span class="o">)</span> <span class="o">{</span>
         <span class="n">_sum</span><span class="o">+=</span><span 
class="n">tuple</span><span class="o">.</span><span 
class="na">getInteger</span><span class="o">(</span><span 
class="mi">1</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">finishBatch</span><span class="o">()</span> <span class="o">{</span>
+    <span class="kd">public</span> <span class="kt">void</span> <span 
class="nf">finishBatch</span><span class="o">()</span> <span class="o">{</span>
         <span class="n">Value</span> <span class="n">val</span> <span 
class="o">=</span> <span class="n">DATABASE</span><span class="o">.</span><span 
class="na">get</span><span class="o">(</span><span 
class="n">GLOBAL_COUNT_KEY</span><span class="o">);</span>
         <span class="n">Value</span> <span class="n">newval</span><span 
class="o">;</span>
         <span class="k">if</span><span class="o">(</span><span 
class="n">val</span> <span class="o">==</span> <span class="kc">null</span> 
<span class="o">||</span> <span class="o">!</span><span 
class="n">val</span><span class="o">.</span><span class="na">txid</span><span 
class="o">.</span><span class="na">equals</span><span class="o">(</span><span 
class="n">_attempt</span><span class="o">.</span><span 
class="na">getTransactionId</span><span class="o">()))</span> <span 
class="o">{</span>
@@ -343,7 +343,7 @@
     <span class="o">}</span>
 
     <span class="nd">@Override</span>
-    <span class="kd">public</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="o">{</span>
+    <span class="kd">public</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>
         <span class="n">declarer</span><span class="o">.</span><span 
class="na">declare</span><span class="o">(</span><span class="k">new</span> 
<span class="n">Fields</span><span class="o">(</span><span 
class="s">"id"</span><span class="o">,</span> <span class="s">"sum"</span><span 
class="o">));</span>
     <span class="o">}</span>
 <span class="o">}</span>
@@ -421,7 +421,7 @@
 <li><em>Number of active batches permissible at once:</em> You must set a 
limit to the number of batches that can be processed at once. You configure 
this using the &quot;topology.max.spout.pending&quot; config. If you don&#39;t 
set this config, it will default to 1.</li>
 </ol>
 
-<h2 
id="what-if-you-can-39-t-emit-the-same-batch-of-tuples-for-a-given-transaction-id">What
 if you can&#39;t emit the same batch of tuples for a given transaction id?</h2>
+<h2 
id="what-if-you-cant-emit-the-same-batch-of-tuples-for-a-given-transaction-id">What
 if you can&#39;t emit the same batch of tuples for a given transaction id?</h2>
 
 <p>So far the discussion around transactional topologies has assumed that you 
can always emit the exact same batch of tuples for the same transaction id. So 
what do you do if this is not possible?</p>
 

http://git-wip-us.apache.org/repos/asf/storm-site/blob/a7a19afb/content/releases/0.10.2/Trident-API-Overview.html
----------------------------------------------------------------------
diff --git a/content/releases/0.10.2/Trident-API-Overview.html 
b/content/releases/0.10.2/Trident-API-Overview.html
index f085fc1..f59b9c9 100644
--- a/content/releases/0.10.2/Trident-API-Overview.html
+++ b/content/releases/0.10.2/Trident-API-Overview.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>
@@ -180,7 +180,7 @@
 
 <p>A function takes in a set of input fields and emits zero or more tuples as 
output. The fields of the output tuple are appended to the original input tuple 
in the stream. If a function emits no tuples, the original input tuple is 
filtered out. Otherwise, the input tuple is duplicated for each output tuple. 
Suppose you have this function:</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">MyFunction</span> <span class="kd">extends</span> <span 
class="n">BaseFunction</span> <span class="o">{</span>
-    <span class="kd">public</span> <span class="kt">void</span> <span 
class="n">execute</span><span class="o">(</span><span 
class="n">TridentTuple</span> <span class="n">tuple</span><span 
class="o">,</span> <span class="n">TridentCollector</span> <span 
class="n">collector</span><span class="o">)</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">TridentTuple</span> <span class="n">tuple</span><span 
class="o">,</span> <span class="n">TridentCollector</span> <span 
class="n">collector</span><span class="o">)</span> <span class="o">{</span>
         <span class="k">for</span><span class="o">(</span><span 
class="kt">int</span> <span class="n">i</span><span class="o">=</span><span 
class="mi">0</span><span class="o">;</span> <span class="n">i</span> <span 
class="o">&lt;</span> <span class="n">tuple</span><span class="o">.</span><span 
class="na">getInteger</span><span class="o">(</span><span 
class="mi">0</span><span class="o">);</span> <span class="n">i</span><span 
class="o">++)</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="k">new</span> <span 
class="n">Values</span><span class="o">(</span><span class="n">i</span><span 
class="o">));</span>
         <span class="o">}</span>
@@ -204,7 +204,7 @@
 
 <p>Filters take in a tuple as input and decide whether or not to keep that 
tuple or not. Suppose you had this filter:</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">MyFilter</span> <span class="kd">extends</span> <span 
class="n">BaseFilter</span> <span class="o">{</span>
-    <span class="kd">public</span> <span class="kt">boolean</span> <span 
class="n">isKeep</span><span class="o">(</span><span 
class="n">TridentTuple</span> <span class="n">tuple</span><span 
class="o">)</span> <span class="o">{</span>
+    <span class="kd">public</span> <span class="kt">boolean</span> <span 
class="nf">isKeep</span><span class="o">(</span><span 
class="n">TridentTuple</span> <span class="n">tuple</span><span 
class="o">)</span> <span class="o">{</span>
         <span class="k">return</span> <span class="n">tuple</span><span 
class="o">.</span><span class="na">getInteger</span><span 
class="o">(</span><span class="mi">0</span><span class="o">)</span> <span 
class="o">==</span> <span class="mi">1</span> <span class="o">&amp;&amp;</span> 
<span class="n">tuple</span><span class="o">.</span><span 
class="na">getInteger</span><span class="o">(</span><span 
class="mi">1</span><span class="o">)</span> <span class="o">==</span> <span 
class="mi">2</span><span class="o">;</span>
     <span class="o">}</span>
 <span class="o">}</span>
@@ -229,8 +229,8 @@ can be used to apply a one-one transformation to the 
tuples.</p>
 you could define a mapping function as follows,</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">UpperCase</span> <span class="kd">extends</span> <span 
class="n">MapFunction</span> <span class="o">{</span>
  <span class="nd">@Override</span>
- <span class="kd">public</span> <span class="n">Values</span> <span 
class="n">execute</span><span class="o">(</span><span 
class="n">TridentTuple</span> <span class="n">input</span><span 
class="o">)</span> <span class="o">{</span>
-   <span class="k">return</span> <span class="k">new</span> <span 
class="n">Values</span><span class="o">(</span><span 
class="n">input</span><span class="o">.</span><span 
class="na">getString</span><span class="o">(</span><span 
class="mi">0</span><span class="o">).</span><span 
class="na">toUpperCase</span><span class="o">());</span>
+ <span class="kd">public</span> <span class="n">Values</span> <span 
class="nf">execute</span><span class="o">(</span><span 
class="n">TridentTuple</span> <span class="n">input</span><span 
class="o">)</span> <span class="o">{</span>
+   <span class="k">return</span> <span class="k">new</span> <span 
class="nf">Values</span><span class="o">(</span><span 
class="n">input</span><span class="o">.</span><span 
class="na">getString</span><span class="o">(</span><span 
class="mi">0</span><span class="o">).</span><span 
class="na">toUpperCase</span><span class="o">());</span>
  <span class="o">}</span>
 <span class="o">}</span>
 </code></pre></div>
@@ -244,7 +244,7 @@ and then flattening the resulting elements into a new 
stream.</p>
 you could define a flatMap function as follows,</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">Split</span> <span class="kd">extends</span> <span 
class="n">FlatMapFunction</span> <span class="o">{</span>
   <span class="nd">@Override</span>
-  <span class="kd">public</span> <span class="n">Iterable</span><span 
class="o">&lt;</span><span class="n">Values</span><span class="o">&gt;</span> 
<span class="n">execute</span><span class="o">(</span><span 
class="n">TridentTuple</span> <span class="n">input</span><span 
class="o">)</span> <span class="o">{</span>
+  <span class="kd">public</span> <span class="n">Iterable</span><span 
class="o">&lt;</span><span class="n">Values</span><span class="o">&gt;</span> 
<span class="nf">execute</span><span class="o">(</span><span 
class="n">TridentTuple</span> <span class="n">input</span><span 
class="o">)</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">valuesList</span> <span class="o">=</span> <span class="k">new</span> 
<span class="n">ArrayList</span><span class="o">&lt;&gt;();</span>
     <span class="k">for</span> <span class="o">(</span><span 
class="n">String</span> <span class="n">word</span> <span class="o">:</span> 
<span class="n">input</span><span class="o">.</span><span 
class="na">getString</span><span class="o">(</span><span 
class="mi">0</span><span class="o">).</span><span class="na">split</span><span 
class="o">(</span><span class="s">" "</span><span class="o">))</span> <span 
class="o">{</span>
       <span class="n">valuesList</span><span class="o">.</span><span 
class="na">add</span><span class="o">(</span><span class="k">new</span> <span 
class="n">Values</span><span class="o">(</span><span class="n">word</span><span 
class="o">));</span>
@@ -376,8 +376,8 @@ Partition 2:
 </code></pre></div>
 <p>You can look at other <code>max</code> and <code>maxBy</code> functions on 
Stream</p>
 <div class="highlight"><pre><code class="language-java" data-lang="java">
-      <span class="kd">public</span> <span class="o">&lt;</span><span 
class="n">T</span><span class="o">&gt;</span> <span class="n">Stream</span> 
<span class="n">maxBy</span><span class="o">(</span><span 
class="n">String</span> <span class="n">inputFieldName</span><span 
class="o">,</span> <span class="n">Comparator</span><span 
class="o">&lt;</span><span class="n">T</span><span class="o">&gt;</span> <span 
class="n">comparator</span><span class="o">)</span> 
-      <span class="kd">public</span> <span class="n">Stream</span> <span 
class="n">max</span><span class="o">(</span><span 
class="n">Comparator</span><span class="o">&lt;</span><span 
class="n">TridentTuple</span><span class="o">&gt;</span> <span 
class="n">comparator</span><span class="o">)</span> 
+      <span class="kd">public</span> <span class="o">&lt;</span><span 
class="n">T</span><span class="o">&gt;</span> <span class="n">Stream</span> 
<span class="nf">maxBy</span><span class="o">(</span><span 
class="n">String</span> <span class="n">inputFieldName</span><span 
class="o">,</span> <span class="n">Comparator</span><span 
class="o">&lt;</span><span class="n">T</span><span class="o">&gt;</span> <span 
class="n">comparator</span><span class="o">)</span> 
+      <span class="kd">public</span> <span class="n">Stream</span> <span 
class="nf">max</span><span class="o">(</span><span 
class="n">Comparator</span><span class="o">&lt;</span><span 
class="n">TridentTuple</span><span class="o">&gt;</span> <span 
class="n">comparator</span><span class="o">)</span> 
 
 </code></pre></div>
 <p>Below example shows how these APIs can be used to find maximum using 
respective Comparators on a tuple.</p>
@@ -434,22 +434,22 @@ Partition 2:
 
 <p>Here&#39;s the interface for CombinerAggregator:</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">CombinerAggregator</span><span class="o">&lt;</span><span 
class="n">T</span><span class="o">&gt;</span> <span class="kd">extends</span> 
<span class="n">Serializable</span> <span class="o">{</span>
-    <span class="n">T</span> <span class="n">init</span><span 
class="o">(</span><span class="n">TridentTuple</span> <span 
class="n">tuple</span><span class="o">);</span>
-    <span class="n">T</span> <span class="n">combine</span><span 
class="o">(</span><span class="n">T</span> <span class="n">val1</span><span 
class="o">,</span> <span class="n">T</span> <span class="n">val2</span><span 
class="o">);</span>
-    <span class="n">T</span> <span class="n">zero</span><span 
class="o">();</span>
+    <span class="n">T</span> <span class="nf">init</span><span 
class="o">(</span><span class="n">TridentTuple</span> <span 
class="n">tuple</span><span class="o">);</span>
+    <span class="n">T</span> <span class="nf">combine</span><span 
class="o">(</span><span class="n">T</span> <span class="n">val1</span><span 
class="o">,</span> <span class="n">T</span> <span class="n">val2</span><span 
class="o">);</span>
+    <span class="n">T</span> <span class="nf">zero</span><span 
class="o">();</span>
 <span class="o">}</span>
 </code></pre></div>
 <p>A CombinerAggregator returns a single tuple with a single field as output. 
CombinerAggregators run the init function on each input tuple and use the 
combine function to combine values until there&#39;s only one value left. If 
there&#39;s no tuples in the partition, the CombinerAggregator emits the output 
of the zero function. For example, here&#39;s the implementation of Count:</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">Count</span> <span class="kd">implements</span> <span 
class="n">CombinerAggregator</span><span class="o">&lt;</span><span 
class="n">Long</span><span class="o">&gt;</span> <span class="o">{</span>
-    <span class="kd">public</span> <span class="n">Long</span> <span 
class="n">init</span><span class="o">(</span><span 
class="n">TridentTuple</span> <span class="n">tuple</span><span 
class="o">)</span> <span class="o">{</span>
+    <span class="kd">public</span> <span class="n">Long</span> <span 
class="nf">init</span><span class="o">(</span><span 
class="n">TridentTuple</span> <span class="n">tuple</span><span 
class="o">)</span> <span class="o">{</span>
         <span class="k">return</span> <span class="mi">1L</span><span 
class="o">;</span>
     <span class="o">}</span>
 
-    <span class="kd">public</span> <span class="n">Long</span> <span 
class="n">combine</span><span class="o">(</span><span class="n">Long</span> 
<span class="n">val1</span><span class="o">,</span> <span class="n">Long</span> 
<span class="n">val2</span><span class="o">)</span> <span class="o">{</span>
+    <span class="kd">public</span> <span class="n">Long</span> <span 
class="nf">combine</span><span class="o">(</span><span class="n">Long</span> 
<span class="n">val1</span><span class="o">,</span> <span class="n">Long</span> 
<span class="n">val2</span><span class="o">)</span> <span class="o">{</span>
         <span class="k">return</span> <span class="n">val1</span> <span 
class="o">+</span> <span class="n">val2</span><span class="o">;</span>
     <span class="o">}</span>
 
-    <span class="kd">public</span> <span class="n">Long</span> <span 
class="n">zero</span><span class="o">()</span> <span class="o">{</span>
+    <span class="kd">public</span> <span class="n">Long</span> <span 
class="nf">zero</span><span class="o">()</span> <span class="o">{</span>
         <span class="k">return</span> <span class="mi">0L</span><span 
class="o">;</span>
     <span class="o">}</span>
 <span class="o">}</span>
@@ -458,17 +458,17 @@ Partition 2:
 
 <p>A ReducerAggregator has the following 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">ReducerAggregator</span><span class="o">&lt;</span><span 
class="n">T</span><span class="o">&gt;</span> <span class="kd">extends</span> 
<span class="n">Serializable</span> <span class="o">{</span>
-    <span class="n">T</span> <span class="n">init</span><span 
class="o">();</span>
-    <span class="n">T</span> <span class="n">reduce</span><span 
class="o">(</span><span class="n">T</span> <span class="n">curr</span><span 
class="o">,</span> <span class="n">TridentTuple</span> <span 
class="n">tuple</span><span class="o">);</span>
+    <span class="n">T</span> <span class="nf">init</span><span 
class="o">();</span>
+    <span class="n">T</span> <span class="nf">reduce</span><span 
class="o">(</span><span class="n">T</span> <span class="n">curr</span><span 
class="o">,</span> <span class="n">TridentTuple</span> <span 
class="n">tuple</span><span class="o">);</span>
 <span class="o">}</span>
 </code></pre></div>
 <p>A ReducerAggregator produces an initial value with init, and then it 
iterates on that value for each input tuple to produce a single tuple with a 
single value as output. For example, here&#39;s how you would define Count as a 
ReducerAggregator:</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">Count</span> <span class="kd">implements</span> <span 
class="n">ReducerAggregator</span><span class="o">&lt;</span><span 
class="n">Long</span><span class="o">&gt;</span> <span class="o">{</span>
-    <span class="kd">public</span> <span class="n">Long</span> <span 
class="n">init</span><span class="o">()</span> <span class="o">{</span>
+    <span class="kd">public</span> <span class="n">Long</span> <span 
class="nf">init</span><span class="o">()</span> <span class="o">{</span>
         <span class="k">return</span> <span class="mi">0L</span><span 
class="o">;</span>
     <span class="o">}</span>
 
-    <span class="kd">public</span> <span class="n">Long</span> <span 
class="n">reduce</span><span class="o">(</span><span class="n">Long</span> 
<span class="n">curr</span><span class="o">,</span> <span 
class="n">TridentTuple</span> <span class="n">tuple</span><span 
class="o">)</span> <span class="o">{</span>
+    <span class="kd">public</span> <span class="n">Long</span> <span 
class="nf">reduce</span><span class="o">(</span><span class="n">Long</span> 
<span class="n">curr</span><span class="o">,</span> <span 
class="n">TridentTuple</span> <span class="n">tuple</span><span 
class="o">)</span> <span class="o">{</span>
         <span class="k">return</span> <span class="n">curr</span> <span 
class="o">+</span> <span class="mi">1</span><span class="o">;</span>
     <span class="o">}</span>
 <span class="o">}</span>
@@ -477,9 +477,9 @@ Partition 2:
 
 <p>The most general interface for performing aggregations is Aggregator, which 
looks like this:</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">Aggregator</span><span class="o">&lt;</span><span 
class="n">T</span><span class="o">&gt;</span> <span class="kd">extends</span> 
<span class="n">Operation</span> <span class="o">{</span>
-    <span class="n">T</span> <span class="n">init</span><span 
class="o">(</span><span class="n">Object</span> <span 
class="n">batchId</span><span class="o">,</span> <span 
class="n">TridentCollector</span> <span class="n">collector</span><span 
class="o">);</span>
-    <span class="kt">void</span> <span class="n">aggregate</span><span 
class="o">(</span><span class="n">T</span> <span class="n">state</span><span 
class="o">,</span> <span class="n">TridentTuple</span> <span 
class="n">tuple</span><span class="o">,</span> <span 
class="n">TridentCollector</span> <span class="n">collector</span><span 
class="o">);</span>
-    <span class="kt">void</span> <span class="n">complete</span><span 
class="o">(</span><span class="n">T</span> <span class="n">state</span><span 
class="o">,</span> <span class="n">TridentCollector</span> <span 
class="n">collector</span><span class="o">);</span>
+    <span class="n">T</span> <span class="nf">init</span><span 
class="o">(</span><span class="n">Object</span> <span 
class="n">batchId</span><span class="o">,</span> <span 
class="n">TridentCollector</span> <span class="n">collector</span><span 
class="o">);</span>
+    <span class="kt">void</span> <span class="nf">aggregate</span><span 
class="o">(</span><span class="n">T</span> <span class="n">state</span><span 
class="o">,</span> <span class="n">TridentTuple</span> <span 
class="n">tuple</span><span class="o">,</span> <span 
class="n">TridentCollector</span> <span class="n">collector</span><span 
class="o">);</span>
+    <span class="kt">void</span> <span class="nf">complete</span><span 
class="o">(</span><span class="n">T</span> <span class="n">state</span><span 
class="o">,</span> <span class="n">TridentCollector</span> <span 
class="n">collector</span><span class="o">);</span>
 <span class="o">}</span>
 </code></pre></div>
 <p>Aggregators can emit any number of tuples with any number of fields. They 
can emit tuples at any point during execution. Aggregators execute in the 
following way:</p>
@@ -496,15 +496,15 @@ Partition 2:
         <span class="kt">long</span> <span class="n">count</span> <span 
class="o">=</span> <span class="mi">0</span><span class="o">;</span>
     <span class="o">}</span>
 
-    <span class="kd">public</span> <span class="n">CountState</span> <span 
class="n">init</span><span class="o">(</span><span class="n">Object</span> 
<span class="n">batchId</span><span class="o">,</span> <span 
class="n">TridentCollector</span> <span class="n">collector</span><span 
class="o">)</span> <span class="o">{</span>
-        <span class="k">return</span> <span class="k">new</span> <span 
class="n">CountState</span><span class="o">();</span>
+    <span class="kd">public</span> <span class="n">CountState</span> <span 
class="nf">init</span><span class="o">(</span><span class="n">Object</span> 
<span class="n">batchId</span><span class="o">,</span> <span 
class="n">TridentCollector</span> <span class="n">collector</span><span 
class="o">)</span> <span class="o">{</span>
+        <span class="k">return</span> <span class="k">new</span> <span 
class="nf">CountState</span><span class="o">();</span>
     <span class="o">}</span>
 
-    <span class="kd">public</span> <span class="kt">void</span> <span 
class="n">aggregate</span><span class="o">(</span><span 
class="n">CountState</span> <span class="n">state</span><span 
class="o">,</span> <span class="n">TridentTuple</span> <span 
class="n">tuple</span><span class="o">,</span> <span 
class="n">TridentCollector</span> <span class="n">collector</span><span 
class="o">)</span> <span class="o">{</span>
+    <span class="kd">public</span> <span class="kt">void</span> <span 
class="nf">aggregate</span><span class="o">(</span><span 
class="n">CountState</span> <span class="n">state</span><span 
class="o">,</span> <span class="n">TridentTuple</span> <span 
class="n">tuple</span><span class="o">,</span> <span 
class="n">TridentCollector</span> <span class="n">collector</span><span 
class="o">)</span> <span class="o">{</span>
         <span class="n">state</span><span class="o">.</span><span 
class="na">count</span><span class="o">+=</span><span class="mi">1</span><span 
class="o">;</span>
     <span class="o">}</span>
 
-    <span class="kd">public</span> <span class="kt">void</span> <span 
class="n">complete</span><span class="o">(</span><span 
class="n">CountState</span> <span class="n">state</span><span 
class="o">,</span> <span class="n">TridentCollector</span> <span 
class="n">collector</span><span class="o">)</span> <span class="o">{</span>
+    <span class="kd">public</span> <span class="kt">void</span> <span 
class="nf">complete</span><span class="o">(</span><span 
class="n">CountState</span> <span class="n">state</span><span 
class="o">,</span> <span class="n">TridentCollector</span> <span 
class="n">collector</span><span class="o">)</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="k">new</span> <span 
class="n">Values</span><span class="o">(</span><span 
class="n">state</span><span class="o">.</span><span 
class="na">count</span><span class="o">));</span>
     <span class="o">}</span>
 <span class="o">}</span>

http://git-wip-us.apache.org/repos/asf/storm-site/blob/a7a19afb/content/releases/0.10.2/Trident-spouts.html
----------------------------------------------------------------------
diff --git a/content/releases/0.10.2/Trident-spouts.html 
b/content/releases/0.10.2/Trident-spouts.html
index f9bead0..26b6d9a 100644
--- a/content/releases/0.10.2/Trident-spouts.html
+++ b/content/releases/0.10.2/Trident-spouts.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