You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2016/04/12 18:07:27 UTC
svn commit: r1738824 [17/38] - in /storm/site/releases/2.0.0-SNAPSHOT: ./
.sass-cache/ documentation/ javadocs/ javadocs/org/apache/storm/
javadocs/org/apache/storm/class-use/ javadocs/org/apache/storm/cluster/
javadocs/org/apache/storm/cluster/class-u...
Modified: storm/site/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/generated/class-use/LocalAssignment.html
URL: http://svn.apache.org/viewvc/storm/site/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/generated/class-use/LocalAssignment.html?rev=1738824&r1=1738823&r2=1738824&view=diff
==============================================================================
--- storm/site/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/generated/class-use/LocalAssignment.html (original)
+++ storm/site/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/generated/class-use/LocalAssignment.html Tue Apr 12 16:07:25 2016
@@ -83,10 +83,14 @@
</tr>
<tbody>
<tr class="altColor">
-<td class="colFirst"><a href="#org.apache.storm.generated">org.apache.storm.generated</a></td>
+<td class="colFirst"><a href="#org.apache.storm.daemon.supervisor">org.apache.storm.daemon.supervisor</a></td>
<td class="colLast"> </td>
</tr>
<tr class="rowColor">
+<td class="colFirst"><a href="#org.apache.storm.generated">org.apache.storm.generated</a></td>
+<td class="colLast"> </td>
+</tr>
+<tr class="altColor">
<td class="colFirst"><a href="#org.apache.storm.utils">org.apache.storm.utils</a></td>
<td class="colLast"> </td>
</tr>
@@ -95,6 +99,85 @@
</li>
<li class="blockList">
<ul class="blockList">
+<li class="blockList"><a name="org.apache.storm.daemon.supervisor">
+<!-- -->
+</a>
+<h3>Uses of <a href="../../../../../org/apache/storm/generated/LocalAssignment.html" title="class in org.apache.storm.generated">LocalAssignment</a> in <a href="../../../../../org/apache/storm/daemon/supervisor/package-summary.html">org.apache.storm.daemon.supervisor</a></h3>
+<table class="useSummary" border="0" cellpadding="3" cellspacing="0" summary="Use table, listing methods, and an explanation">
+<caption><span>Methods in <a href="../../../../../org/apache/storm/daemon/supervisor/package-summary.html">org.apache.storm.daemon.supervisor</a> that return types with arguments of type <a href="../../../../../org/apache/storm/generated/LocalAssignment.html" title="class in org.apache.storm.generated">LocalAssignment</a></span><span class="tabEnd"> </span></caption>
+<tr>
+<th class="colFirst" scope="col">Modifier and Type</th>
+<th class="colLast" scope="col">Method and Description</th>
+</tr>
+<tbody>
+<tr class="altColor">
+<td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/atomic/AtomicReference.html?is-external=true" title="class or interface in java.util.concurrent.atomic">AtomicReference</a><<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/Long.html?is-external=true" title="class or interface in java.lang">Long</a>,<a href="../../../../../org/apache/storm/generated/LocalAssignment.html" title="class in org.apache.storm.generated">LocalAssignment</a>>></code></td>
+<td class="colLast"><span class="typeNameLabel">SupervisorData.</span><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/daemon/supervisor/SupervisorData.html#getCurrAssignment--">getCurrAssignment</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><<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>,<a href="../../../../../org/apache/storm/generated/LocalAssignment.html" title="class in org.apache.storm.generated">LocalAssignment</a>></code></td>
+<td class="colLast"><span class="typeNameLabel">SyncProcessEvent.</span><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/daemon/supervisor/SyncProcessEvent.html#getReassignExecutors-java.util.Map-java.util.Set-">getReassignExecutors</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><<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>,<a href="../../../../../org/apache/storm/generated/LocalAssignment.html" title="class in org.apache.storm.generated">LocalAssignment</a>> assignExecutors,
+ <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Set.html?is-external=true" title="class or interface in java.util">Set</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>> keepPorts)</code> </td>
+</tr>
+<tr class="altColor">
+<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><<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>,<a href="../../../../../org/apache/storm/generated/LocalAssignment.html" title="class in org.apache.storm.generated">LocalAssignment</a>></code></td>
+<td class="colLast"><span class="typeNameLabel">SyncSupervisorEvent.</span><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/daemon/supervisor/SyncSupervisorEvent.html#readAssignments-java.util.Map-java.util.Map-java.lang.String-java.util.concurrent.atomic.AtomicInteger-">readAssignments</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><<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/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 interfa
ce in java.lang">Object</a>>> assignmentsSnapshot,
+ <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/Integer.html?is-external=true" title="class or interface in java.lang">Integer</a>,<a href="../../../../../org/apache/storm/generated/LocalAssignment.html" title="class in org.apache.storm.generated">LocalAssignment</a>> existingAssignment,
+ <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> assignmentId,
+ <a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/atomic/AtomicInteger.html?is-external=true" title="class or interface in java.util.concurrent.atomic">AtomicInteger</a> retries)</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><<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>,<a href="../../../../../org/apache/storm/generated/LocalAssignment.html" title="class in org.apache.storm.generated">LocalAssignment</a>></code></td>
+<td class="colLast"><span class="typeNameLabel">SyncSupervisorEvent.</span><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/daemon/supervisor/SyncSupervisorEvent.html#readMyExecutors-java.lang.String-java.lang.String-org.apache.storm.generated.Assignment-">readMyExecutors</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> stormId,
+ <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> assignmentId,
+ <a href="../../../../../org/apache/storm/generated/Assignment.html" title="class in org.apache.storm.generated">Assignment</a> assignment)</code> </td>
+</tr>
+</tbody>
+</table>
+<table class="useSummary" border="0" cellpadding="3" cellspacing="0" summary="Use table, listing methods, and an explanation">
+<caption><span>Method parameters in <a href="../../../../../org/apache/storm/daemon/supervisor/package-summary.html">org.apache.storm.daemon.supervisor</a> with type arguments of type <a href="../../../../../org/apache/storm/generated/LocalAssignment.html" title="class in org.apache.storm.generated">LocalAssignment</a></span><span class="tabEnd"> </span></caption>
+<tr>
+<th class="colFirst" scope="col">Modifier and Type</th>
+<th class="colLast" scope="col">Method and Description</th>
+</tr>
+<tbody>
+<tr class="altColor">
+<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="../../../../../org/apache/storm/daemon/supervisor/StateHeartbeat.html" title="class in org.apache.storm.daemon.supervisor">StateHeartbeat</a>></code></td>
+<td class="colLast"><span class="typeNameLabel">SyncProcessEvent.</span><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/daemon/supervisor/SyncProcessEvent.html#getLocalWorkerStats-org.apache.storm.daemon.supervisor.SupervisorData-java.util.Map-int-">getLocalWorkerStats</a></span>(<a href="../../../../../org/apache/storm/daemon/supervisor/SupervisorData.html" title="class in org.apache.storm.daemon.supervisor">SupervisorData</a> supervisorData,
+ <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/Integer.html?is-external=true" title="class or interface in java.lang">Integer</a>,<a href="../../../../../org/apache/storm/generated/LocalAssignment.html" title="class in org.apache.storm.generated">LocalAssignment</a>> assignedExecutors,
+ int now)</code>
+<div class="block">Returns map from worker id to worker heartbeat.</div>
+</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><<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>,<a href="../../../../../org/apache/storm/generated/LocalAssignment.html" title="class in org.apache.storm.generated">LocalAssignment</a>></code></td>
+<td class="colLast"><span class="typeNameLabel">SyncProcessEvent.</span><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/daemon/supervisor/SyncProcessEvent.html#getReassignExecutors-java.util.Map-java.util.Set-">getReassignExecutors</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><<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>,<a href="../../../../../org/apache/storm/generated/LocalAssignment.html" title="class in org.apache.storm.generated">LocalAssignment</a>> assignExecutors,
+ <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Set.html?is-external=true" title="class or interface in java.util">Set</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>> keepPorts)</code> </td>
+</tr>
+<tr class="altColor">
+<td class="colFirst"><code>protected boolean</code></td>
+<td class="colLast"><span class="typeNameLabel">SyncProcessEvent.</span><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/daemon/supervisor/SyncProcessEvent.html#matchesAssignment-org.apache.storm.generated.LSWorkerHeartbeat-java.util.Map-">matchesAssignment</a></span>(<a href="../../../../../org/apache/storm/generated/LSWorkerHeartbeat.html" title="class in org.apache.storm.generated">LSWorkerHeartbeat</a> whb,
+ <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/Integer.html?is-external=true" title="class or interface in java.lang">Integer</a>,<a href="../../../../../org/apache/storm/generated/LocalAssignment.html" title="class in org.apache.storm.generated">LocalAssignment</a>> assignedExecutors)</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><<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>,<a href="../../../../../org/apache/storm/generated/LocalAssignment.html" title="class in org.apache.storm.generated">LocalAssignment</a>></code></td>
+<td class="colLast"><span class="typeNameLabel">SyncSupervisorEvent.</span><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/daemon/supervisor/SyncSupervisorEvent.html#readAssignments-java.util.Map-java.util.Map-java.lang.String-java.util.concurrent.atomic.AtomicInteger-">readAssignments</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><<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/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 interfa
ce in java.lang">Object</a>>> assignmentsSnapshot,
+ <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/Integer.html?is-external=true" title="class or interface in java.lang">Integer</a>,<a href="../../../../../org/apache/storm/generated/LocalAssignment.html" title="class in org.apache.storm.generated">LocalAssignment</a>> existingAssignment,
+ <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> assignmentId,
+ <a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/atomic/AtomicInteger.html?is-external=true" title="class or interface in java.util.concurrent.atomic">AtomicInteger</a> retries)</code> </td>
+</tr>
+<tr class="altColor">
+<td class="colFirst"><code>void</code></td>
+<td class="colLast"><span class="typeNameLabel">SupervisorData.</span><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/daemon/supervisor/SupervisorData.html#setCurrAssignment-java.util.Map-">setCurrAssignment</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><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Long.html?is-external=true" title="class or interface in java.lang">Long</a>,<a href="../../../../../org/apache/storm/generated/LocalAssignment.html" title="class in org.apache.storm.generated">LocalAssignment</a>> currAssignment)</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><<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/Integer.html?is-external=true" title="class or interface in java.lang">Integer</a>></code></td>
+<td class="colLast"><span class="typeNameLabel">SyncProcessEvent.</span><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/daemon/supervisor/SyncProcessEvent.html#startNewWorkers-java.util.Map-java.util.Map-">startNewWorkers</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><<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>,<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>> newWorkerIds,
+ <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/Integer.html?is-external=true" title="class or interface in java.lang">Integer</a>,<a href="../../../../../org/apache/storm/generated/LocalAssignment.html" title="class in org.apache.storm.generated">LocalAssignment</a>> reassignExecutors)</code> </td>
+</tr>
+</tbody>
+</table>
+</li>
<li class="blockList"><a name="org.apache.storm.generated">
<!-- -->
</a>
Modified: storm/site/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/generated/class-use/ProfileRequest.html
URL: http://svn.apache.org/viewvc/storm/site/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/generated/class-use/ProfileRequest.html?rev=1738824&r1=1738823&r2=1738824&view=diff
==============================================================================
--- storm/site/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/generated/class-use/ProfileRequest.html (original)
+++ storm/site/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/generated/class-use/ProfileRequest.html Tue Apr 12 16:07:25 2016
@@ -87,6 +87,10 @@
<td class="colLast"> </td>
</tr>
<tr class="rowColor">
+<td class="colFirst"><a href="#org.apache.storm.daemon.supervisor">org.apache.storm.daemon.supervisor</a></td>
+<td class="colLast"> </td>
+</tr>
+<tr class="altColor">
<td class="colFirst"><a href="#org.apache.storm.generated">org.apache.storm.generated</a></td>
<td class="colLast"> </td>
</tr>
@@ -155,6 +159,42 @@
</tr>
</tbody>
</table>
+</li>
+<li class="blockList"><a name="org.apache.storm.daemon.supervisor">
+<!-- -->
+</a>
+<h3>Uses of <a href="../../../../../org/apache/storm/generated/ProfileRequest.html" title="class in org.apache.storm.generated">ProfileRequest</a> in <a href="../../../../../org/apache/storm/daemon/supervisor/package-summary.html">org.apache.storm.daemon.supervisor</a></h3>
+<table class="useSummary" border="0" cellpadding="3" cellspacing="0" summary="Use table, listing methods, and an explanation">
+<caption><span>Methods in <a href="../../../../../org/apache/storm/daemon/supervisor/package-summary.html">org.apache.storm.daemon.supervisor</a> that return types with arguments of type <a href="../../../../../org/apache/storm/generated/ProfileRequest.html" title="class in org.apache.storm.generated">ProfileRequest</a></span><span class="tabEnd"> </span></caption>
+<tr>
+<th class="colFirst" scope="col">Modifier and Type</th>
+<th class="colLast" scope="col">Method and Description</th>
+</tr>
+<tbody>
+<tr class="altColor">
+<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><<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/util/List.html?is-external=true" title="class or interface in java.util">List</a><<a href="../../../../../org/apache/storm/generated/ProfileRequest.html" title="class in org.apache.storm.generated">ProfileRequest</a>>></code></td>
+<td class="colLast"><span class="typeNameLabel">SyncSupervisorEvent.</span><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/daemon/supervisor/SyncSupervisorEvent.html#getProfileActions-org.apache.storm.cluster.IStormClusterState-java.util.List-">getProfileActions</a></span>(<a href="../../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a> stormClusterState,
+ <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>> stormIds)</code> </td>
+</tr>
+<tr class="rowColor">
+<td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/atomic/AtomicReference.html?is-external=true" title="class or interface in java.util.concurrent.atomic">AtomicReference</a><<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/util/List.html?is-external=true" title="class or interface in java.util">List</a><<a href="../../../../../org/apache/storm/generated/ProfileRequest.html" title="class in org.apache.storm.generated">ProfileRequest</a>>>></code></td>
+<td class="colLast"><span class="typeNameLabel">SupervisorData.</span><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/daemon/supervisor/SupervisorData.html#getStormIdToProfilerActions--">getStormIdToProfilerActions</a></span>()</code> </td>
+</tr>
+</tbody>
+</table>
+<table class="useSummary" border="0" cellpadding="3" cellspacing="0" summary="Use table, listing methods, and an explanation">
+<caption><span>Method parameters in <a href="../../../../../org/apache/storm/daemon/supervisor/package-summary.html">org.apache.storm.daemon.supervisor</a> with type arguments of type <a href="../../../../../org/apache/storm/generated/ProfileRequest.html" title="class in org.apache.storm.generated">ProfileRequest</a></span><span class="tabEnd"> </span></caption>
+<tr>
+<th class="colFirst" scope="col">Modifier and Type</th>
+<th class="colLast" scope="col">Method and Description</th>
+</tr>
+<tbody>
+<tr class="altColor">
+<td class="colFirst"><code>void</code></td>
+<td class="colLast"><span class="typeNameLabel">SupervisorData.</span><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/daemon/supervisor/SupervisorData.html#setStormIdToProfilerActions-java.util.Map-">setStormIdToProfilerActions</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><<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/util/List.html?is-external=true" title="class or interface in java.util">List</a><<a href="../../../../../org/apache/storm/generated/ProfileRequest.html" title="class in org.apache.storm.generated">ProfileRequest</a>>> stormIdToProfilerActions)</code> </td>
+</tr>
+</tbody>
+</table>
</li>
<li class="blockList"><a name="org.apache.storm.generated">
<!-- -->
Modified: storm/site/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/generated/class-use/WorkerResources.html
URL: http://svn.apache.org/viewvc/storm/site/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/generated/class-use/WorkerResources.html?rev=1738824&r1=1738823&r2=1738824&view=diff
==============================================================================
--- storm/site/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/generated/class-use/WorkerResources.html (original)
+++ storm/site/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/generated/class-use/WorkerResources.html Tue Apr 12 16:07:25 2016
@@ -83,6 +83,14 @@
</tr>
<tbody>
<tr class="altColor">
+<td class="colFirst"><a href="#org.apache.storm.daemon.supervisor">org.apache.storm.daemon.supervisor</a></td>
+<td class="colLast"> </td>
+</tr>
+<tr class="rowColor">
+<td class="colFirst"><a href="#org.apache.storm.daemon.supervisor.workermanager">org.apache.storm.daemon.supervisor.workermanager</a></td>
+<td class="colLast"> </td>
+</tr>
+<tr class="altColor">
<td class="colFirst"><a href="#org.apache.storm.generated">org.apache.storm.generated</a></td>
<td class="colLast"> </td>
</tr>
@@ -91,6 +99,76 @@
</li>
<li class="blockList">
<ul class="blockList">
+<li class="blockList"><a name="org.apache.storm.daemon.supervisor">
+<!-- -->
+</a>
+<h3>Uses of <a href="../../../../../org/apache/storm/generated/WorkerResources.html" title="class in org.apache.storm.generated">WorkerResources</a> in <a href="../../../../../org/apache/storm/daemon/supervisor/package-summary.html">org.apache.storm.daemon.supervisor</a></h3>
+<table class="useSummary" border="0" cellpadding="3" cellspacing="0" summary="Use table, listing methods, and an explanation">
+<caption><span>Methods in <a href="../../../../../org/apache/storm/daemon/supervisor/package-summary.html">org.apache.storm.daemon.supervisor</a> with parameters of type <a href="../../../../../org/apache/storm/generated/WorkerResources.html" title="class in org.apache.storm.generated">WorkerResources</a></span><span class="tabEnd"> </span></caption>
+<tr>
+<th class="colFirst" scope="col">Modifier and Type</th>
+<th class="colLast" scope="col">Method and Description</th>
+</tr>
+<tbody>
+<tr class="altColor">
+<td class="colFirst"><code>protected void</code></td>
+<td class="colLast"><span class="typeNameLabel">SyncProcessEvent.</span><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/daemon/supervisor/SyncProcessEvent.html#launchDistributedWorker-org.apache.storm.daemon.supervisor.workermanager.IWorkerManager-java.util.Map-java.lang.String-java.lang.String-java.lang.String-java.lang.Long-java.lang.String-org.apache.storm.generated.WorkerResources-org.eclipse.jetty.util.ConcurrentHashSet-">launchDistributedWorker</a></span>(<a href="../../../../../org/apache/storm/daemon/supervisor/workermanager/IWorkerManager.html" title="interface in org.apache.storm.daemon.supervisor.workermanager">IWorkerManager</a> workerManager,
+ <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> conf,
+ <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> supervisorId,
+ <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> assignmentId,
+ <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> stormId,
+ <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Long.html?is-external=true" title="class or interface in java.lang">Long</a> port,
+ <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> workerId,
+ <a href="../../../../../org/apache/storm/generated/WorkerResources.html" title="class in org.apache.storm.generated">WorkerResources</a> resources,
+ org.eclipse.jetty.util.ConcurrentHashSet deadWorkers)</code> </td>
+</tr>
+<tr class="rowColor">
+<td class="colFirst"><code>protected void</code></td>
+<td class="colLast"><span class="typeNameLabel">SyncProcessEvent.</span><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/daemon/supervisor/SyncProcessEvent.html#launchLocalWorker-org.apache.storm.daemon.supervisor.SupervisorData-java.lang.String-java.lang.Long-java.lang.String-org.apache.storm.generated.WorkerResources-">launchLocalWorker</a></span>(<a href="../../../../../org/apache/storm/daemon/supervisor/SupervisorData.html" title="class in org.apache.storm.daemon.supervisor">SupervisorData</a> supervisorData,
+ <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> stormId,
+ <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Long.html?is-external=true" title="class or interface in java.lang">Long</a> port,
+ <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> workerId,
+ <a href="../../../../../org/apache/storm/generated/WorkerResources.html" title="class in org.apache.storm.generated">WorkerResources</a> resources)</code>
+<div class="block">launch a worker in local mode.</div>
+</td>
+</tr>
+</tbody>
+</table>
+</li>
+<li class="blockList"><a name="org.apache.storm.daemon.supervisor.workermanager">
+<!-- -->
+</a>
+<h3>Uses of <a href="../../../../../org/apache/storm/generated/WorkerResources.html" title="class in org.apache.storm.generated">WorkerResources</a> in <a href="../../../../../org/apache/storm/daemon/supervisor/workermanager/package-summary.html">org.apache.storm.daemon.supervisor.workermanager</a></h3>
+<table class="useSummary" border="0" cellpadding="3" cellspacing="0" summary="Use table, listing methods, and an explanation">
+<caption><span>Methods in <a href="../../../../../org/apache/storm/daemon/supervisor/workermanager/package-summary.html">org.apache.storm.daemon.supervisor.workermanager</a> with parameters of type <a href="../../../../../org/apache/storm/generated/WorkerResources.html" title="class in org.apache.storm.generated">WorkerResources</a></span><span class="tabEnd"> </span></caption>
+<tr>
+<th class="colFirst" scope="col">Modifier and Type</th>
+<th class="colLast" scope="col">Method and Description</th>
+</tr>
+<tbody>
+<tr class="altColor">
+<td class="colFirst"><code>void</code></td>
+<td class="colLast"><span class="typeNameLabel">IWorkerManager.</span><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/daemon/supervisor/workermanager/IWorkerManager.html#launchWorker-java.lang.String-java.lang.String-java.lang.String-java.lang.Long-java.lang.String-org.apache.storm.generated.WorkerResources-org.apache.storm.utils.Utils.ExitCodeCallable-">launchWorker</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> supervisorId,
+ <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> assignmentId,
+ <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> stormId,
+ <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Long.html?is-external=true" title="class or interface in java.lang">Long</a> port,
+ <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> workerId,
+ <a href="../../../../../org/apache/storm/generated/WorkerResources.html" title="class in org.apache.storm.generated">WorkerResources</a> resources,
+ <a href="../../../../../org/apache/storm/utils/Utils.ExitCodeCallable.html" title="interface in org.apache.storm.utils">Utils.ExitCodeCallable</a> workerExitCallback)</code> </td>
+</tr>
+<tr class="rowColor">
+<td class="colFirst"><code>void</code></td>
+<td class="colLast"><span class="typeNameLabel">DefaultWorkerManager.</span><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/daemon/supervisor/workermanager/DefaultWorkerManager.html#launchWorker-java.lang.String-java.lang.String-java.lang.String-java.lang.Long-java.lang.String-org.apache.storm.generated.WorkerResources-org.apache.storm.utils.Utils.ExitCodeCallable-">launchWorker</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> supervisorId,
+ <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> assignmentId,
+ <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> stormId,
+ <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Long.html?is-external=true" title="class or interface in java.lang">Long</a> port,
+ <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> workerId,
+ <a href="../../../../../org/apache/storm/generated/WorkerResources.html" title="class in org.apache.storm.generated">WorkerResources</a> resources,
+ <a href="../../../../../org/apache/storm/utils/Utils.ExitCodeCallable.html" title="interface in org.apache.storm.utils">Utils.ExitCodeCallable</a> workerExitCallback)</code> </td>
+</tr>
+</tbody>
+</table>
+</li>
<li class="blockList"><a name="org.apache.storm.generated">
<!-- -->
</a>
Modified: storm/site/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/generated/package-use.html
URL: http://svn.apache.org/viewvc/storm/site/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/generated/package-use.html?rev=1738824&r1=1738823&r2=1738824&view=diff
==============================================================================
--- storm/site/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/generated/package-use.html (original)
+++ storm/site/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/generated/package-use.html Tue Apr 12 16:07:25 2016
@@ -111,6 +111,14 @@
<td class="colLast"> </td>
</tr>
<tr class="rowColor">
+<td class="colFirst"><a href="#org.apache.storm.daemon.supervisor">org.apache.storm.daemon.supervisor</a></td>
+<td class="colLast"> </td>
+</tr>
+<tr class="altColor">
+<td class="colFirst"><a href="#org.apache.storm.daemon.supervisor.workermanager">org.apache.storm.daemon.supervisor.workermanager</a></td>
+<td class="colLast"> </td>
+</tr>
+<tr class="rowColor">
<td class="colFirst"><a href="#org.apache.storm.drpc">org.apache.storm.drpc</a></td>
<td class="colLast"> </td>
</tr>
@@ -513,6 +521,51 @@
</tr>
</tbody>
</table>
+</li>
+<li class="blockList"><a name="org.apache.storm.daemon.supervisor">
+<!-- -->
+</a>
+<table class="useSummary" border="0" cellpadding="3" cellspacing="0" summary="Use table, listing classes, and an explanation">
+<caption><span>Classes in <a href="../../../../org/apache/storm/generated/package-summary.html">org.apache.storm.generated</a> used by <a href="../../../../org/apache/storm/daemon/supervisor/package-summary.html">org.apache.storm.daemon.supervisor</a></span><span class="tabEnd"> </span></caption>
+<tr>
+<th class="colOne" scope="col">Class and Description</th>
+</tr>
+<tbody>
+<tr class="altColor">
+<td class="colOne"><a href="../../../../org/apache/storm/generated/class-use/Assignment.html#org.apache.storm.daemon.supervisor">Assignment</a> </td>
+</tr>
+<tr class="rowColor">
+<td class="colOne"><a href="../../../../org/apache/storm/generated/class-use/ExecutorInfo.html#org.apache.storm.daemon.supervisor">ExecutorInfo</a> </td>
+</tr>
+<tr class="altColor">
+<td class="colOne"><a href="../../../../org/apache/storm/generated/class-use/LocalAssignment.html#org.apache.storm.daemon.supervisor">LocalAssignment</a> </td>
+</tr>
+<tr class="rowColor">
+<td class="colOne"><a href="../../../../org/apache/storm/generated/class-use/LSWorkerHeartbeat.html#org.apache.storm.daemon.supervisor">LSWorkerHeartbeat</a> </td>
+</tr>
+<tr class="altColor">
+<td class="colOne"><a href="../../../../org/apache/storm/generated/class-use/ProfileRequest.html#org.apache.storm.daemon.supervisor">ProfileRequest</a> </td>
+</tr>
+<tr class="rowColor">
+<td class="colOne"><a href="../../../../org/apache/storm/generated/class-use/WorkerResources.html#org.apache.storm.daemon.supervisor">WorkerResources</a> </td>
+</tr>
+</tbody>
+</table>
+</li>
+<li class="blockList"><a name="org.apache.storm.daemon.supervisor.workermanager">
+<!-- -->
+</a>
+<table class="useSummary" border="0" cellpadding="3" cellspacing="0" summary="Use table, listing classes, and an explanation">
+<caption><span>Classes in <a href="../../../../org/apache/storm/generated/package-summary.html">org.apache.storm.generated</a> used by <a href="../../../../org/apache/storm/daemon/supervisor/workermanager/package-summary.html">org.apache.storm.daemon.supervisor.workermanager</a></span><span class="tabEnd"> </span></caption>
+<tr>
+<th class="colOne" scope="col">Class and Description</th>
+</tr>
+<tbody>
+<tr class="altColor">
+<td class="colOne"><a href="../../../../org/apache/storm/generated/class-use/WorkerResources.html#org.apache.storm.daemon.supervisor.workermanager">WorkerResources</a> </td>
+</tr>
+</tbody>
+</table>
</li>
<li class="blockList"><a name="org.apache.storm.drpc">
<!-- -->
Modified: storm/site/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/grouping/CustomStreamGrouping.html
URL: http://svn.apache.org/viewvc/storm/site/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/grouping/CustomStreamGrouping.html?rev=1738824&r1=1738823&r2=1738824&view=diff
==============================================================================
--- storm/site/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/grouping/CustomStreamGrouping.html (original)
+++ storm/site/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/grouping/CustomStreamGrouping.html Tue Apr 12 16:07:25 2016
@@ -109,7 +109,7 @@ var activeTableTab = "activeTableTab";
</dl>
<dl>
<dt>All Known Implementing Classes:</dt>
-<dd><a href="../../../../org/apache/storm/trident/partition/GlobalGrouping.html" title="class in org.apache.storm.trident.partition">GlobalGrouping</a>, <a href="../../../../org/apache/storm/trident/partition/IdentityGrouping.html" title="class in org.apache.storm.trident.partition">IdentityGrouping</a>, <a href="../../../../org/apache/storm/trident/partition/IndexHashGrouping.html" title="class in org.apache.storm.trident.partition">IndexHashGrouping</a>, <a href="../../../../org/apache/storm/grouping/LoadAwareShuffleGrouping.html" title="class in org.apache.storm.grouping">LoadAwareShuffleGrouping</a>, <a href="../../../../org/apache/storm/cassandra/Murmur3StreamGrouping.html" title="class in org.apache.storm.cassandra">Murmur3StreamGrouping</a>, <a href="../../../../org/apache/storm/testing/NGrouping.html" title="class in org.apache.storm.testing">NGrouping</a>, <a href="../../../../org/apache/storm/grouping/PartialKeyGrouping.html" title="class in org.apache.storm.grouping">Part
ialKeyGrouping</a>, <a href="../../../../org/apache/storm/grouping/ShuffleGrouping.html" title="class in org.apache.storm.grouping">ShuffleGrouping</a></dd>
+<dd><a href="../../../../org/apache/storm/trident/partition/GlobalGrouping.html" title="class in org.apache.storm.trident.partition">GlobalGrouping</a>, <a href="../../../../org/apache/storm/daemon/GrouperFactory.AllGrouper.html" title="class in org.apache.storm.daemon">GrouperFactory.AllGrouper</a>, <a href="../../../../org/apache/storm/daemon/GrouperFactory.BasicLoadAwareCustomStreamGrouping.html" title="class in org.apache.storm.daemon">GrouperFactory.BasicLoadAwareCustomStreamGrouping</a>, <a href="../../../../org/apache/storm/daemon/GrouperFactory.FieldsGrouper.html" title="class in org.apache.storm.daemon">GrouperFactory.FieldsGrouper</a>, <a href="../../../../org/apache/storm/daemon/GrouperFactory.GlobalGrouper.html" title="class in org.apache.storm.daemon">GrouperFactory.GlobalGrouper</a>, <a href="../../../../org/apache/storm/daemon/GrouperFactory.NoneGrouper.html" title="class in org.apache.storm.daemon">GrouperFactory.NoneGrouper</a>, <a href="../../../../org/apache/storm
/trident/partition/IdentityGrouping.html" title="class in org.apache.storm.trident.partition">IdentityGrouping</a>, <a href="../../../../org/apache/storm/trident/partition/IndexHashGrouping.html" title="class in org.apache.storm.trident.partition">IndexHashGrouping</a>, <a href="../../../../org/apache/storm/grouping/LoadAwareShuffleGrouping.html" title="class in org.apache.storm.grouping">LoadAwareShuffleGrouping</a>, <a href="../../../../org/apache/storm/cassandra/Murmur3StreamGrouping.html" title="class in org.apache.storm.cassandra">Murmur3StreamGrouping</a>, <a href="../../../../org/apache/storm/testing/NGrouping.html" title="class in org.apache.storm.testing">NGrouping</a>, <a href="../../../../org/apache/storm/grouping/PartialKeyGrouping.html" title="class in org.apache.storm.grouping">PartialKeyGrouping</a>, <a href="../../../../org/apache/storm/grouping/ShuffleGrouping.html" title="class in org.apache.storm.grouping">ShuffleGrouping</a></dd>
</dl>
<hr>
<br>
Modified: storm/site/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/grouping/LoadAwareCustomStreamGrouping.html
URL: http://svn.apache.org/viewvc/storm/site/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/grouping/LoadAwareCustomStreamGrouping.html?rev=1738824&r1=1738823&r2=1738824&view=diff
==============================================================================
--- storm/site/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/grouping/LoadAwareCustomStreamGrouping.html (original)
+++ storm/site/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/grouping/LoadAwareCustomStreamGrouping.html Tue Apr 12 16:07:25 2016
@@ -105,7 +105,7 @@ var activeTableTab = "activeTableTab";
</dl>
<dl>
<dt>All Known Implementing Classes:</dt>
-<dd><a href="../../../../org/apache/storm/grouping/LoadAwareShuffleGrouping.html" title="class in org.apache.storm.grouping">LoadAwareShuffleGrouping</a></dd>
+<dd><a href="../../../../org/apache/storm/daemon/GrouperFactory.BasicLoadAwareCustomStreamGrouping.html" title="class in org.apache.storm.daemon">GrouperFactory.BasicLoadAwareCustomStreamGrouping</a>, <a href="../../../../org/apache/storm/grouping/LoadAwareShuffleGrouping.html" title="class in org.apache.storm.grouping">LoadAwareShuffleGrouping</a></dd>
</dl>
<hr>
<br>
Modified: storm/site/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/grouping/class-use/CustomStreamGrouping.html
URL: http://svn.apache.org/viewvc/storm/site/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/grouping/class-use/CustomStreamGrouping.html?rev=1738824&r1=1738823&r2=1738824&view=diff
==============================================================================
--- storm/site/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/grouping/class-use/CustomStreamGrouping.html (original)
+++ storm/site/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/grouping/class-use/CustomStreamGrouping.html Tue Apr 12 16:07:25 2016
@@ -87,26 +87,30 @@
<td class="colLast"> </td>
</tr>
<tr class="rowColor">
-<td class="colFirst"><a href="#org.apache.storm.drpc">org.apache.storm.drpc</a></td>
+<td class="colFirst"><a href="#org.apache.storm.daemon">org.apache.storm.daemon</a></td>
<td class="colLast"> </td>
</tr>
<tr class="altColor">
-<td class="colFirst"><a href="#org.apache.storm.grouping">org.apache.storm.grouping</a></td>
+<td class="colFirst"><a href="#org.apache.storm.drpc">org.apache.storm.drpc</a></td>
<td class="colLast"> </td>
</tr>
<tr class="rowColor">
-<td class="colFirst"><a href="#org.apache.storm.testing">org.apache.storm.testing</a></td>
+<td class="colFirst"><a href="#org.apache.storm.grouping">org.apache.storm.grouping</a></td>
<td class="colLast"> </td>
</tr>
<tr class="altColor">
-<td class="colFirst"><a href="#org.apache.storm.topology">org.apache.storm.topology</a></td>
+<td class="colFirst"><a href="#org.apache.storm.testing">org.apache.storm.testing</a></td>
<td class="colLast"> </td>
</tr>
<tr class="rowColor">
-<td class="colFirst"><a href="#org.apache.storm.trident">org.apache.storm.trident</a></td>
+<td class="colFirst"><a href="#org.apache.storm.topology">org.apache.storm.topology</a></td>
<td class="colLast"> </td>
</tr>
<tr class="altColor">
+<td class="colFirst"><a href="#org.apache.storm.trident">org.apache.storm.trident</a></td>
+<td class="colLast"> </td>
+</tr>
+<tr class="rowColor">
<td class="colFirst"><a href="#org.apache.storm.trident.partition">org.apache.storm.trident.partition</a></td>
<td class="colLast"> </td>
</tr>
@@ -134,6 +138,53 @@
</tr>
</tbody>
</table>
+</li>
+<li class="blockList"><a name="org.apache.storm.daemon">
+<!-- -->
+</a>
+<h3>Uses of <a href="../../../../../org/apache/storm/grouping/CustomStreamGrouping.html" title="interface in org.apache.storm.grouping">CustomStreamGrouping</a> in <a href="../../../../../org/apache/storm/daemon/package-summary.html">org.apache.storm.daemon</a></h3>
+<table class="useSummary" border="0" cellpadding="3" cellspacing="0" summary="Use table, listing classes, and an explanation">
+<caption><span>Classes in <a href="../../../../../org/apache/storm/daemon/package-summary.html">org.apache.storm.daemon</a> that implement <a href="../../../../../org/apache/storm/grouping/CustomStreamGrouping.html" title="interface in org.apache.storm.grouping">CustomStreamGrouping</a></span><span class="tabEnd"> </span></caption>
+<tr>
+<th class="colFirst" scope="col">Modifier and Type</th>
+<th class="colLast" scope="col">Class and Description</th>
+</tr>
+<tbody>
+<tr class="altColor">
+<td class="colFirst"><code>static class </code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/daemon/GrouperFactory.AllGrouper.html" title="class in org.apache.storm.daemon">GrouperFactory.AllGrouper</a></span></code> </td>
+</tr>
+<tr class="rowColor">
+<td class="colFirst"><code>static class </code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/daemon/GrouperFactory.BasicLoadAwareCustomStreamGrouping.html" title="class in org.apache.storm.daemon">GrouperFactory.BasicLoadAwareCustomStreamGrouping</a></span></code>
+<div class="block">A bridge between CustomStreamGrouping and LoadAwareCustomStreamGrouping</div>
+</td>
+</tr>
+<tr class="altColor">
+<td class="colFirst"><code>static class </code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/daemon/GrouperFactory.FieldsGrouper.html" title="class in org.apache.storm.daemon">GrouperFactory.FieldsGrouper</a></span></code> </td>
+</tr>
+<tr class="rowColor">
+<td class="colFirst"><code>static class </code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/daemon/GrouperFactory.GlobalGrouper.html" title="class in org.apache.storm.daemon">GrouperFactory.GlobalGrouper</a></span></code> </td>
+</tr>
+<tr class="altColor">
+<td class="colFirst"><code>static class </code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/daemon/GrouperFactory.NoneGrouper.html" title="class in org.apache.storm.daemon">GrouperFactory.NoneGrouper</a></span></code> </td>
+</tr>
+</tbody>
+</table>
+<table class="useSummary" border="0" cellpadding="3" cellspacing="0" summary="Use table, listing constructors, and an explanation">
+<caption><span>Constructors in <a href="../../../../../org/apache/storm/daemon/package-summary.html">org.apache.storm.daemon</a> with parameters of type <a href="../../../../../org/apache/storm/grouping/CustomStreamGrouping.html" title="interface in org.apache.storm.grouping">CustomStreamGrouping</a></span><span class="tabEnd"> </span></caption>
+<tr>
+<th class="colOne" scope="col">Constructor and Description</th>
+</tr>
+<tbody>
+<tr class="altColor">
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/daemon/GrouperFactory.BasicLoadAwareCustomStreamGrouping.html#BasicLoadAwareCustomStreamGrouping-org.apache.storm.grouping.CustomStreamGrouping-">BasicLoadAwareCustomStreamGrouping</a></span>(<a href="../../../../../org/apache/storm/grouping/CustomStreamGrouping.html" title="interface in org.apache.storm.grouping">CustomStreamGrouping</a> customStreamGrouping)</code> </td>
+</tr>
+</tbody>
+</table>
</li>
<li class="blockList"><a name="org.apache.storm.drpc">
<!-- -->
Modified: storm/site/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/grouping/class-use/LoadAwareCustomStreamGrouping.html
URL: http://svn.apache.org/viewvc/storm/site/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/grouping/class-use/LoadAwareCustomStreamGrouping.html?rev=1738824&r1=1738823&r2=1738824&view=diff
==============================================================================
--- storm/site/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/grouping/class-use/LoadAwareCustomStreamGrouping.html (original)
+++ storm/site/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/grouping/class-use/LoadAwareCustomStreamGrouping.html Tue Apr 12 16:07:25 2016
@@ -83,6 +83,10 @@
</tr>
<tbody>
<tr class="altColor">
+<td class="colFirst"><a href="#org.apache.storm.daemon">org.apache.storm.daemon</a></td>
+<td class="colLast"> </td>
+</tr>
+<tr class="rowColor">
<td class="colFirst"><a href="#org.apache.storm.grouping">org.apache.storm.grouping</a></td>
<td class="colLast"> </td>
</tr>
@@ -91,6 +95,58 @@
</li>
<li class="blockList">
<ul class="blockList">
+<li class="blockList"><a name="org.apache.storm.daemon">
+<!-- -->
+</a>
+<h3>Uses of <a href="../../../../../org/apache/storm/grouping/LoadAwareCustomStreamGrouping.html" title="interface in org.apache.storm.grouping">LoadAwareCustomStreamGrouping</a> in <a href="../../../../../org/apache/storm/daemon/package-summary.html">org.apache.storm.daemon</a></h3>
+<table class="useSummary" border="0" cellpadding="3" cellspacing="0" summary="Use table, listing classes, and an explanation">
+<caption><span>Classes in <a href="../../../../../org/apache/storm/daemon/package-summary.html">org.apache.storm.daemon</a> that implement <a href="../../../../../org/apache/storm/grouping/LoadAwareCustomStreamGrouping.html" title="interface in org.apache.storm.grouping">LoadAwareCustomStreamGrouping</a></span><span class="tabEnd"> </span></caption>
+<tr>
+<th class="colFirst" scope="col">Modifier and Type</th>
+<th class="colLast" scope="col">Class and Description</th>
+</tr>
+<tbody>
+<tr class="altColor">
+<td class="colFirst"><code>static class </code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/daemon/GrouperFactory.BasicLoadAwareCustomStreamGrouping.html" title="class in org.apache.storm.daemon">GrouperFactory.BasicLoadAwareCustomStreamGrouping</a></span></code>
+<div class="block">A bridge between CustomStreamGrouping and LoadAwareCustomStreamGrouping</div>
+</td>
+</tr>
+</tbody>
+</table>
+<table class="useSummary" border="0" cellpadding="3" cellspacing="0" summary="Use table, listing fields, and an explanation">
+<caption><span>Fields in <a href="../../../../../org/apache/storm/daemon/package-summary.html">org.apache.storm.daemon</a> declared as <a href="../../../../../org/apache/storm/grouping/LoadAwareCustomStreamGrouping.html" title="interface in org.apache.storm.grouping">LoadAwareCustomStreamGrouping</a></span><span class="tabEnd"> </span></caption>
+<tr>
+<th class="colFirst" scope="col">Modifier and Type</th>
+<th class="colLast" scope="col">Field and Description</th>
+</tr>
+<tbody>
+<tr class="altColor">
+<td class="colFirst"><code>static <a href="../../../../../org/apache/storm/grouping/LoadAwareCustomStreamGrouping.html" title="interface in org.apache.storm.grouping">LoadAwareCustomStreamGrouping</a></code></td>
+<td class="colLast"><span class="typeNameLabel">GrouperFactory.</span><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/daemon/GrouperFactory.html#DIRECT">DIRECT</a></span></code> </td>
+</tr>
+</tbody>
+</table>
+<table class="useSummary" border="0" cellpadding="3" cellspacing="0" summary="Use table, listing methods, and an explanation">
+<caption><span>Methods in <a href="../../../../../org/apache/storm/daemon/package-summary.html">org.apache.storm.daemon</a> that return <a href="../../../../../org/apache/storm/grouping/LoadAwareCustomStreamGrouping.html" title="interface in org.apache.storm.grouping">LoadAwareCustomStreamGrouping</a></span><span class="tabEnd"> </span></caption>
+<tr>
+<th class="colFirst" scope="col">Modifier and Type</th>
+<th class="colLast" scope="col">Method and Description</th>
+</tr>
+<tbody>
+<tr class="altColor">
+<td class="colFirst"><code>static <a href="../../../../../org/apache/storm/grouping/LoadAwareCustomStreamGrouping.html" title="interface in org.apache.storm.grouping">LoadAwareCustomStreamGrouping</a></code></td>
+<td class="colLast"><span class="typeNameLabel">GrouperFactory.</span><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/daemon/GrouperFactory.html#mkGrouper-org.apache.storm.task.WorkerTopologyContext-java.lang.String-java.lang.String-org.apache.storm.tuple.Fields-org.apache.storm.generated.Grouping-java.util.List-java.util.Map-">mkGrouper</a></span>(<a href="../../../../../org/apache/storm/task/WorkerTopologyContext.html" title="class in org.apache.storm.task">WorkerTopologyContext</a> context,
+ <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> componentId,
+ <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> streamId,
+ <a href="../../../../../org/apache/storm/tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a> outFields,
+ <a href="../../../../../org/apache/storm/generated/Grouping.html" title="class in org.apache.storm.generated">Grouping</a> thriftGrouping,
+ <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>> unsortedTargetTasks,
+ <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> topoConf)</code> </td>
+</tr>
+</tbody>
+</table>
+</li>
<li class="blockList"><a name="org.apache.storm.grouping">
<!-- -->
</a>
Modified: storm/site/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/grouping/class-use/LoadMapping.html
URL: http://svn.apache.org/viewvc/storm/site/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/grouping/class-use/LoadMapping.html?rev=1738824&r1=1738823&r2=1738824&view=diff
==============================================================================
--- storm/site/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/grouping/class-use/LoadMapping.html (original)
+++ storm/site/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/grouping/class-use/LoadMapping.html Tue Apr 12 16:07:25 2016
@@ -83,6 +83,10 @@
</tr>
<tbody>
<tr class="altColor">
+<td class="colFirst"><a href="#org.apache.storm.daemon">org.apache.storm.daemon</a></td>
+<td class="colLast"> </td>
+</tr>
+<tr class="rowColor">
<td class="colFirst"><a href="#org.apache.storm.grouping">org.apache.storm.grouping</a></td>
<td class="colLast"> </td>
</tr>
@@ -91,6 +95,26 @@
</li>
<li class="blockList">
<ul class="blockList">
+<li class="blockList"><a name="org.apache.storm.daemon">
+<!-- -->
+</a>
+<h3>Uses of <a href="../../../../../org/apache/storm/grouping/LoadMapping.html" title="class in org.apache.storm.grouping">LoadMapping</a> in <a href="../../../../../org/apache/storm/daemon/package-summary.html">org.apache.storm.daemon</a></h3>
+<table class="useSummary" border="0" cellpadding="3" cellspacing="0" summary="Use table, listing methods, and an explanation">
+<caption><span>Methods in <a href="../../../../../org/apache/storm/daemon/package-summary.html">org.apache.storm.daemon</a> with parameters of type <a href="../../../../../org/apache/storm/grouping/LoadMapping.html" title="class in org.apache.storm.grouping">LoadMapping</a></span><span class="tabEnd"> </span></caption>
+<tr>
+<th class="colFirst" scope="col">Modifier and Type</th>
+<th class="colLast" scope="col">Method and Description</th>
+</tr>
+<tbody>
+<tr 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="colLast"><span class="typeNameLabel">GrouperFactory.BasicLoadAwareCustomStreamGrouping.</span><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/daemon/GrouperFactory.BasicLoadAwareCustomStreamGrouping.html#chooseTasks-int-java.util.List-org.apache.storm.grouping.LoadMapping-">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,
+ <a href="../../../../../org/apache/storm/grouping/LoadMapping.html" title="class in org.apache.storm.grouping">LoadMapping</a> load)</code> </td>
+</tr>
+</tbody>
+</table>
+</li>
<li class="blockList"><a name="org.apache.storm.grouping">
<!-- -->
</a>
Modified: storm/site/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/grouping/package-use.html
URL: http://svn.apache.org/viewvc/storm/site/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/grouping/package-use.html?rev=1738824&r1=1738823&r2=1738824&view=diff
==============================================================================
--- storm/site/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/grouping/package-use.html (original)
+++ storm/site/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/grouping/package-use.html Tue Apr 12 16:07:25 2016
@@ -87,34 +87,38 @@
<td class="colLast"> </td>
</tr>
<tr class="rowColor">
-<td class="colFirst"><a href="#org.apache.storm.drpc">org.apache.storm.drpc</a></td>
+<td class="colFirst"><a href="#org.apache.storm.daemon">org.apache.storm.daemon</a></td>
<td class="colLast"> </td>
</tr>
<tr class="altColor">
-<td class="colFirst"><a href="#org.apache.storm.grouping">org.apache.storm.grouping</a></td>
+<td class="colFirst"><a href="#org.apache.storm.drpc">org.apache.storm.drpc</a></td>
<td class="colLast"> </td>
</tr>
<tr class="rowColor">
-<td class="colFirst"><a href="#org.apache.storm.messaging">org.apache.storm.messaging</a></td>
+<td class="colFirst"><a href="#org.apache.storm.grouping">org.apache.storm.grouping</a></td>
<td class="colLast"> </td>
</tr>
<tr class="altColor">
-<td class="colFirst"><a href="#org.apache.storm.messaging.netty">org.apache.storm.messaging.netty</a></td>
+<td class="colFirst"><a href="#org.apache.storm.messaging">org.apache.storm.messaging</a></td>
<td class="colLast"> </td>
</tr>
<tr class="rowColor">
-<td class="colFirst"><a href="#org.apache.storm.testing">org.apache.storm.testing</a></td>
+<td class="colFirst"><a href="#org.apache.storm.messaging.netty">org.apache.storm.messaging.netty</a></td>
<td class="colLast"> </td>
</tr>
<tr class="altColor">
-<td class="colFirst"><a href="#org.apache.storm.topology">org.apache.storm.topology</a></td>
+<td class="colFirst"><a href="#org.apache.storm.testing">org.apache.storm.testing</a></td>
<td class="colLast"> </td>
</tr>
<tr class="rowColor">
-<td class="colFirst"><a href="#org.apache.storm.trident">org.apache.storm.trident</a></td>
+<td class="colFirst"><a href="#org.apache.storm.topology">org.apache.storm.topology</a></td>
<td class="colLast"> </td>
</tr>
<tr class="altColor">
+<td class="colFirst"><a href="#org.apache.storm.trident">org.apache.storm.trident</a></td>
+<td class="colLast"> </td>
+</tr>
+<tr class="rowColor">
<td class="colFirst"><a href="#org.apache.storm.trident.partition">org.apache.storm.trident.partition</a></td>
<td class="colLast"> </td>
</tr>
@@ -135,6 +139,29 @@
</tr>
</tbody>
</table>
+</li>
+<li class="blockList"><a name="org.apache.storm.daemon">
+<!-- -->
+</a>
+<table class="useSummary" border="0" cellpadding="3" cellspacing="0" summary="Use table, listing classes, and an explanation">
+<caption><span>Classes in <a href="../../../../org/apache/storm/grouping/package-summary.html">org.apache.storm.grouping</a> used by <a href="../../../../org/apache/storm/daemon/package-summary.html">org.apache.storm.daemon</a></span><span class="tabEnd"> </span></caption>
+<tr>
+<th class="colOne" scope="col">Class and Description</th>
+</tr>
+<tbody>
+<tr class="altColor">
+<td class="colOne"><a href="../../../../org/apache/storm/grouping/class-use/CustomStreamGrouping.html#org.apache.storm.daemon">CustomStreamGrouping</a> </td>
+</tr>
+<tr class="rowColor">
+<td class="colOne"><a href="../../../../org/apache/storm/grouping/class-use/LoadAwareCustomStreamGrouping.html#org.apache.storm.daemon">LoadAwareCustomStreamGrouping</a> </td>
+</tr>
+<tr class="altColor">
+<td class="colOne"><a href="../../../../org/apache/storm/grouping/class-use/LoadMapping.html#org.apache.storm.daemon">LoadMapping</a>
+<div class="block">Holds a list of the current loads</div>
+</td>
+</tr>
+</tbody>
+</table>
</li>
<li class="blockList"><a name="org.apache.storm.drpc">
<!-- -->
Modified: storm/site/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/hdfs/bolt/AbstractHdfsBolt.html
URL: http://svn.apache.org/viewvc/storm/site/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/hdfs/bolt/AbstractHdfsBolt.html?rev=1738824&r1=1738823&r2=1738824&view=diff
==============================================================================
--- storm/site/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/hdfs/bolt/AbstractHdfsBolt.html (original)
+++ storm/site/releases/2.0.0-SNAPSHOT/javadocs/org/apache/storm/hdfs/bolt/AbstractHdfsBolt.html Tue Apr 12 16:07:25 2016
@@ -18,7 +18,7 @@
catch(err) {
}
//-->
-var methods = {"i0":6,"i1":6,"i2":10,"i3":6,"i4":10,"i5":10,"i6":10,"i7":10,"i8":6,"i9":6};
+var methods = {"i0":10,"i1":6,"i2":10,"i3":10,"i4":10,"i5":6,"i6":6,"i7":10,"i8":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";
@@ -180,16 +180,24 @@ extends <a href="../../../../../org/apac
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/hdfs/bolt/AbstractHdfsBolt.html#hdfsConfig">hdfsConfig</a></span></code> </td>
</tr>
<tr class="rowColor">
+<td class="colFirst"><code>protected <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="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/hdfs/bolt/AbstractHdfsBolt.html#maxOpenFiles">maxOpenFiles</a></span></code> </td>
+</tr>
+<tr class="altColor">
<td class="colFirst"><code>protected long</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/hdfs/bolt/AbstractHdfsBolt.html#offset">offset</a></span></code> </td>
</tr>
+<tr class="rowColor">
+<td class="colFirst"><code>protected <a href="../../../../../org/apache/storm/hdfs/common/Partitioner.html" title="interface in org.apache.storm.hdfs.common">Partitioner</a></code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/hdfs/bolt/AbstractHdfsBolt.html#partitioner">partitioner</a></span></code> </td>
+</tr>
<tr class="altColor">
-<td class="colFirst"><code>protected int</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/hdfs/bolt/AbstractHdfsBolt.html#rotation">rotation</a></span></code> </td>
+<td class="colFirst"><code>protected <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="../../../../../org/apache/storm/hdfs/common/rotation/RotationAction.html" title="interface in org.apache.storm.hdfs.common.rotation">RotationAction</a>></code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/hdfs/bolt/AbstractHdfsBolt.html#rotationActions">rotationActions</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/ArrayList.html?is-external=true" title="class or interface in java.util">ArrayList</a><<a href="../../../../../org/apache/storm/hdfs/common/rotation/RotationAction.html" title="interface in org.apache.storm.hdfs.common.rotation">RotationAction</a>></code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/hdfs/bolt/AbstractHdfsBolt.html#rotationActions">rotationActions</a></span></code> </td>
+<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><<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/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/hdfs/bolt/AbstractHdfsBolt.html#rotationCounterMap">rotationCounterMap</a></span></code> </td>
</tr>
<tr class="altColor">
<td class="colFirst"><code>protected <a href="../../../../../org/apache/storm/hdfs/bolt/rotation/FileRotationPolicy.html" title="interface in org.apache.storm.hdfs.bolt.rotation">FileRotationPolicy</a></code></td>
@@ -211,6 +219,10 @@ extends <a href="../../../../../org/apac
<td class="colFirst"><code>protected <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="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/hdfs/bolt/AbstractHdfsBolt.html#writeLock">writeLock</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><<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="../../../../../org/apache/storm/hdfs/common/AbstractHDFSWriter.html" title="class in org.apache.storm.hdfs.common">AbstractHDFSWriter</a>></code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/hdfs/bolt/AbstractHdfsBolt.html#writers">writers</a></span></code> </td>
+</tr>
</table>
</li>
</ul>
@@ -244,38 +256,43 @@ extends <a href="../../../../../org/apac
<th class="colLast" scope="col">Method and Description</th>
</tr>
<tr id="i0" class="altColor">
-<td class="colFirst"><code>protected abstract void</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/hdfs/bolt/AbstractHdfsBolt.html#closeOutputFile--">closeOutputFile</a></span>()</code> </td>
-</tr>
-<tr id="i1" class="rowColor">
-<td class="colFirst"><code>protected abstract org.apache.hadoop.fs.Path</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/hdfs/bolt/AbstractHdfsBolt.html#createOutputFile--">createOutputFile</a></span>()</code> </td>
-</tr>
-<tr id="i2" class="altColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/hdfs/bolt/AbstractHdfsBolt.html#declareOutputFields-org.apache.storm.topology.OutputFieldsDeclarer-">declareOutputFields</a></span>(<a href="../../../../../org/apache/storm/topology/OutputFieldsDeclarer.html" title="interface in org.apache.storm.topology">OutputFieldsDeclarer</a> outputFieldsDeclarer)</code>
<div class="block">Declare the output schema for all the streams of this topology.</div>
</td>
</tr>
-<tr id="i3" class="rowColor">
+<tr id="i1" class="rowColor">
<td class="colFirst"><code>protected abstract void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/hdfs/bolt/AbstractHdfsBolt.html#doPrepare-java.util.Map-org.apache.storm.task.TopologyContext-org.apache.storm.task.OutputCollector-">doPrepare</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> conf,
<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> collector)</code> </td>
</tr>
-<tr id="i4" class="altColor">
+<tr id="i2" class="altColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/hdfs/bolt/AbstractHdfsBolt.html#execute-org.apache.storm.tuple.Tuple-">execute</a></span>(<a href="../../../../../org/apache/storm/tuple/Tuple.html" title="interface in org.apache.storm.tuple">Tuple</a> tuple)</code>
<div class="block">Process a single tuple of input.</div>
</td>
</tr>
-<tr id="i5" class="rowColor">
+<tr id="i3" class="rowColor">
+<td class="colFirst"><code>protected org.apache.hadoop.fs.Path</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/hdfs/bolt/AbstractHdfsBolt.html#getBasePathForNextFile-org.apache.storm.tuple.Tuple-">getBasePathForNextFile</a></span>(<a href="../../../../../org/apache/storm/tuple/Tuple.html" title="interface in org.apache.storm.tuple">Tuple</a> tuple)</code> </td>
+</tr>
+<tr id="i4" class="altColor">
<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="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/hdfs/bolt/AbstractHdfsBolt.html#getComponentConfiguration--">getComponentConfiguration</a></span>()</code>
<div class="block">Declare configuration specific to this component.</div>
</td>
</tr>
+<tr id="i5" class="rowColor">
+<td class="colFirst"><code>protected abstract <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></code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/hdfs/bolt/AbstractHdfsBolt.html#getWriterKey-org.apache.storm.tuple.Tuple-">getWriterKey</a></span>(<a href="../../../../../org/apache/storm/tuple/Tuple.html" title="interface in org.apache.storm.tuple">Tuple</a> tuple)</code> </td>
+</tr>
<tr id="i6" class="altColor">
+<td class="colFirst"><code>protected abstract <a href="../../../../../org/apache/storm/hdfs/common/AbstractHDFSWriter.html" title="class in org.apache.storm.hdfs.common">AbstractHDFSWriter</a></code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/hdfs/bolt/AbstractHdfsBolt.html#makeNewWriter-org.apache.hadoop.fs.Path-org.apache.storm.tuple.Tuple-">makeNewWriter</a></span>(org.apache.hadoop.fs.Path path,
+ <a href="../../../../../org/apache/storm/tuple/Tuple.html" title="interface in org.apache.storm.tuple">Tuple</a> tuple)</code> </td>
+</tr>
+<tr id="i7" class="rowColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/hdfs/bolt/AbstractHdfsBolt.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> conf,
<a href="../../../../../org/apache/storm/task/TopologyContext.html" title="class in org.apache.storm.task">TopologyContext</a> topologyContext,
@@ -283,21 +300,9 @@ extends <a href="../../../../../org/apac
<div class="block">Marked as final to prevent override.</div>
</td>
</tr>
-<tr id="i7" class="rowColor">
-<td class="colFirst"><code>protected void</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/hdfs/bolt/AbstractHdfsBolt.html#rotateOutputFile--">rotateOutputFile</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/hdfs/bolt/AbstractHdfsBolt.html#syncTuples--">syncTuples</a></span>()</code>
-<div class="block">Make the best effort to sync written data to the underlying file system.</div>
-</td>
-</tr>
-<tr id="i9" class="rowColor">
-<td class="colFirst"><code>protected abstract void</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/hdfs/bolt/AbstractHdfsBolt.html#writeTuple-org.apache.storm.tuple.Tuple-">writeTuple</a></span>(<a href="../../../../../org/apache/storm/tuple/Tuple.html" title="interface in org.apache.storm.tuple">Tuple</a> tuple)</code>
-<div class="block">writes a tuple to the underlying filesystem but makes no guarantees about syncing data.</div>
-</td>
+<td class="colFirst"><code>protected void</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/hdfs/bolt/AbstractHdfsBolt.html#rotateOutputFile-org.apache.storm.hdfs.common.AbstractHDFSWriter-">rotateOutputFile</a></span>(<a href="../../../../../org/apache/storm/hdfs/common/AbstractHDFSWriter.html" title="class in org.apache.storm.hdfs.common">AbstractHDFSWriter</a> writer)</code> </td>
</tr>
</table>
<ul class="blockList">
@@ -328,13 +333,31 @@ extends <a href="../../../../../org/apac
<!-- -->
</a>
<h3>Field Detail</h3>
+<a name="writers">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>writers</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><<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="../../../../../org/apache/storm/hdfs/common/AbstractHDFSWriter.html" title="class in org.apache.storm.hdfs.common">AbstractHDFSWriter</a>> writers</pre>
+</li>
+</ul>
+<a name="rotationCounterMap">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>rotationCounterMap</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><<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/Integer.html?is-external=true" title="class or interface in java.lang">Integer</a>> rotationCounterMap</pre>
+</li>
+</ul>
<a name="rotationActions">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>rotationActions</h4>
-<pre>protected <a href="http://docs.oracle.com/javase/7/docs/api/java/util/ArrayList.html?is-external=true" title="class or interface in java.util">ArrayList</a><<a href="../../../../../org/apache/storm/hdfs/common/rotation/RotationAction.html" title="interface in org.apache.storm.hdfs.common.rotation">RotationAction</a>> rotationActions</pre>
+<pre>protected <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="../../../../../org/apache/storm/hdfs/common/rotation/RotationAction.html" title="interface in org.apache.storm.hdfs.common.rotation">RotationAction</a>> rotationActions</pre>
</li>
</ul>
<a name="collector">
@@ -382,15 +405,6 @@ extends <a href="../../../../../org/apac
<pre>protected <a href="../../../../../org/apache/storm/hdfs/bolt/format/FileNameFormat.html" title="interface in org.apache.storm.hdfs.bolt.format">FileNameFormat</a> fileNameFormat</pre>
</li>
</ul>
-<a name="rotation">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>rotation</h4>
-<pre>protected int rotation</pre>
-</li>
-</ul>
<a name="fsUrl">
<!-- -->
</a>
@@ -454,6 +468,24 @@ extends <a href="../../../../../org/apac
<pre>protected <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> tickTupleInterval</pre>
</li>
</ul>
+<a name="maxOpenFiles">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>maxOpenFiles</h4>
+<pre>protected <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> maxOpenFiles</pre>
+</li>
+</ul>
+<a name="partitioner">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>partitioner</h4>
+<pre>protected <a href="../../../../../org/apache/storm/hdfs/common/Partitioner.html" title="interface in org.apache.storm.hdfs.common">Partitioner</a> partitioner</pre>
+</li>
+</ul>
<a name="hdfsConfig">
<!-- -->
</a>
@@ -488,13 +520,13 @@ extends <a href="../../../../../org/apac
<!-- -->
</a>
<h3>Method Detail</h3>
-<a name="rotateOutputFile--">
+<a name="rotateOutputFile-org.apache.storm.hdfs.common.AbstractHDFSWriter-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>rotateOutputFile</h4>
-<pre>protected void rotateOutputFile()
+<pre>protected void rotateOutputFile(<a href="../../../../../org/apache/storm/hdfs/common/AbstractHDFSWriter.html" title="class in org.apache.storm.hdfs.common">AbstractHDFSWriter</a> writer)
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>
<dl>
<dt><span class="throwsLabel">Throws:</span></dt>
@@ -567,76 +599,49 @@ extends <a href="../../../../../org/apac
</dl>
</li>
</ul>
-<a name="writeTuple-org.apache.storm.tuple.Tuple-">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>writeTuple</h4>
-<pre>protected abstract void writeTuple(<a href="../../../../../org/apache/storm/tuple/Tuple.html" title="interface in org.apache.storm.tuple">Tuple</a> tuple)
- 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>writes a tuple to the underlying filesystem but makes no guarantees about syncing data.</p><p>this.offset is also updated to reflect additional data written</p></div>
-<dl>
-<dt><span class="paramLabel">Parameters:</span></dt>
-<dd><code>tuple</code> - </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>
-<a name="syncTuples--">
+<a name="getBasePathForNextFile-org.apache.storm.tuple.Tuple-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
-<h4>syncTuples</h4>
-<pre>protected abstract void syncTuples()
- 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>Make the best effort to sync written data to the underlying file system. Concrete classes should very clearly state the file state that sync guarantees. For example, HdfsBolt can make a much stronger guarantee than SequenceFileBolt.</p></div>
-<dl>
-<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>
+<h4>getBasePathForNextFile</h4>
+<pre>protected org.apache.hadoop.fs.Path getBasePathForNextFile(<a href="../../../../../org/apache/storm/tuple/Tuple.html" title="interface in org.apache.storm.tuple">Tuple</a> tuple)</pre>
</li>
</ul>
-<a name="closeOutputFile--">
+<a name="doPrepare-java.util.Map-org.apache.storm.task.TopologyContext-org.apache.storm.task.OutputCollector-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
-<h4>closeOutputFile</h4>
-<pre>protected abstract void closeOutputFile()
- 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>
+<h4>doPrepare</h4>
+<pre>protected abstract void doPrepare(<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> conf,
+ <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> collector)
+ 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>
<dl>
<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>
-<a name="createOutputFile--">
+<a name="getWriterKey-org.apache.storm.tuple.Tuple-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
-<h4>createOutputFile</h4>
-<pre>protected abstract org.apache.hadoop.fs.Path createOutputFile()
- 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>
-<dl>
-<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>
+<h4>getWriterKey</h4>
+<pre>protected abstract <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> getWriterKey(<a href="../../../../../org/apache/storm/tuple/Tuple.html" title="interface in org.apache.storm.tuple">Tuple</a> tuple)</pre>
</li>
</ul>
-<a name="doPrepare-java.util.Map-org.apache.storm.task.TopologyContext-org.apache.storm.task.OutputCollector-">
+<a name="makeNewWriter-org.apache.hadoop.fs.Path-org.apache.storm.tuple.Tuple-">
<!-- -->
</a>
<ul class="blockListLast">
<li class="blockList">
-<h4>doPrepare</h4>
-<pre>protected abstract void doPrepare(<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> conf,
- <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> collector)
- 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>
+<h4>makeNewWriter</h4>
+<pre>protected abstract <a href="../../../../../org/apache/storm/hdfs/common/AbstractHDFSWriter.html" title="class in org.apache.storm.hdfs.common">AbstractHDFSWriter</a> makeNewWriter(org.apache.hadoop.fs.Path path,
+ <a href="../../../../../org/apache/storm/tuple/Tuple.html" title="interface in org.apache.storm.tuple">Tuple</a> tuple)
+ 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>
<dl>
<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>