http://git-wip-us.apache.org/repos/asf/storm-site/blob/0183bf7e/content/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/cassandra/Murmur3StreamGrouping.html ---------------------------------------------------------------------- diff --git a/content/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/cassandra/Murmur3StreamGrouping.html b/content/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/cassandra/Murmur3StreamGrouping.html index c637548..a0f7205 100644 --- a/content/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/cassandra/Murmur3StreamGrouping.html +++ b/content/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/cassandra/Murmur3StreamGrouping.html @@ -97,7 +97,7 @@ var activeTableTab = "activeTableTab"; </div> <div class="contentContainer"> <ul class="inheritance"> -<li><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">java.lang.Object</a></li> +<li><a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">java.lang.Object</a></li> <li> <ul class="inheritance"> <li>org.apache.storm.cassandra.Murmur3StreamGrouping</li> @@ -109,12 +109,12 @@ var activeTableTab = "activeTableTab"; <li class="blockList"> <dl> <dt>All Implemented Interfaces:</dt> -<dd><a href="http://docs.oracle.com/javase/7/docs/api/java/io/Serializable.html?is-external=true"; title="class or interface in java.io">Serializable</a>, <a href="../../../../org/apache/storm/grouping/CustomStreamGrouping.html" title="interface in org.apache.storm.grouping">CustomStreamGrouping</a></dd> +<dd><a href="http://docs.oracle.com/javase/8/docs/api/java/io/Serializable.html?is-external=true"; title="class or interface in java.io">Serializable</a>, <a href="../../../../org/apache/storm/grouping/CustomStreamGrouping.html" title="interface in org.apache.storm.grouping">CustomStreamGrouping</a></dd> </dl> <hr> <br> <pre>public class <span class="typeNameLabel">Murmur3StreamGrouping</span> -extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a> +extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a> implements <a href="../../../../org/apache/storm/grouping/CustomStreamGrouping.html" title="interface in org.apache.storm.grouping">CustomStreamGrouping</a></pre> <div class="block"><p>Simple <a href="../../../../org/apache/storm/grouping/CustomStreamGrouping.html" title="interface in org.apache.storm.grouping"><code>CustomStreamGrouping</code></a> that uses Murmur3 algorithm to choose the target task of a tuple.</p><p>This stream grouping may be used to optimise writes to Apache Cassandra.</p></div> <dl> @@ -139,12 +139,12 @@ implements <a href="../../../../org/apache/storm/grouping/CustomStreamGrouping.h <th class="colOne" scope="col">Constructor and Description</th> </tr> <tr class="altColor"> -<td class="colOne"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cassandra/Murmur3StreamGrouping.html#Murmur3StreamGrouping-java.util.List-">Murmur3StreamGrouping</a></span>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>> partitionKeyNames)</code> +<td class="colOne"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cassandra/Murmur3StreamGrouping.html#Murmur3StreamGrouping-java.util.List-">Murmur3StreamGrouping</a></span>(<a href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>> partitionKeyNames)</code> <div class="block">Creates a new <a href="../../../../org/apache/storm/cassandra/Murmur3StreamGrouping.html" title="class in org.apache.storm.cassandra"><code>Murmur3StreamGrouping</code></a> instance.</div> </td> </tr> <tr class="rowColor"> -<td class="colOne"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cassandra/Murmur3StreamGrouping.html#Murmur3StreamGrouping-java.lang.String...-">Murmur3StreamGrouping</a></span>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>... partitionKeyNames)</code> +<td class="colOne"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cassandra/Murmur3StreamGrouping.html#Murmur3StreamGrouping-java.lang.String...-">Murmur3StreamGrouping</a></span>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>... partitionKeyNames)</code> <div class="block">Creates a new <a href="../../../../org/apache/storm/cassandra/Murmur3StreamGrouping.html" title="class in org.apache.storm.cassandra"><code>Murmur3StreamGrouping</code></a> instance.</div> </td> </tr> @@ -164,15 +164,15 @@ implements <a href="../../../../org/apache/storm/grouping/CustomStreamGrouping.h <th class="colLast" scope="col">Method and Description</th> </tr> <tr id="i0" class="altColor"> -<td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Integer.html?is-external=true"; title="class or interface in java.lang">Integer</a>></code></td> +<td class="colFirst"><code><a href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Integer.html?is-external=true"; title="class or interface in java.lang">Integer</a>></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cassandra/Murmur3StreamGrouping.html#chooseTasks-int-java.util.List-">chooseTasks</a></span>(int taskId, - <a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a>> values)</code> + <a href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a>> values)</code> <div class="block">This function implements a custom stream grouping.</div> </td> </tr> <tr id="i1" class="rowColor"> <td class="colFirst"><code>static long</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cassandra/Murmur3StreamGrouping.html#hashes-java.util.List-">hashes</a></span>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a>> values)</code> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cassandra/Murmur3StreamGrouping.html#hashes-java.util.List-">hashes</a></span>(<a href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a>> values)</code> <div class="block">Computes the murmur3 hash for the specified values.</div> </td> </tr> @@ -180,7 +180,7 @@ implements <a href="../../../../org/apache/storm/grouping/CustomStreamGrouping.h <td class="colFirst"><code>void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cassandra/Murmur3StreamGrouping.html#prepare-org.apache.storm.task.WorkerTopologyContext-org.apache.storm.generated.GlobalStreamId-java.util.List-">prepare</a></span>(<a href="../../../../org/apache/storm/task/WorkerTopologyContext.html" title="class in org.apache.storm.task">WorkerTopologyContext</a> context, <a href="../../../../org/apache/storm/generated/GlobalStreamId.html" title="class in org.apache.storm.generated">GlobalStreamId</a> stream, - <a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Integer.html?is-external=true"; title="class or interface in java.lang">Integer</a>> targetTasks)</code> + <a href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Integer.html?is-external=true"; title="class or interface in java.lang">Integer</a>> targetTasks)</code> <div class="block">Tells the stream grouping at runtime the tasks in the target bolt.</div> </td> </tr> @@ -189,8 +189,8 @@ implements <a href="../../../../org/apache/storm/grouping/CustomStreamGrouping.h <li class="blockList"><a name="methods.inherited.from.class.java.lang.Object"> <!-- --> </a> -<h3>Methods inherited from class java.lang.<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a></h3> -<code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#clone--"; title="class or interface in java.lang">clone</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#equals-java.lang.Object-"; title="class or interface in java.lang">equals</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#finalize--"; title="class or interface in java.lang">finalize</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#getClass--"; title="class or interface in java.lang">getClass</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#hashCode--"; title="class or interface in java.lang">hashCode</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#notify--"; title="class or interface in java.lang">notify</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang /Object.html?is-external=true#notifyAll--" title="class or interface in java.lang">notifyAll</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#toString--"; title="class or interface in java.lang">toString</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#wait--"; title="class or interface in java.lang">wait</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#wait-long-"; title="class or interface in java.lang">wait</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#wait-long-int-"; title="class or interface in java.lang">wait</a></code></li> +<h3>Methods inherited from class java.lang.<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a></h3> +<code><a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#clone--"; title="class or interface in java.lang">clone</a>, <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#equals-java.lang.Object-"; title="class or interface in java.lang">equals</a>, <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#finalize--"; title="class or interface in java.lang">finalize</a>, <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#getClass--"; title="class or interface in java.lang">getClass</a>, <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#hashCode--"; title="class or interface in java.lang">hashCode</a>, <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#notify--"; title="class or interface in java.lang">notify</a>, <a href="http://docs.oracle.com/javase/8/docs/api/java/lang /Object.html?is-external=true#notifyAll--" title="class or interface in java.lang">notifyAll</a>, <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#toString--"; title="class or interface in java.lang">toString</a>, <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#wait--"; title="class or interface in java.lang">wait</a>, <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#wait-long-"; title="class or interface in java.lang">wait</a>, <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#wait-long-int-"; title="class or interface in java.lang">wait</a></code></li> </ul> </li> </ul> @@ -212,7 +212,7 @@ implements <a href="../../../../org/apache/storm/grouping/CustomStreamGrouping.h <ul class="blockList"> <li class="blockList"> <h4>Murmur3StreamGrouping</h4> -<pre>public Murmur3StreamGrouping(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>... partitionKeyNames)</pre> +<pre>public Murmur3StreamGrouping(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>... partitionKeyNames)</pre> <div class="block"><p>Creates a new <a href="../../../../org/apache/storm/cassandra/Murmur3StreamGrouping.html" title="class in org.apache.storm.cassandra"><code>Murmur3StreamGrouping</code></a> instance.</p></div> <dl> <dt><span class="paramLabel">Parameters:</span></dt> @@ -226,7 +226,7 @@ implements <a href="../../../../org/apache/storm/grouping/CustomStreamGrouping.h <ul class="blockListLast"> <li class="blockList"> <h4>Murmur3StreamGrouping</h4> -<pre>public Murmur3StreamGrouping(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>> partitionKeyNames)</pre> +<pre>public Murmur3StreamGrouping(<a href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>> partitionKeyNames)</pre> <div class="block"><p>Creates a new <a href="../../../../org/apache/storm/cassandra/Murmur3StreamGrouping.html" title="class in org.apache.storm.cassandra"><code>Murmur3StreamGrouping</code></a> instance.</p></div> <dl> <dt><span class="paramLabel">Parameters:</span></dt> @@ -242,6 +242,25 @@ implements <a href="../../../../org/apache/storm/grouping/CustomStreamGrouping.h <!-- --> </a> <h3>Method Detail</h3> +<a name="hashes-java.util.List-"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>hashes</h4> +<pre>public static long hashes(<a href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a>> values) + throws <a href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> +<div class="block"><p>Computes the murmur3 hash for the specified values. <a href="http://stackoverflow.com/questions/27212797/cassandra-hashing-algorithm-with-composite-keys";>http://stackoverflow.com/questions/27212797/cassandra-hashing-algorithm-with-composite-keys</a> <a href="https://github.com/apache/cassandra/blob/trunk/src/java/org/apache/cassandra/db/marshal/CompositeType.java";>https://github.com/apache/cassandra/blob/trunk/src/java/org/apache/cassandra/db/marshal/CompositeType.java</a></p></div> +<dl> +<dt><span class="paramLabel">Parameters:</span></dt> +<dd><code>values</code> - the fields which are part of the (compose) partition key.</dd> +<dt><span class="returnLabel">Returns:</span></dt> +<dd>the computed hash for input values.</dd> +<dt><span class="throwsLabel">Throws:</span></dt> +<dd><code><a href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></code></dd> +</dl> +</li> +</ul> <a name="prepare-org.apache.storm.task.WorkerTopologyContext-org.apache.storm.generated.GlobalStreamId-java.util.List-"> <!-- --> </a> @@ -250,7 +269,7 @@ implements <a href="../../../../org/apache/storm/grouping/CustomStreamGrouping.h <h4>prepare</h4> <pre>public void prepare(<a href="../../../../org/apache/storm/task/WorkerTopologyContext.html" title="class in org.apache.storm.task">WorkerTopologyContext</a> context, <a href="../../../../org/apache/storm/generated/GlobalStreamId.html" title="class in org.apache.storm.generated">GlobalStreamId</a> stream, - <a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Integer.html?is-external=true"; title="class or interface in java.lang">Integer</a>> targetTasks)</pre> + <a href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Integer.html?is-external=true"; title="class or interface in java.lang">Integer</a>> targetTasks)</pre> <div class="block"><p><p>Tells the stream grouping at runtime the tasks in the target bolt. This information should be used in chooseTasks to determine the target tasks.</p><p>It also tells the grouping the metadata on the stream this grouping will be used on.</p></p></div> <dl> <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> @@ -261,11 +280,11 @@ implements <a href="../../../../org/apache/storm/grouping/CustomStreamGrouping.h <a name="chooseTasks-int-java.util.List-"> <!-- --> </a> -<ul class="blockList"> +<ul class="blockListLast"> <li class="blockList"> <h4>chooseTasks</h4> -<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Integer.html?is-external=true"; title="class or interface in java.lang">Integer</a>> chooseTasks(int taskId, - <a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a>> values)</pre> +<pre>public <a href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Integer.html?is-external=true"; title="class or interface in java.lang">Integer</a>> chooseTasks(int taskId, + <a href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a>> values)</pre> <div class="block"><p><p>This function implements a custom stream grouping. It takes in as input the number of tasks in the target bolt in prepare and returns the tasks to send the tuples to.</p></p></div> <dl> <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> @@ -274,25 +293,6 @@ implements <a href="../../../../org/apache/storm/grouping/CustomStreamGrouping.h </dl> </li> </ul> -<a name="hashes-java.util.List-"> -<!-- --> -</a> -<ul class="blockListLast"> -<li class="blockList"> -<h4>hashes</h4> -<pre>public static long hashes(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a>> values) - throws <a href="http://docs.oracle.com/javase/7/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> -<div class="block"><p>Computes the murmur3 hash for the specified values. <a href="http://stackoverflow.com/questions/27212797/cassandra-hashing-algorithm-with-composite-keys";>http://stackoverflow.com/questions/27212797/cassandra-hashing-algorithm-with-composite-keys</a> <a href="https://github.com/apache/cassandra/blob/trunk/src/java/org/apache/cassandra/db/marshal/CompositeType.java";>https://github.com/apache/cassandra/blob/trunk/src/java/org/apache/cassandra/db/marshal/CompositeType.java</a></p></div> -<dl> -<dt><span class="paramLabel">Parameters:</span></dt> -<dd><code>values</code> - the fields which are part of the (compose) partition key.</dd> -<dt><span class="returnLabel">Returns:</span></dt> -<dd>the computed hash for input values.</dd> -<dt><span class="throwsLabel">Throws:</span></dt> -<dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></code></dd> -</dl> -</li> -</ul> </li> </ul> </li> @@ -366,6 +366,6 @@ hljs.initHighlightingOnLoad(); <!-- --> </a></div> <!-- ======== END OF BOTTOM NAVBAR ======= --> -<p class="legalCopy"><small>Copyright © 2016 <a href="http://www.apache.org/";>The Apache Software Foundation</a>. All Rights Reserved.</small></p> +<p class="legalCopy"><small>Copyright © 2018 <a href="https://www.apache.org/";>The Apache Software Foundation</a>. All rights reserved.</small></p> </body> </html>
http://git-wip-us.apache.org/repos/asf/storm-site/blob/0183bf7e/content/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/cassandra/bolt/BaseCassandraBolt.html ---------------------------------------------------------------------- diff --git a/content/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/cassandra/bolt/BaseCassandraBolt.html b/content/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/cassandra/bolt/BaseCassandraBolt.html index e198625..b3dc60a 100644 --- a/content/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/cassandra/bolt/BaseCassandraBolt.html +++ b/content/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/cassandra/bolt/BaseCassandraBolt.html @@ -18,7 +18,7 @@ catch(err) { } //--> -var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":6,"i5":10,"i6":10,"i7":10,"i8":6,"i9":10,"i10":6,"i11":10,"i12":10,"i13":10}; +var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":6,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10}; var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],4:["t3","Abstract Methods"],8:["t4","Concrete Methods"]}; var altColor = "altColor"; var rowColor = "rowColor"; @@ -97,7 +97,7 @@ var activeTableTab = "activeTableTab"; </div> <div class="contentContainer"> <ul class="inheritance"> -<li><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">java.lang.Object</a></li> +<li><a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">java.lang.Object</a></li> <li> <ul class="inheritance"> <li><a href="../../../../../org/apache/storm/topology/base/BaseComponent.html" title="class in org.apache.storm.topology.base">org.apache.storm.topology.base.BaseComponent</a></li> @@ -106,6 +106,9 @@ var activeTableTab = "activeTableTab"; <li><a href="../../../../../org/apache/storm/topology/base/BaseRichBolt.html" title="class in org.apache.storm.topology.base">org.apache.storm.topology.base.BaseRichBolt</a></li> <li> <ul class="inheritance"> +<li><a href="../../../../../org/apache/storm/topology/base/BaseTickTupleAwareRichBolt.html" title="class in org.apache.storm.topology.base">org.apache.storm.topology.base.BaseTickTupleAwareRichBolt</a></li> +<li> +<ul class="inheritance"> <li>org.apache.storm.cassandra.bolt.BaseCassandraBolt<T></li> </ul> </li> @@ -114,12 +117,14 @@ var activeTableTab = "activeTableTab"; </ul> </li> </ul> +</li> +</ul> <div class="description"> <ul class="blockList"> <li class="blockList"> <dl> <dt>All Implemented Interfaces:</dt> -<dd><a href="http://docs.oracle.com/javase/7/docs/api/java/io/Serializable.html?is-external=true"; title="class or interface in java.io">Serializable</a>, <a href="../../../../../org/apache/storm/task/IBolt.html" title="interface in org.apache.storm.task">IBolt</a>, <a href="../../../../../org/apache/storm/topology/IComponent.html" title="interface in org.apache.storm.topology">IComponent</a>, <a href="../../../../../org/apache/storm/topology/IRichBolt.html" title="interface in org.apache.storm.topology">IRichBolt</a></dd> +<dd><a href="http://docs.oracle.com/javase/8/docs/api/java/io/Serializable.html?is-external=true"; title="class or interface in java.io">Serializable</a>, <a href="../../../../../org/apache/storm/task/IBolt.html" title="interface in org.apache.storm.task">IBolt</a>, <a href="../../../../../org/apache/storm/topology/IComponent.html" title="interface in org.apache.storm.topology">IComponent</a>, <a href="../../../../../org/apache/storm/topology/IRichBolt.html" title="interface in org.apache.storm.topology">IRichBolt</a></dd> </dl> <dl> <dt>Direct Known Subclasses:</dt> @@ -128,8 +133,8 @@ var activeTableTab = "activeTableTab"; <hr> <br> <pre>public abstract class <span class="typeNameLabel">BaseCassandraBolt<T></span> -extends <a href="../../../../../org/apache/storm/topology/base/BaseRichBolt.html" title="class in org.apache.storm.topology.base">BaseRichBolt</a></pre> -<div class="block"><p>A base cassandra bolt.</p><p>Default <a href="../../../../../org/apache/storm/topology/base/BaseRichBolt.html" title="class in org.apache.storm.topology.base"><code>BaseRichBolt</code></a></p></div> +extends <a href="../../../../../org/apache/storm/topology/base/BaseTickTupleAwareRichBolt.html" title="class in org.apache.storm.topology.base">BaseTickTupleAwareRichBolt</a></pre> +<div class="block"><p>A base cassandra bolt.</p><p>Default <a href="../../../../../org/apache/storm/topology/base/BaseTickTupleAwareRichBolt.html" title="class in org.apache.storm.topology.base"><code>BaseTickTupleAwareRichBolt</code></a></p></div> <dl> <dt><span class="seeLabel">See Also:</span></dt> <dd><a href="../../../../../serialized-form.html#org.apache.storm.cassandra.bolt.BaseCassandraBolt">Serialized Form</a></dd> @@ -154,7 +159,7 @@ extends <a href="../../../../../org/apache/storm/topology/base/BaseRichBolt.html </tr> <tr class="altColor"> <td class="colFirst"><code>protected <a href="../../../../../org/apache/storm/cassandra/client/CassandraConf.html" title="class in org.apache.storm.cassandra.client">CassandraConf</a></code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/cassandra/bolt/BaseCassandraBolt.html#cassandraConfConfig">cassandraConfConfig</a></span></code> </td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/cassandra/bolt/BaseCassandraBolt.html#cassandraConf">cassandraConf</a></span></code> </td> </tr> <tr class="rowColor"> <td class="colFirst"><code>protected <a href="../../../../../org/apache/storm/cassandra/client/SimpleClient.html" title="interface in org.apache.storm.cassandra.client">SimpleClient</a></code></td> @@ -173,8 +178,8 @@ extends <a href="../../../../../org/apache/storm/topology/base/BaseRichBolt.html <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/cassandra/bolt/BaseCassandraBolt.html#session">session</a></span></code> </td> </tr> <tr class="rowColor"> -<td class="colFirst"><code>protected <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a></code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/cassandra/bolt/BaseCassandraBolt.html#stormConfig">stormConfig</a></span></code> </td> +<td class="colFirst"><code>protected <a href="http://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a>></code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/cassandra/bolt/BaseCassandraBolt.html#topoConfig">topoConfig</a></span></code> </td> </tr> </table> </li> @@ -243,7 +248,7 @@ extends <a href="../../../../../org/apache/storm/topology/base/BaseRichBolt.html <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/cassandra/bolt/BaseCassandraBolt.html#getAsyncHandler--">getAsyncHandler</a></span>()</code> </td> </tr> <tr id="i5" class="rowColor"> -<td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a>></code></td> +<td class="colFirst"><code><a href="http://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a>></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/cassandra/bolt/BaseCassandraBolt.html#getComponentConfiguration--">getComponentConfiguration</a></span>()</code> <div class="block">Declare configuration specific to this component.</div> </td> @@ -257,45 +262,50 @@ extends <a href="../../../../../org/apache/storm/topology/base/BaseRichBolt.html <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/cassandra/bolt/BaseCassandraBolt.html#getResultHandler--">getResultHandler</a></span>()</code> </td> </tr> <tr id="i8" class="altColor"> -<td class="colFirst"><code>protected abstract void</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/cassandra/bolt/BaseCassandraBolt.html#onTickTuple--">onTickTuple</a></span>()</code> -<div class="block">Calls by an input tick tuple.</div> -</td> -</tr> -<tr id="i9" class="rowColor"> <td class="colFirst"><code>void</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/cassandra/bolt/BaseCassandraBolt.html#prepare-java.util.Map-org.apache.storm.task.TopologyContext-org.apache.storm.task.OutputCollector-">prepare</a></span>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a> stormConfig, +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/cassandra/bolt/BaseCassandraBolt.html#prepare-java.util.Map-org.apache.storm.task.TopologyContext-org.apache.storm.task.OutputCollector-">prepare</a></span>(<a href="http://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a>> topoConfig, <a href="../../../../../org/apache/storm/task/TopologyContext.html" title="class in org.apache.storm.task">TopologyContext</a> topologyContext, <a href="../../../../../org/apache/storm/task/OutputCollector.html" title="class in org.apache.storm.task">OutputCollector</a> outputCollector)</code> <div class="block">Called when a task for this component is initialized within a worker on the cluster.</div> </td> </tr> -<tr id="i10" class="altColor"> -<td class="colFirst"><code>protected abstract void</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/cassandra/bolt/BaseCassandraBolt.html#process-org.apache.storm.tuple.Tuple-">process</a></span>(<a href="../../../../../org/apache/storm/tuple/Tuple.html" title="interface in org.apache.storm.tuple">Tuple</a> input)</code> -<div class="block">Process a single tuple of input.</div> +<tr id="i9" class="rowColor"> +<td class="colFirst"><code><a href="../../../../../org/apache/storm/cassandra/bolt/BaseCassandraBolt.html" title="class in org.apache.storm.cassandra.bolt">BaseCassandraBolt</a></code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/cassandra/bolt/BaseCassandraBolt.html#withCassandraConfig-java.util.Map-">withCassandraConfig</a></span>(<a href="http://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a>> config)</code> +<div class="block">Takes the given <code>config</code> for creating cassandra client.</div> </td> </tr> -<tr id="i11" class="rowColor"> +<tr id="i10" class="altColor"> <td class="colFirst"><code><a href="../../../../../org/apache/storm/cassandra/bolt/BaseCassandraBolt.html" title="class in org.apache.storm.cassandra.bolt">BaseCassandraBolt</a></code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/cassandra/bolt/BaseCassandraBolt.html#withOutputFields-org.apache.storm.tuple.Fields-">withOutputFields</a></span>(<a href="../../../../../org/apache/storm/tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a> fields)</code> </td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/cassandra/bolt/BaseCassandraBolt.html#withOutputFields-org.apache.storm.tuple.Fields-">withOutputFields</a></span>(<a href="../../../../../org/apache/storm/tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a> fields)</code> +<div class="block">Configures this bolt with the given <code>fields</code> as outputfields with stream id as <a href="../../../../../org/apache/storm/utils/Utils.html#DEFAULT_STREAM_ID"><code>Utils.DEFAULT_STREAM_ID</code></a></div> +</td> </tr> -<tr id="i12" class="altColor"> +<tr id="i11" class="rowColor"> <td class="colFirst"><code><a href="../../../../../org/apache/storm/cassandra/bolt/BaseCassandraBolt.html" title="class in org.apache.storm.cassandra.bolt">BaseCassandraBolt</a></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/cassandra/bolt/BaseCassandraBolt.html#withResultHandler-org.apache.storm.cassandra.ExecutionResultHandler-">withResultHandler</a></span>(<a href="../../../../../org/apache/storm/cassandra/ExecutionResultHandler.html" title="interface in org.apache.storm.cassandra">ExecutionResultHandler</a> resultHandler)</code> </td> </tr> -<tr id="i13" class="rowColor"> +<tr id="i12" class="altColor"> <td class="colFirst"><code><a href="../../../../../org/apache/storm/cassandra/bolt/BaseCassandraBolt.html" title="class in org.apache.storm.cassandra.bolt">BaseCassandraBolt</a></code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/cassandra/bolt/BaseCassandraBolt.html#withStreamOutputFields-java.lang.String-org.apache.storm.tuple.Fields-">withStreamOutputFields</a></span>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> stream, - <a href="../../../../../org/apache/storm/tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a> fields)</code> </td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/cassandra/bolt/BaseCassandraBolt.html#withStreamOutputFields-java.lang.String-org.apache.storm.tuple.Fields-">withStreamOutputFields</a></span>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> stream, + <a href="../../../../../org/apache/storm/tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a> fields)</code> +<div class="block">Configures this bolt given <code>fields</code> as outputfields for the given <code>stream</code>.</div> +</td> </tr> </table> <ul class="blockList"> +<li class="blockList"><a name="methods.inherited.from.class.org.apache.storm.topology.base.BaseTickTupleAwareRichBolt"> +<!-- --> +</a> +<h3>Methods inherited from class org.apache.storm.topology.base.<a href="../../../../../org/apache/storm/topology/base/BaseTickTupleAwareRichBolt.html" title="class in org.apache.storm.topology.base">BaseTickTupleAwareRichBolt</a></h3> +<code><a href="../../../../../org/apache/storm/topology/base/BaseTickTupleAwareRichBolt.html#onTickTuple-org.apache.storm.tuple.Tuple-">onTickTuple</a>, <a href="../../../../../org/apache/storm/topology/base/BaseTickTupleAwareRichBolt.html#process-org.apache.storm.tuple.Tuple-">process</a></code></li> +</ul> +<ul class="blockList"> <li class="blockList"><a name="methods.inherited.from.class.java.lang.Object"> <!-- --> </a> -<h3>Methods inherited from class java.lang.<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a></h3> -<code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#clone--"; title="class or interface in java.lang">clone</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#equals-java.lang.Object-"; title="class or interface in java.lang">equals</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#finalize--"; title="class or interface in java.lang">finalize</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#getClass--"; title="class or interface in java.lang">getClass</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#hashCode--"; title="class or interface in java.lang">hashCode</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#notify--"; title="class or interface in java.lang">notify</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang /Object.html?is-external=true#notifyAll--" title="class or interface in java.lang">notifyAll</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#toString--"; title="class or interface in java.lang">toString</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#wait--"; title="class or interface in java.lang">wait</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#wait-long-"; title="class or interface in java.lang">wait</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#wait-long-int-"; title="class or interface in java.lang">wait</a></code></li> +<h3>Methods inherited from class java.lang.<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a></h3> +<code><a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#clone--"; title="class or interface in java.lang">clone</a>, <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#equals-java.lang.Object-"; title="class or interface in java.lang">equals</a>, <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#finalize--"; title="class or interface in java.lang">finalize</a>, <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#getClass--"; title="class or interface in java.lang">getClass</a>, <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#hashCode--"; title="class or interface in java.lang">hashCode</a>, <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#notify--"; title="class or interface in java.lang">notify</a>, <a href="http://docs.oracle.com/javase/8/docs/api/java/lang /Object.html?is-external=true#notifyAll--" title="class or interface in java.lang">notifyAll</a>, <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#toString--"; title="class or interface in java.lang">toString</a>, <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#wait--"; title="class or interface in java.lang">wait</a>, <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#wait-long-"; title="class or interface in java.lang">wait</a>, <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#wait-long-int-"; title="class or interface in java.lang">wait</a></code></li> </ul> </li> </ul> @@ -347,22 +357,22 @@ extends <a href="../../../../../org/apache/storm/topology/base/BaseRichBolt.html <pre>protected com.datastax.driver.core.Session session</pre> </li> </ul> -<a name="stormConfig"> +<a name="topoConfig"> <!-- --> </a> <ul class="blockList"> <li class="blockList"> -<h4>stormConfig</h4> -<pre>protected <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a> stormConfig</pre> +<h4>topoConfig</h4> +<pre>protected <a href="http://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a>> topoConfig</pre> </li> </ul> -<a name="cassandraConfConfig"> +<a name="cassandraConf"> <!-- --> </a> <ul class="blockListLast"> <li class="blockList"> -<h4>cassandraConfConfig</h4> -<pre>protected <a href="../../../../../org/apache/storm/cassandra/client/CassandraConf.html" title="class in org.apache.storm.cassandra.client">CassandraConf</a> cassandraConfConfig</pre> +<h4>cassandraConf</h4> +<pre>protected <a href="../../../../../org/apache/storm/cassandra/client/CassandraConf.html" title="class in org.apache.storm.cassandra.client">CassandraConf</a> cassandraConf</pre> </li> </ul> </li> @@ -416,15 +426,15 @@ extends <a href="../../../../../org/apache/storm/topology/base/BaseRichBolt.html <ul class="blockList"> <li class="blockList"> <h4>prepare</h4> -<pre>public void prepare(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a> stormConfig, +<pre>public void prepare(<a href="http://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a>> topoConfig, <a href="../../../../../org/apache/storm/task/TopologyContext.html" title="class in org.apache.storm.task">TopologyContext</a> topologyContext, <a href="../../../../../org/apache/storm/task/OutputCollector.html" title="class in org.apache.storm.task">OutputCollector</a> outputCollector)</pre> <div class="block"><p><p>Called when a task for this component is initialized within a worker on the cluster. It provides the bolt with the environment in which the bolt executes.</p><p>This includes the:</p></p></div> <dl> <dt><span class="paramLabel">Parameters:</span></dt> -<dd><code>stormConfig</code> - The Storm configuration for this bolt. This is the configuration provided to the topology merged in with cluster configuration on this machine.</dd> -<dd><code>topologyContext</code> - This object can be used to get information about this task’s place within the topology, including the task id and component id of this task, input and output information, etc.</dd> -<dd><code>outputCollector</code> - The collector is used to emit tuples from this bolt. Tuples can be emitted at any time, including the prepare and cleanup methods. The collector is thread-safe and should be saved as an instance variable of this bolt object.</dd> +<dd><code>topoConfig</code> - The Storm configuration for this bolt. This is the configuration provided to the topology merged in with cluster configuration on this machine.</dd> +<dd><code>topologyContext</code> - This object can be used to get information about this task’s place within the topology, including the task id and component id of this task, input and output information, etc.</dd> +<dd><code>outputCollector</code> - The collector is used to emit tuples from this bolt. Tuples can be emitted at any time, including the prepare and cleanup methods. The collector is thread-safe and should be saved as an instance variable of this bolt object.</dd> </dl> </li> </ul> @@ -444,6 +454,11 @@ extends <a href="../../../../../org/apache/storm/topology/base/BaseRichBolt.html <li class="blockList"> <h4>withOutputFields</h4> <pre>public <a href="../../../../../org/apache/storm/cassandra/bolt/BaseCassandraBolt.html" title="class in org.apache.storm.cassandra.bolt">BaseCassandraBolt</a> withOutputFields(<a href="../../../../../org/apache/storm/tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a> fields)</pre> +<div class="block"><p>Configures this bolt with the given <code>fields</code> as outputfields with stream id as <a href="../../../../../org/apache/storm/utils/Utils.html#DEFAULT_STREAM_ID"><code>Utils.DEFAULT_STREAM_ID</code></a></p></div> +<dl> +<dt><span class="paramLabel">Parameters:</span></dt> +<dd><code>fields</code> - outputfields</dd> +</dl> </li> </ul> <a name="withStreamOutputFields-java.lang.String-org.apache.storm.tuple.Fields-"> @@ -452,8 +467,28 @@ extends <a href="../../../../../org/apache/storm/topology/base/BaseRichBolt.html <ul class="blockList"> <li class="blockList"> <h4>withStreamOutputFields</h4> -<pre>public <a href="../../../../../org/apache/storm/cassandra/bolt/BaseCassandraBolt.html" title="class in org.apache.storm.cassandra.bolt">BaseCassandraBolt</a> withStreamOutputFields(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> stream, +<pre>public <a href="../../../../../org/apache/storm/cassandra/bolt/BaseCassandraBolt.html" title="class in org.apache.storm.cassandra.bolt">BaseCassandraBolt</a> withStreamOutputFields(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> stream, <a href="../../../../../org/apache/storm/tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a> fields)</pre> +<div class="block"><p>Configures this bolt given <code>fields</code> as outputfields for the given <code>stream</code>.</p></div> +<dl> +<dt><span class="paramLabel">Parameters:</span></dt> +<dd><code>stream</code> - </dd> +<dd><code>fields</code> - </dd> +</dl> +</li> +</ul> +<a name="withCassandraConfig-java.util.Map-"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>withCassandraConfig</h4> +<pre>public <a href="../../../../../org/apache/storm/cassandra/bolt/BaseCassandraBolt.html" title="class in org.apache.storm.cassandra.bolt">BaseCassandraBolt</a> withCassandraConfig(<a href="http://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a>> config)</pre> +<div class="block"><p>Takes the given <code>config</code> for creating cassandra client. <a href="../../../../../org/apache/storm/cassandra/client/CassandraConf.html" title="class in org.apache.storm.cassandra.client"><code>CassandraConf</code></a> contains all the properties that can be configured.</p></div> +<dl> +<dt><span class="paramLabel">Parameters:</span></dt> +<dd><code>config</code> - </dd> +</dl> </li> </ul> <a name="getResultHandler--"> @@ -499,37 +534,17 @@ extends <a href="../../../../../org/apache/storm/topology/base/BaseRichBolt.html <li class="blockList"> <h4>execute</h4> <pre>public final void execute(<a href="../../../../../org/apache/storm/tuple/Tuple.html" title="interface in org.apache.storm.tuple">Tuple</a> input)</pre> -<div class="block"><p><p>Process a single tuple of input. The Tuple object contains metadata on it about which component/stream/task it came from. The values of the Tuple can be accessed using Tuple#getValue. The IBolt does not have to process the Tuple immediately. It is perfectly fine to hang onto a tuple and process it later (for instance, to do an aggregation or join).</p><p>Tuples should be emitted using the OutputCollector provided through the prepare method. It is required that all input tuples are acked or failed at some point using the OutputCollector. Otherwise, Storm will be unable to determine when tuples coming off the spouts have been completed.</p><p>For the common case of acking an input tuple at the end of the execute method, see IBasicBolt which automates this.</p></p></div> +<div class="block"><p><p><p>Process a single tuple of input. The Tuple object contains metadata on it about which component/stream/task it came from. The values of the Tuple can be accessed using Tuple#getValue. The IBolt does not have to process the Tuple immediately. It is perfectly fine to hang onto a tuple and process it later (for instance, to do an aggregation or join).</p><p>Tuples should be emitted using the OutputCollector provided through the prepare method. It is required that all input tuples are acked or failed at some point using the OutputCollector. Otherwise, Storm will be unable to determine when tuples coming off the spouts have been completed.</p><p>For the common case of acking an input tuple at the end of the execute method, see IBasicBolt which automates this.</p></p></p></div> <dl> +<dt><span class="overrideSpecifyLabel">Specified by:</span></dt> +<dd><code><a href="../../../../../org/apache/storm/task/IBolt.html#execute-org.apache.storm.tuple.Tuple-">execute</a></code> in interface <code><a href="../../../../../org/apache/storm/task/IBolt.html" title="interface in org.apache.storm.task">IBolt</a></code></dd> +<dt><span class="overrideSpecifyLabel">Overrides:</span></dt> +<dd><code><a href="../../../../../org/apache/storm/topology/base/BaseTickTupleAwareRichBolt.html#execute-org.apache.storm.tuple.Tuple-">execute</a></code> in class <code><a href="../../../../../org/apache/storm/topology/base/BaseTickTupleAwareRichBolt.html" title="class in org.apache.storm.topology.base">BaseTickTupleAwareRichBolt</a></code></dd> <dt><span class="paramLabel">Parameters:</span></dt> <dd><code>input</code> - the tuple to process.</dd> </dl> </li> </ul> -<a name="process-org.apache.storm.tuple.Tuple-"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>process</h4> -<pre>protected abstract void process(<a href="../../../../../org/apache/storm/tuple/Tuple.html" title="interface in org.apache.storm.tuple">Tuple</a> input)</pre> -<div class="block"><p>Process a single tuple of input.</p></div> -<dl> -<dt><span class="paramLabel">Parameters:</span></dt> -<dd><code>input</code> - The input tuple to be processed.</dd> -</dl> -</li> -</ul> -<a name="onTickTuple--"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>onTickTuple</h4> -<pre>protected abstract void onTickTuple()</pre> -<div class="block"><p>Calls by an input tick tuple.</p></div> -</li> -</ul> <a name="declareOutputFields-org.apache.storm.topology.OutputFieldsDeclarer-"> <!-- --> </a> @@ -550,7 +565,7 @@ extends <a href="../../../../../org/apache/storm/topology/base/BaseRichBolt.html <ul class="blockList"> <li class="blockList"> <h4>getComponentConfiguration</h4> -<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a>> getComponentConfiguration()</pre> +<pre>public <a href="http://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a>> getComponentConfiguration()</pre> <div class="block"><p><p>Declare configuration specific to this component. Only a subset of the “topology.*” configs can be overridden. The component configuration can be further overridden when constructing the topology using <a href="../../../../../org/apache/storm/topology/TopologyBuilder.html" title="class in org.apache.storm.topology"><code>TopologyBuilder</code></a></p></p></div> <dl> <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> @@ -649,6 +664,6 @@ hljs.initHighlightingOnLoad(); <!-- --> </a></div> <!-- ======== END OF BOTTOM NAVBAR ======= --> -<p class="legalCopy"><small>Copyright © 2016 <a href="http://www.apache.org/";>The Apache Software Foundation</a>. All Rights Reserved.</small></p> +<p class="legalCopy"><small>Copyright © 2018 <a href="https://www.apache.org/";>The Apache Software Foundation</a>. All rights reserved.</small></p> </body> </html>
