| <!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd"> |
| <!-- NewPage --> |
| <html lang="en"> |
| <head> |
| <!-- Generated by javadoc --> |
| <meta http-equiv="Content-Type" content="text/html; charset=UTF-8"> |
| <title>LocalCluster (Storm 2.4.0 API)</title> |
| <link rel="stylesheet" type="text/css" href="../../../stylesheet.css" title="Style"> |
| <script type="text/javascript" src="../../../script.js"></script> |
| </head> |
| <body> |
| <script type="text/javascript"><!-- |
| try { |
| if (location.href.indexOf('is-external=true') == -1) { |
| parent.document.title="LocalCluster (Storm 2.4.0 API)"; |
| } |
| } |
| catch(err) { |
| } |
| //--> |
| var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":10,"i18":10,"i19":10,"i20":10,"i21":10,"i22":10,"i23":10,"i24":10,"i25":10,"i26":10,"i27":10,"i28":10,"i29":10,"i30":10,"i31":10,"i32":10,"i33":10,"i34":10,"i35":10,"i36":10,"i37":10,"i38":10,"i39":10,"i40":10,"i41":10,"i42":10,"i43":10,"i44":10,"i45":10,"i46":10,"i47":10,"i48":10,"i49":10,"i50":10,"i51":10,"i52":10,"i53":10,"i54":10,"i55":10,"i56":10,"i57":9,"i58":10,"i59":10,"i60":10,"i61":10,"i62":10,"i63":10,"i64":10,"i65":10,"i66":10,"i67":10,"i68":10,"i69":10,"i70":10,"i71":10,"i72":10,"i73":10,"i74":10,"i75":10,"i76":10,"i77":10,"i78":9,"i79":9}; |
| var tabs = {65535:["t0","All Methods"],1:["t1","Static Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]}; |
| var altColor = "altColor"; |
| var rowColor = "rowColor"; |
| var tableTab = "tableTab"; |
| var activeTableTab = "activeTableTab"; |
| </script> |
| <noscript> |
| <div>JavaScript is disabled on your browser.</div> |
| </noscript> |
| <!-- ========= START OF TOP NAVBAR ======= --> |
| <div class="topNav"><a name="navbar.top"> |
| <!-- --> |
| </a> |
| <div class="skipNav"><a href="#skip.navbar.top" title="Skip navigation links">Skip navigation links</a></div> |
| <a name="navbar.top.firstrow"> |
| <!-- --> |
| </a> |
| <ul class="navList" title="Navigation"> |
| <li><a href="../../../overview-summary.html">Overview</a></li> |
| <li><a href="package-summary.html">Package</a></li> |
| <li class="navBarCell1Rev">Class</li> |
| <li><a href="class-use/LocalCluster.html">Use</a></li> |
| <li><a href="package-tree.html">Tree</a></li> |
| <li><a href="../../../deprecated-list.html">Deprecated</a></li> |
| <li><a href="../../../index-all.html">Index</a></li> |
| <li><a href="../../../help-doc.html">Help</a></li> |
| </ul> |
| </div> |
| <div class="subNav"> |
| <ul class="navList"> |
| <li><a href="../../../org/apache/storm/ISubmitterHook.html" title="interface in org.apache.storm"><span class="typeNameLink">Prev Class</span></a></li> |
| <li><a href="../../../org/apache/storm/LocalCluster.Builder.html" title="class in org.apache.storm"><span class="typeNameLink">Next Class</span></a></li> |
| </ul> |
| <ul class="navList"> |
| <li><a href="../../../index.html?org/apache/storm/LocalCluster.html" target="_top">Frames</a></li> |
| <li><a href="LocalCluster.html" target="_top">No Frames</a></li> |
| </ul> |
| <ul class="navList" id="allclasses_navbar_top"> |
| <li><a href="../../../allclasses-noframe.html">All Classes</a></li> |
| </ul> |
| <div> |
| <script type="text/javascript"><!-- |
| allClassesLink = document.getElementById("allclasses_navbar_top"); |
| if(window==top) { |
| allClassesLink.style.display = "block"; |
| } |
| else { |
| allClassesLink.style.display = "none"; |
| } |
| //--> |
| </script> |
| </div> |
| <div> |
| <ul class="subNavList"> |
| <li>Summary: </li> |
| <li><a href="#nested.class.summary">Nested</a> | </li> |
| <li><a href="#field.summary">Field</a> | </li> |
| <li><a href="#constructor.summary">Constr</a> | </li> |
| <li><a href="#method.summary">Method</a></li> |
| </ul> |
| <ul class="subNavList"> |
| <li>Detail: </li> |
| <li><a href="#field.detail">Field</a> | </li> |
| <li><a href="#constructor.detail">Constr</a> | </li> |
| <li><a href="#method.detail">Method</a></li> |
| </ul> |
| </div> |
| <a name="skip.navbar.top"> |
| <!-- --> |
| </a></div> |
| <!-- ========= END OF TOP NAVBAR ========= --> |
| <!-- ======== START OF CLASS DATA ======== --> |
| <div class="header"> |
| <div class="subTitle">org.apache.storm</div> |
| <h2 title="Class LocalCluster" class="title">Class LocalCluster</h2> |
| </div> |
| <div class="contentContainer"> |
| <ul class="inheritance"> |
| <li><a href="https://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.LocalCluster</li> |
| </ul> |
| </li> |
| </ul> |
| <div class="description"> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <dl> |
| <dt>All Implemented Interfaces:</dt> |
| <dd><a href="https://docs.oracle.com/javase/8/docs/api/java/lang/AutoCloseable.html?is-external=true" title="class or interface in java.lang">AutoCloseable</a>, <a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a>, <a href="../../../org/apache/storm/ILocalCluster.html" title="interface in org.apache.storm">ILocalCluster</a>, <a href="../../../org/apache/storm/ILocalClusterTrackedTopologyAware.html" title="interface in org.apache.storm">ILocalClusterTrackedTopologyAware</a></dd> |
| </dl> |
| <hr> |
| <br> |
| <pre>public class <span class="typeNameLabel">LocalCluster</span> |
| extends <a href="https://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/ILocalClusterTrackedTopologyAware.html" title="interface in org.apache.storm">ILocalClusterTrackedTopologyAware</a>, <a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></pre> |
| <div class="block"><p>A stand alone storm cluster that runs inside a single process. It is intended to be used for testing. Both internal testing for Apache Storm itself and for people building storm topologies. <p> LocalCluster is an AutoCloseable so if you are using it in tests you can use a try block to be sure it is shut down. </p> try (LocalCluster cluster = new LocalCluster()) { // Do some tests } // The cluster has been shut down.</p></div> |
| </li> |
| </ul> |
| </div> |
| <div class="summary"> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <!-- ======== NESTED CLASS SUMMARY ======== --> |
| <ul class="blockList"> |
| <li class="blockList"><a name="nested.class.summary"> |
| <!-- --> |
| </a> |
| <h3>Nested Class Summary</h3> |
| <table class="memberSummary" border="0" cellpadding="3" cellspacing="0" summary="Nested Class Summary table, listing nested classes, and an explanation"> |
| <caption><span>Nested Classes</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> |
| <tr class="altColor"> |
| <td class="colFirst"><code>static class </code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.Builder.html" title="class in org.apache.storm">LocalCluster.Builder</a></span></code> |
| <div class="block">Simple way to configure a LocalCluster to meet your needs.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><code>class </code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.LocalTopology.html" title="class in org.apache.storm">LocalCluster.LocalTopology</a></span></code> |
| <div class="block">When running a topology locally, for tests etc.</div> |
| </td> |
| </tr> |
| </table> |
| <ul class="blockList"> |
| <li class="blockList"><a name="nested.classes.inherited.from.class.org.apache.storm.ILocalCluster"> |
| <!-- --> |
| </a> |
| <h3>Nested classes/interfaces inherited from interface org.apache.storm.<a href="../../../org/apache/storm/ILocalCluster.html" title="interface in org.apache.storm">ILocalCluster</a></h3> |
| <code><a href="../../../org/apache/storm/ILocalCluster.ILocalTopology.html" title="interface in org.apache.storm">ILocalCluster.ILocalTopology</a></code></li> |
| </ul> |
| </li> |
| </ul> |
| <!-- =========== FIELD SUMMARY =========== --> |
| <ul class="blockList"> |
| <li class="blockList"><a name="field.summary"> |
| <!-- --> |
| </a> |
| <h3>Field Summary</h3> |
| <table class="memberSummary" border="0" cellpadding="3" cellspacing="0" summary="Field Summary table, listing fields, and an explanation"> |
| <caption><span>Fields</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> |
| <tr class="altColor"> |
| <td class="colFirst"><code>static <a href="../../../org/apache/storm/generated/KillOptions.html" title="class in org.apache.storm.generated">KillOptions</a></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#KILL_NOW">KILL_NOW</a></span></code> </td> |
| </tr> |
| </table> |
| </li> |
| </ul> |
| <!-- ======== CONSTRUCTOR SUMMARY ======== --> |
| <ul class="blockList"> |
| <li class="blockList"><a name="constructor.summary"> |
| <!-- --> |
| </a> |
| <h3>Constructor Summary</h3> |
| <table class="memberSummary" border="0" cellpadding="3" cellspacing="0" summary="Constructor Summary table, listing constructors, and an explanation"> |
| <caption><span>Constructors</span><span class="tabEnd"> </span></caption> |
| <tr> |
| <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/LocalCluster.html#LocalCluster--">LocalCluster</a></span>()</code> |
| <div class="block">Create a default LocalCluster.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colOne"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#LocalCluster-java.lang.String-java.lang.Long-">LocalCluster</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> zkHost, |
| <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Long.html?is-external=true" title="class or interface in java.lang">Long</a> zkPort)</code> |
| <div class="block">Create a LocalCluster that connects to an existing Zookeeper instance.</div> |
| </td> |
| </tr> |
| </table> |
| </li> |
| </ul> |
| <!-- ========== METHOD SUMMARY =========== --> |
| <ul class="blockList"> |
| <li class="blockList"><a name="method.summary"> |
| <!-- --> |
| </a> |
| <h3>Method Summary</h3> |
| <table class="memberSummary" border="0" cellpadding="3" cellspacing="0" summary="Method Summary table, listing methods, and an explanation"> |
| <caption><span id="t0" class="activeTableTab"><span>All Methods</span><span class="tabEnd"> </span></span><span id="t1" class="tableTab"><span><a href="javascript:show(1);">Static Methods</a></span><span class="tabEnd"> </span></span><span id="t2" class="tableTab"><span><a href="javascript:show(2);">Instance Methods</a></span><span class="tabEnd"> </span></span><span id="t4" class="tableTab"><span><a href="javascript:show(8);">Concrete Methods</a></span><span class="tabEnd"> </span></span></caption> |
| <tr> |
| <th class="colFirst" scope="col">Modifier and Type</th> |
| <th class="colLast" scope="col">Method and Description</th> |
| </tr> |
| <tr id="i0" class="altColor"> |
| <td class="colFirst"><code>void</code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#activate-java.lang.String-">activate</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> topologyName)</code> |
| <div class="block">Activate a topology.</div> |
| </td> |
| </tr> |
| <tr id="i1" class="rowColor"> |
| <td class="colFirst"><code><a href="../../../org/apache/storm/daemon/supervisor/Supervisor.html" title="class in org.apache.storm.daemon.supervisor">Supervisor</a></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#addSupervisor--">addSupervisor</a></span>()</code> |
| <div class="block">Add another supervisor to the topology.</div> |
| </td> |
| </tr> |
| <tr id="i2" class="altColor"> |
| <td class="colFirst"><code><a href="../../../org/apache/storm/daemon/supervisor/Supervisor.html" title="class in org.apache.storm.daemon.supervisor">Supervisor</a></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#addSupervisor-java.lang.Number-">addSupervisor</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Number.html?is-external=true" title="class or interface in java.lang">Number</a> ports)</code> |
| <div class="block">Add another supervisor to the topology.</div> |
| </td> |
| </tr> |
| <tr id="i3" class="rowColor"> |
| <td class="colFirst"><code><a href="../../../org/apache/storm/daemon/supervisor/Supervisor.html" title="class in org.apache.storm.daemon.supervisor">Supervisor</a></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#addSupervisor-java.lang.Number-java.util.Map-java.lang.String-">addSupervisor</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Number.html?is-external=true" title="class or interface in java.lang">Number</a> ports, |
| <a href="https://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="https://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="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a>> conf, |
| <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> id)</code> |
| <div class="block">Add another supervisor to the topology.</div> |
| </td> |
| </tr> |
| <tr id="i4" class="altColor"> |
| <td class="colFirst"><code><a href="../../../org/apache/storm/daemon/supervisor/Supervisor.html" title="class in org.apache.storm.daemon.supervisor">Supervisor</a></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#addSupervisor-java.lang.Number-java.lang.String-">addSupervisor</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Number.html?is-external=true" title="class or interface in java.lang">Number</a> ports, |
| <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> id)</code> |
| <div class="block">Add another supervisor to the topology.</div> |
| </td> |
| </tr> |
| <tr id="i5" class="rowColor"> |
| <td class="colFirst"><code>void</code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#advanceClusterTime-int-">advanceClusterTime</a></span>(int secs)</code> |
| <div class="block">Advance the cluster time when the cluster is using SimulatedTime.</div> |
| </td> |
| </tr> |
| <tr id="i6" class="altColor"> |
| <td class="colFirst"><code>void</code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#advanceClusterTime-int-int-">advanceClusterTime</a></span>(int secs, |
| int incSecs)</code> |
| <div class="block">Advance the cluster time when the cluster is using SimulatedTime.</div> |
| </td> |
| </tr> |
| <tr id="i7" class="rowColor"> |
| <td class="colFirst"><code><a href="../../../org/apache/storm/generated/BeginDownloadResult.html" title="class in org.apache.storm.generated">BeginDownloadResult</a></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#beginBlobDownload-java.lang.String-">beginBlobDownload</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> key)</code> </td> |
| </tr> |
| <tr id="i8" class="altColor"> |
| <td class="colFirst"><code><a href="https://docs.oracle.com/javase/8/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/LocalCluster.html#beginCreateBlob-java.lang.String-org.apache.storm.generated.SettableBlobMeta-">beginCreateBlob</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> key, |
| <a href="../../../org/apache/storm/generated/SettableBlobMeta.html" title="class in org.apache.storm.generated">SettableBlobMeta</a> meta)</code> </td> |
| </tr> |
| <tr id="i9" class="rowColor"> |
| <td class="colFirst"><code><a href="https://docs.oracle.com/javase/8/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/LocalCluster.html#beginFileUpload--">beginFileUpload</a></span>()</code> </td> |
| </tr> |
| <tr id="i10" class="altColor"> |
| <td class="colFirst"><code><a href="https://docs.oracle.com/javase/8/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/LocalCluster.html#beginUpdateBlob-java.lang.String-">beginUpdateBlob</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> key)</code> </td> |
| </tr> |
| <tr id="i11" class="rowColor"> |
| <td class="colFirst"><code>void</code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#cancelBlobUpload-java.lang.String-">cancelBlobUpload</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> session)</code> </td> |
| </tr> |
| <tr id="i12" class="altColor"> |
| <td class="colFirst"><code>void</code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#close--">close</a></span>()</code> </td> |
| </tr> |
| <tr id="i13" class="rowColor"> |
| <td class="colFirst"><code>void</code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#createStateInZookeeper-java.lang.String-">createStateInZookeeper</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> key)</code> </td> |
| </tr> |
| <tr id="i14" class="altColor"> |
| <td class="colFirst"><code>void</code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#deactivate-java.lang.String-">deactivate</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> topologyName)</code> |
| <div class="block">Deactivate a topology.</div> |
| </td> |
| </tr> |
| <tr id="i15" class="rowColor"> |
| <td class="colFirst"><code>void</code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#debug-java.lang.String-java.lang.String-boolean-double-">debug</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> name, |
| <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> component, |
| boolean enable, |
| double samplingPercentage)</code> |
| <div class="block">Enable/disable logging the tuples generated in topology via an internal EventLogger bolt.</div> |
| </td> |
| </tr> |
| <tr id="i16" class="altColor"> |
| <td class="colFirst"><code>void</code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#deleteBlob-java.lang.String-">deleteBlob</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> key)</code> </td> |
| </tr> |
| <tr id="i17" class="rowColor"> |
| <td class="colFirst"><code><a href="https://docs.oracle.com/javase/8/docs/api/java/nio/ByteBuffer.html?is-external=true" title="class or interface in java.nio">ByteBuffer</a></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#downloadBlobChunk-java.lang.String-">downloadBlobChunk</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> session)</code> </td> |
| </tr> |
| <tr id="i18" class="altColor"> |
| <td class="colFirst"><code><a href="https://docs.oracle.com/javase/8/docs/api/java/nio/ByteBuffer.html?is-external=true" title="class or interface in java.nio">ByteBuffer</a></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#downloadChunk-java.lang.String-">downloadChunk</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> id)</code> </td> |
| </tr> |
| <tr id="i19" class="rowColor"> |
| <td class="colFirst"><code>void</code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#finishBlobUpload-java.lang.String-">finishBlobUpload</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> session)</code> </td> |
| </tr> |
| <tr id="i20" class="altColor"> |
| <td class="colFirst"><code>void</code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#finishFileUpload-java.lang.String-">finishFileUpload</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> location)</code> </td> |
| </tr> |
| <tr id="i21" class="rowColor"> |
| <td class="colFirst"><code><a href="../../../org/apache/storm/generated/ReadableBlobMeta.html" title="class in org.apache.storm.generated">ReadableBlobMeta</a></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#getBlobMeta-java.lang.String-">getBlobMeta</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> key)</code> </td> |
| </tr> |
| <tr id="i22" class="altColor"> |
| <td class="colFirst"><code>int</code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#getBlobReplication-java.lang.String-">getBlobReplication</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> key)</code> </td> |
| </tr> |
| <tr id="i23" class="rowColor"> |
| <td class="colFirst"><code><a href="../../../org/apache/storm/generated/ClusterSummary.html" title="class in org.apache.storm.generated">ClusterSummary</a></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#getClusterInfo--">getClusterInfo</a></span>()</code> |
| <div class="block">Get cluster information.</div> |
| </td> |
| </tr> |
| <tr id="i24" class="altColor"> |
| <td class="colFirst"><code><a href="../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#getClusterState--">getClusterState</a></span>()</code> |
| <div class="block">This is intended for internal testing only.</div> |
| </td> |
| </tr> |
| <tr id="i25" class="rowColor"> |
| <td class="colFirst"><code><a href="../../../org/apache/storm/generated/ComponentPageInfo.html" title="class in org.apache.storm.generated">ComponentPageInfo</a></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#getComponentPageInfo-java.lang.String-java.lang.String-java.lang.String-boolean-">getComponentPageInfo</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> topologyId, |
| <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> componentId, |
| <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> window, |
| boolean isIncludeSys)</code> </td> |
| </tr> |
| <tr id="i26" class="altColor"> |
| <td class="colFirst"><code><a href="https://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="../../../org/apache/storm/generated/ProfileRequest.html" title="class in org.apache.storm.generated">ProfileRequest</a>></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#getComponentPendingProfileActions-java.lang.String-java.lang.String-org.apache.storm.generated.ProfileAction-">getComponentPendingProfileActions</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> id, |
| <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> componentId, |
| <a href="../../../org/apache/storm/generated/ProfileAction.html" title="enum in org.apache.storm.generated">ProfileAction</a> action)</code> </td> |
| </tr> |
| <tr id="i27" class="rowColor"> |
| <td class="colFirst"><code><a href="https://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="https://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="https://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/LocalCluster.html#getDaemonConf--">getDaemonConf</a></span>()</code> |
| <div class="block">Get daemon configuration.</div> |
| </td> |
| </tr> |
| <tr id="i28" class="altColor"> |
| <td class="colFirst"><code><a href="../../../org/apache/storm/generated/NimbusSummary.html" title="class in org.apache.storm.generated">NimbusSummary</a></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#getLeader--">getLeader</a></span>()</code> </td> |
| </tr> |
| <tr id="i29" class="rowColor"> |
| <td class="colFirst"><code><a href="../../../org/apache/storm/generated/LogConfig.html" title="class in org.apache.storm.generated">LogConfig</a></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#getLogConfig-java.lang.String-">getLogConfig</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> name)</code> </td> |
| </tr> |
| <tr id="i30" class="altColor"> |
| <td class="colFirst"><code><a href="../../../org/apache/storm/metric/StormMetricsRegistry.html" title="class in org.apache.storm.metric">StormMetricsRegistry</a></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#getMetricRegistry--">getMetricRegistry</a></span>()</code> |
| <div class="block">Reference to metrics registry.</div> |
| </td> |
| </tr> |
| <tr id="i31" class="rowColor"> |
| <td class="colFirst"><code><a href="../../../org/apache/storm/daemon/nimbus/Nimbus.html" title="class in org.apache.storm.daemon.nimbus">Nimbus</a></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#getNimbus--">getNimbus</a></span>()</code> |
| <div class="block">Reference to nimbus.</div> |
| </td> |
| </tr> |
| <tr id="i32" class="altColor"> |
| <td class="colFirst"><code><a href="https://docs.oracle.com/javase/8/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/LocalCluster.html#getNimbusConf--">getNimbusConf</a></span>()</code> </td> |
| </tr> |
| <tr id="i33" class="rowColor"> |
| <td class="colFirst"><code><a href="https://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="../../../org/apache/storm/generated/OwnerResourceSummary.html" title="class in org.apache.storm.generated">OwnerResourceSummary</a>></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#getOwnerResourceSummaries-java.lang.String-">getOwnerResourceSummaries</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> owner)</code> </td> |
| </tr> |
| <tr id="i34" class="altColor"> |
| <td class="colFirst"><code><a href="../../../org/apache/storm/daemon/supervisor/Supervisor.html" title="class in org.apache.storm.daemon.supervisor">Supervisor</a></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#getSupervisor-java.lang.String-">getSupervisor</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> id)</code> |
| <div class="block">Get a specific Supervisor.</div> |
| </td> |
| </tr> |
| <tr id="i35" class="rowColor"> |
| <td class="colFirst"><code><a href="../../../org/apache/storm/generated/SupervisorAssignments.html" title="class in org.apache.storm.generated">SupervisorAssignments</a></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#getSupervisorAssignments-java.lang.String-">getSupervisorAssignments</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> node)</code> |
| <div class="block">Get assigned assignments for a specific supervisor</div> |
| </td> |
| </tr> |
| <tr id="i36" class="altColor"> |
| <td class="colFirst"><code><a href="../../../org/apache/storm/generated/SupervisorPageInfo.html" title="class in org.apache.storm.generated">SupervisorPageInfo</a></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#getSupervisorPageInfo-java.lang.String-java.lang.String-boolean-">getSupervisorPageInfo</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> id, |
| <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> host, |
| boolean isIncludeSys)</code> </td> |
| </tr> |
| <tr id="i37" class="rowColor"> |
| <td class="colFirst"><code>int</code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#getThriftServerPort--">getThriftServerPort</a></span>()</code> </td> |
| </tr> |
| <tr id="i38" class="altColor"> |
| <td class="colFirst"><code><a href="../../../org/apache/storm/generated/StormTopology.html" title="class in org.apache.storm.generated">StormTopology</a></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#getTopology-java.lang.String-">getTopology</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> id)</code> |
| <div class="block">Get the compiled storm topology.</div> |
| </td> |
| </tr> |
| <tr id="i39" class="rowColor"> |
| <td class="colFirst"><code><a href="https://docs.oracle.com/javase/8/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/LocalCluster.html#getTopologyConf-java.lang.String-">getTopologyConf</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> id)</code> |
| <div class="block">The config of a topology as a JSON string.</div> |
| </td> |
| </tr> |
| <tr id="i40" class="altColor"> |
| <td class="colFirst"><code><a href="../../../org/apache/storm/generated/TopologyHistoryInfo.html" title="class in org.apache.storm.generated">TopologyHistoryInfo</a></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#getTopologyHistory-java.lang.String-">getTopologyHistory</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> user)</code> </td> |
| </tr> |
| <tr id="i41" class="rowColor"> |
| <td class="colFirst"><code><a href="../../../org/apache/storm/generated/TopologyInfo.html" title="class in org.apache.storm.generated">TopologyInfo</a></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#getTopologyInfo-java.lang.String-">getTopologyInfo</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> id)</code> |
| <div class="block">Get the state of a topology.</div> |
| </td> |
| </tr> |
| <tr id="i42" class="altColor"> |
| <td class="colFirst"><code><a href="../../../org/apache/storm/generated/TopologyInfo.html" title="class in org.apache.storm.generated">TopologyInfo</a></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#getTopologyInfoByName-java.lang.String-">getTopologyInfoByName</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> name)</code> |
| <div class="block">Get the state of a topology.</div> |
| </td> |
| </tr> |
| <tr id="i43" class="rowColor"> |
| <td class="colFirst"><code><a href="../../../org/apache/storm/generated/TopologyInfo.html" title="class in org.apache.storm.generated">TopologyInfo</a></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#getTopologyInfoByNameWithOpts-java.lang.String-org.apache.storm.generated.GetInfoOptions-">getTopologyInfoByNameWithOpts</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> name, |
| <a href="../../../org/apache/storm/generated/GetInfoOptions.html" title="class in org.apache.storm.generated">GetInfoOptions</a> options)</code> |
| <div class="block">Get the state of a topology.</div> |
| </td> |
| </tr> |
| <tr id="i44" class="altColor"> |
| <td class="colFirst"><code><a href="../../../org/apache/storm/generated/TopologyInfo.html" title="class in org.apache.storm.generated">TopologyInfo</a></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#getTopologyInfoWithOpts-java.lang.String-org.apache.storm.generated.GetInfoOptions-">getTopologyInfoWithOpts</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> id, |
| <a href="../../../org/apache/storm/generated/GetInfoOptions.html" title="class in org.apache.storm.generated">GetInfoOptions</a> options)</code> |
| <div class="block">Get the state of a topology.</div> |
| </td> |
| </tr> |
| <tr id="i45" class="rowColor"> |
| <td class="colFirst"><code><a href="../../../org/apache/storm/generated/TopologyPageInfo.html" title="class in org.apache.storm.generated">TopologyPageInfo</a></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#getTopologyPageInfo-java.lang.String-java.lang.String-boolean-">getTopologyPageInfo</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> id, |
| <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> window, |
| boolean isIncludeSys)</code> </td> |
| </tr> |
| <tr id="i46" class="altColor"> |
| <td class="colFirst"><code><a href="https://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="../../../org/apache/storm/generated/TopologySummary.html" title="class in org.apache.storm.generated">TopologySummary</a>></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#getTopologySummaries--">getTopologySummaries</a></span>()</code> </td> |
| </tr> |
| <tr id="i47" class="rowColor"> |
| <td class="colFirst"><code><a href="../../../org/apache/storm/generated/TopologySummary.html" title="class in org.apache.storm.generated">TopologySummary</a></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#getTopologySummary-java.lang.String-">getTopologySummary</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> id)</code> </td> |
| </tr> |
| <tr id="i48" class="altColor"> |
| <td class="colFirst"><code><a href="../../../org/apache/storm/generated/TopologySummary.html" title="class in org.apache.storm.generated">TopologySummary</a></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#getTopologySummaryByName-java.lang.String-">getTopologySummaryByName</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> name)</code> </td> |
| </tr> |
| <tr id="i49" class="rowColor"> |
| <td class="colFirst"><code><a href="https://docs.oracle.com/javase/8/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/LocalCluster.html#getTrackedId--">getTrackedId</a></span>()</code> |
| <div class="block">If the cluster is tracked get the id for the tracked cluster.</div> |
| </td> |
| </tr> |
| <tr id="i50" class="altColor"> |
| <td class="colFirst"><code><a href="../../../org/apache/storm/generated/StormTopology.html" title="class in org.apache.storm.generated">StormTopology</a></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#getUserTopology-java.lang.String-">getUserTopology</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> id)</code> |
| <div class="block">Returns the user specified topology as submitted originally.</div> |
| </td> |
| </tr> |
| <tr id="i51" class="rowColor"> |
| <td class="colFirst"><code>boolean</code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#isRemoteBlobExists-java.lang.String-">isRemoteBlobExists</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> blobKey)</code> |
| <div class="block">Decide if the blob is removed from cluster.</div> |
| </td> |
| </tr> |
| <tr id="i52" class="altColor"> |
| <td class="colFirst"><code>boolean</code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#isTopologyNameAllowed-java.lang.String-">isTopologyNameAllowed</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> name)</code> </td> |
| </tr> |
| <tr id="i53" class="rowColor"> |
| <td class="colFirst"><code>void</code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#killSupervisor-java.lang.String-">killSupervisor</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> id)</code> |
| <div class="block">Kill a specific supervisor.</div> |
| </td> |
| </tr> |
| <tr id="i54" class="altColor"> |
| <td class="colFirst"><code>void</code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#killTopology-java.lang.String-">killTopology</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> topologyName)</code> |
| <div class="block">Kill a topology (if you are not using ILocalTopology).</div> |
| </td> |
| </tr> |
| <tr id="i55" class="rowColor"> |
| <td class="colFirst"><code>void</code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#killTopologyWithOpts-java.lang.String-org.apache.storm.generated.KillOptions-">killTopologyWithOpts</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> name, |
| <a href="../../../org/apache/storm/generated/KillOptions.html" title="class in org.apache.storm.generated">KillOptions</a> options)</code> |
| <div class="block">Kill a topology (if you are not using ILocalTopology).</div> |
| </td> |
| </tr> |
| <tr id="i56" class="altColor"> |
| <td class="colFirst"><code><a href="../../../org/apache/storm/generated/ListBlobsResult.html" title="class in org.apache.storm.generated">ListBlobsResult</a></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#listBlobs-java.lang.String-">listBlobs</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> session)</code> </td> |
| </tr> |
| <tr id="i57" class="rowColor"> |
| <td class="colFirst"><code>static void</code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#main-java.lang.String:A-">main</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>[] args)</code> |
| <div class="block">Main entry point to running in local mode.</div> |
| </td> |
| </tr> |
| <tr id="i58" class="altColor"> |
| <td class="colFirst"><code>void</code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#processWorkerMetrics-org.apache.storm.generated.WorkerMetrics-">processWorkerMetrics</a></span>(<a href="../../../org/apache/storm/generated/WorkerMetrics.html" title="class in org.apache.storm.generated">WorkerMetrics</a> metrics)</code> </td> |
| </tr> |
| <tr id="i59" class="rowColor"> |
| <td class="colFirst"><code>void</code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#rebalance-java.lang.String-org.apache.storm.generated.RebalanceOptions-">rebalance</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> name, |
| <a href="../../../org/apache/storm/generated/RebalanceOptions.html" title="class in org.apache.storm.generated">RebalanceOptions</a> options)</code> |
| <div class="block">Rebalance a topology.</div> |
| </td> |
| </tr> |
| <tr id="i60" class="altColor"> |
| <td class="colFirst"><code>void</code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#sendSupervisorWorkerHeartbeat-org.apache.storm.generated.SupervisorWorkerHeartbeat-">sendSupervisorWorkerHeartbeat</a></span>(<a href="../../../org/apache/storm/generated/SupervisorWorkerHeartbeat.html" title="class in org.apache.storm.generated">SupervisorWorkerHeartbeat</a> heatbeat)</code> |
| <div class="block">Send supervisor local worker heartbeat when a supervisor is unreachable</div> |
| </td> |
| </tr> |
| <tr id="i61" class="rowColor"> |
| <td class="colFirst"><code>void</code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#sendSupervisorWorkerHeartbeats-org.apache.storm.generated.SupervisorWorkerHeartbeats-">sendSupervisorWorkerHeartbeats</a></span>(<a href="../../../org/apache/storm/generated/SupervisorWorkerHeartbeats.html" title="class in org.apache.storm.generated">SupervisorWorkerHeartbeats</a> heartbeats)</code> |
| <div class="block">Send supervisor worker heartbeats for a specific supervisor</div> |
| </td> |
| </tr> |
| <tr id="i62" class="altColor"> |
| <td class="colFirst"><code>void</code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#setBlobMeta-java.lang.String-org.apache.storm.generated.SettableBlobMeta-">setBlobMeta</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> key, |
| <a href="../../../org/apache/storm/generated/SettableBlobMeta.html" title="class in org.apache.storm.generated">SettableBlobMeta</a> meta)</code> </td> |
| </tr> |
| <tr id="i63" class="rowColor"> |
| <td class="colFirst"><code>void</code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#setLogConfig-java.lang.String-org.apache.storm.generated.LogConfig-">setLogConfig</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> name, |
| <a href="../../../org/apache/storm/generated/LogConfig.html" title="class in org.apache.storm.generated">LogConfig</a> config)</code> </td> |
| </tr> |
| <tr id="i64" class="altColor"> |
| <td class="colFirst"><code>void</code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#setWorkerProfiler-java.lang.String-org.apache.storm.generated.ProfileRequest-">setWorkerProfiler</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> id, |
| <a href="../../../org/apache/storm/generated/ProfileRequest.html" title="class in org.apache.storm.generated">ProfileRequest</a> profileRequest)</code> </td> |
| </tr> |
| <tr id="i65" class="rowColor"> |
| <td class="colFirst"><code>void</code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#shutdown--">shutdown</a></span>()</code> |
| <div class="block">Shut down the cluster.</div> |
| </td> |
| </tr> |
| <tr id="i66" class="altColor"> |
| <td class="colFirst"><code><a href="../../../org/apache/storm/LocalCluster.LocalTopology.html" title="class in org.apache.storm">LocalCluster.LocalTopology</a></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#submitTopology-java.lang.String-java.util.Map-org.apache.storm.generated.StormTopology-">submitTopology</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> topologyName, |
| <a href="https://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="https://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="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a>> conf, |
| <a href="../../../org/apache/storm/generated/StormTopology.html" title="class in org.apache.storm.generated">StormTopology</a> topology)</code> |
| <div class="block">Submit a topology to be run in local mode.</div> |
| </td> |
| </tr> |
| <tr id="i67" class="rowColor"> |
| <td class="colFirst"><code><a href="../../../org/apache/storm/LocalCluster.LocalTopology.html" title="class in org.apache.storm">LocalCluster.LocalTopology</a></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#submitTopology-java.lang.String-java.util.Map-org.apache.storm.testing.TrackedTopology-">submitTopology</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> topologyName, |
| <a href="https://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="https://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="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a>> conf, |
| <a href="../../../org/apache/storm/testing/TrackedTopology.html" title="class in org.apache.storm.testing">TrackedTopology</a> topology)</code> |
| <div class="block">Submit a tracked topology to be run in local mode.</div> |
| </td> |
| </tr> |
| <tr id="i68" class="altColor"> |
| <td class="colFirst"><code>void</code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#submitTopology-java.lang.String-java.lang.String-java.lang.String-org.apache.storm.generated.StormTopology-">submitTopology</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> name, |
| <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> uploadedJarLocation, |
| <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> jsonConf, |
| <a href="../../../org/apache/storm/generated/StormTopology.html" title="class in org.apache.storm.generated">StormTopology</a> topology)</code> </td> |
| </tr> |
| <tr id="i69" class="rowColor"> |
| <td class="colFirst"><code><a href="../../../org/apache/storm/LocalCluster.LocalTopology.html" title="class in org.apache.storm">LocalCluster.LocalTopology</a></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#submitTopologyWithOpts-java.lang.String-java.util.Map-org.apache.storm.generated.StormTopology-org.apache.storm.generated.SubmitOptions-">submitTopologyWithOpts</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> topologyName, |
| <a href="https://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="https://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="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a>> conf, |
| <a href="../../../org/apache/storm/generated/StormTopology.html" title="class in org.apache.storm.generated">StormTopology</a> topology, |
| <a href="../../../org/apache/storm/generated/SubmitOptions.html" title="class in org.apache.storm.generated">SubmitOptions</a> submitOpts)</code> |
| <div class="block">Submit a topology to be run in local mode.</div> |
| </td> |
| </tr> |
| <tr id="i70" class="altColor"> |
| <td class="colFirst"><code><a href="../../../org/apache/storm/LocalCluster.LocalTopology.html" title="class in org.apache.storm">LocalCluster.LocalTopology</a></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#submitTopologyWithOpts-java.lang.String-java.util.Map-org.apache.storm.testing.TrackedTopology-org.apache.storm.generated.SubmitOptions-">submitTopologyWithOpts</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> topologyName, |
| <a href="https://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="https://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="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a>> conf, |
| <a href="../../../org/apache/storm/testing/TrackedTopology.html" title="class in org.apache.storm.testing">TrackedTopology</a> topology, |
| <a href="../../../org/apache/storm/generated/SubmitOptions.html" title="class in org.apache.storm.generated">SubmitOptions</a> submitOpts)</code> |
| <div class="block">Submit a tracked topology to be run in local mode.</div> |
| </td> |
| </tr> |
| <tr id="i71" class="rowColor"> |
| <td class="colFirst"><code>void</code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#submitTopologyWithOpts-java.lang.String-java.lang.String-java.lang.String-org.apache.storm.generated.StormTopology-org.apache.storm.generated.SubmitOptions-">submitTopologyWithOpts</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> name, |
| <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> uploadedJarLocation, |
| <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> jsonConf, |
| <a href="../../../org/apache/storm/generated/StormTopology.html" title="class in org.apache.storm.generated">StormTopology</a> topology, |
| <a href="../../../org/apache/storm/generated/SubmitOptions.html" title="class in org.apache.storm.generated">SubmitOptions</a> options)</code> </td> |
| </tr> |
| <tr id="i72" class="altColor"> |
| <td class="colFirst"><code>int</code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#updateBlobReplication-java.lang.String-int-">updateBlobReplication</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> key, |
| int replication)</code> </td> |
| </tr> |
| <tr id="i73" class="rowColor"> |
| <td class="colFirst"><code>void</code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#uploadBlobChunk-java.lang.String-java.nio.ByteBuffer-">uploadBlobChunk</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> session, |
| <a href="https://docs.oracle.com/javase/8/docs/api/java/nio/ByteBuffer.html?is-external=true" title="class or interface in java.nio">ByteBuffer</a> chunk)</code> </td> |
| </tr> |
| <tr id="i74" class="altColor"> |
| <td class="colFirst"><code>void</code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#uploadChunk-java.lang.String-java.nio.ByteBuffer-">uploadChunk</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> location, |
| <a href="https://docs.oracle.com/javase/8/docs/api/java/nio/ByteBuffer.html?is-external=true" title="class or interface in java.nio">ByteBuffer</a> chunk)</code> </td> |
| </tr> |
| <tr id="i75" class="rowColor"> |
| <td class="colFirst"><code>void</code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#uploadNewCredentials-java.lang.String-org.apache.storm.generated.Credentials-">uploadNewCredentials</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> topologyName, |
| <a href="../../../org/apache/storm/generated/Credentials.html" title="class in org.apache.storm.generated">Credentials</a> creds)</code> |
| <div class="block">Upload new credentials to a topology.</div> |
| </td> |
| </tr> |
| <tr id="i76" class="altColor"> |
| <td class="colFirst"><code>void</code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#waitForIdle--">waitForIdle</a></span>()</code> |
| <div class="block">Wait for the cluster to be idle.</div> |
| </td> |
| </tr> |
| <tr id="i77" class="rowColor"> |
| <td class="colFirst"><code>void</code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#waitForIdle-long-">waitForIdle</a></span>(long timeoutMs)</code> |
| <div class="block">Wait for the cluster to be idle.</div> |
| </td> |
| </tr> |
| <tr id="i78" class="altColor"> |
| <td class="colFirst"><code>static <T> T</code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#withLocalModeOverride-java.util.concurrent.Callable-long-">withLocalModeOverride</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/Callable.html?is-external=true" title="class or interface in java.util.concurrent">Callable</a><T> c, |
| long ttlSec)</code> |
| <div class="block">Run c with a local mode cluster overriding the NimbusClient and DRPCClient calls.</div> |
| </td> |
| </tr> |
| <tr id="i79" class="rowColor"> |
| <td class="colFirst"><code>static <T> T</code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../org/apache/storm/LocalCluster.html#withLocalModeOverride-java.util.concurrent.Callable-long-java.util.Map-">withLocalModeOverride</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/Callable.html?is-external=true" title="class or interface in java.util.concurrent">Callable</a><T> c, |
| long ttlSec, |
| <a href="https://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="https://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="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a>> daemonConf)</code> |
| <div class="block">Run c with a local mode cluster overriding the NimbusClient and DRPCClient calls.</div> |
| </td> |
| </tr> |
| </table> |
| <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="https://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="https://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="https://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="https://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="https://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="https://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="https://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="https://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="https://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="https://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="https://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="https://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> |
| </li> |
| </ul> |
| </div> |
| <div class="details"> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <!-- ============ FIELD DETAIL =========== --> |
| <ul class="blockList"> |
| <li class="blockList"><a name="field.detail"> |
| <!-- --> |
| </a> |
| <h3>Field Detail</h3> |
| <a name="KILL_NOW"> |
| <!-- --> |
| </a> |
| <ul class="blockListLast"> |
| <li class="blockList"> |
| <h4>KILL_NOW</h4> |
| <pre>public static final <a href="../../../org/apache/storm/generated/KillOptions.html" title="class in org.apache.storm.generated">KillOptions</a> KILL_NOW</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| <!-- ========= CONSTRUCTOR DETAIL ======== --> |
| <ul class="blockList"> |
| <li class="blockList"><a name="constructor.detail"> |
| <!-- --> |
| </a> |
| <h3>Constructor Detail</h3> |
| <a name="LocalCluster--"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>LocalCluster</h4> |
| <pre>public LocalCluster() |
| throws <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true" title="class or interface in java.lang">Exception</a></pre> |
| <div class="block"><p>Create a default LocalCluster.</p></div> |
| <dl> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code><a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true" title="class or interface in java.lang">Exception</a></code> - on any error</dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="LocalCluster-java.lang.String-java.lang.Long-"> |
| <!-- --> |
| </a> |
| <ul class="blockListLast"> |
| <li class="blockList"> |
| <h4>LocalCluster</h4> |
| <pre>public LocalCluster(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> zkHost, |
| <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Long.html?is-external=true" title="class or interface in java.lang">Long</a> zkPort) |
| throws <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true" title="class or interface in java.lang">Exception</a></pre> |
| <div class="block"><p>Create a LocalCluster that connects to an existing Zookeeper instance.</p></div> |
| <dl> |
| <dt><span class="paramLabel">Parameters:</span></dt> |
| <dd><code>zkHost</code> - the host for ZK</dd> |
| <dd><code>zkPort</code> - the port for ZK</dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code><a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true" title="class or interface in java.lang">Exception</a></code> - on any error</dd> |
| </dl> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| <!-- ============ METHOD DETAIL ========== --> |
| <ul class="blockList"> |
| <li class="blockList"><a name="method.detail"> |
| <!-- --> |
| </a> |
| <h3>Method Detail</h3> |
| <a name="withLocalModeOverride-java.util.concurrent.Callable-long-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>withLocalModeOverride</h4> |
| <pre>public static <T> T withLocalModeOverride(<a href="https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/Callable.html?is-external=true" title="class or interface in java.util.concurrent">Callable</a><T> c, |
| long ttlSec) |
| throws <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true" title="class or interface in java.lang">Exception</a></pre> |
| <div class="block"><p>Run c with a local mode cluster overriding the NimbusClient and DRPCClient calls. NOTE local mode override happens by default now unless netty is turned on for the local cluster.</p></div> |
| <dl> |
| <dt><span class="paramLabel">Parameters:</span></dt> |
| <dd><code>c</code> - the callable to run in this mode</dd> |
| <dd><code>ttlSec</code> - the number of seconds to let the cluster run after c has completed</dd> |
| <dt><span class="returnLabel">Returns:</span></dt> |
| <dd>the result of calling C</dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code><a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true" title="class or interface in java.lang">Exception</a></code> - on any Exception.</dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="withLocalModeOverride-java.util.concurrent.Callable-long-java.util.Map-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>withLocalModeOverride</h4> |
| <pre>public static <T> T withLocalModeOverride(<a href="https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/Callable.html?is-external=true" title="class or interface in java.util.concurrent">Callable</a><T> c, |
| long ttlSec, |
| <a href="https://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="https://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="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a>> daemonConf) |
| throws <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true" title="class or interface in java.lang">Exception</a></pre> |
| <div class="block"><p>Run c with a local mode cluster overriding the NimbusClient and DRPCClient calls. NOTE local mode override happens by default now unless netty is turned on for the local cluster.</p></div> |
| <dl> |
| <dt><span class="paramLabel">Parameters:</span></dt> |
| <dd><code>c</code> - the callable to run in this mode</dd> |
| <dd><code>ttlSec</code> - the number of seconds to let the cluster run after c has completed</dd> |
| <dd><code>daemonConf</code> - configs to set for the daemon processes.</dd> |
| <dt><span class="returnLabel">Returns:</span></dt> |
| <dd>the result of calling C</dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code><a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true" title="class or interface in java.lang">Exception</a></code> - on any Exception.</dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="main-java.lang.String:A-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>main</h4> |
| <pre>public static void main(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>[] args) |
| throws <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true" title="class or interface in java.lang">Exception</a></pre> |
| <div class="block"><p>Main entry point to running in local mode.</p></div> |
| <dl> |
| <dt><span class="paramLabel">Parameters:</span></dt> |
| <dd><code>args</code> - arguments to be run in local mode</dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code><a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true" title="class or interface in java.lang">Exception</a></code> - on any error when running.</dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="getNimbus--"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>getNimbus</h4> |
| <pre>public <a href="../../../org/apache/storm/daemon/nimbus/Nimbus.html" title="class in org.apache.storm.daemon.nimbus">Nimbus</a> getNimbus()</pre> |
| <div class="block"><p>Reference to nimbus.</p></div> |
| <dl> |
| <dt><span class="returnLabel">Returns:</span></dt> |
| <dd>Nimbus itself so you can interact with it directly, if needed.</dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="getMetricRegistry--"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>getMetricRegistry</h4> |
| <pre>public <a href="../../../org/apache/storm/metric/StormMetricsRegistry.html" title="class in org.apache.storm.metric">StormMetricsRegistry</a> getMetricRegistry()</pre> |
| <div class="block"><p>Reference to metrics registry.</p></div> |
| <dl> |
| <dt><span class="returnLabel">Returns:</span></dt> |
| <dd>The metrics registry for the local cluster.</dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="getDaemonConf--"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>getDaemonConf</h4> |
| <pre>public <a href="https://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="https://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="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a>> getDaemonConf()</pre> |
| <div class="block"><p>Get daemon configuration.</p></div> |
| <dl> |
| <dt><span class="returnLabel">Returns:</span></dt> |
| <dd>the base config for the daemons</dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="submitTopology-java.lang.String-java.util.Map-org.apache.storm.generated.StormTopology-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>submitTopology</h4> |
| <pre>public <a href="../../../org/apache/storm/LocalCluster.LocalTopology.html" title="class in org.apache.storm">LocalCluster.LocalTopology</a> submitTopology(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> topologyName, |
| <a href="https://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="https://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="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a>> conf, |
| <a href="../../../org/apache/storm/generated/StormTopology.html" title="class in org.apache.storm.generated">StormTopology</a> topology) |
| throws org.apache.storm.thrift.TException</pre> |
| <div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../org/apache/storm/ILocalCluster.html#submitTopology-java.lang.String-java.util.Map-org.apache.storm.generated.StormTopology-">ILocalCluster</a></code></span></div> |
| <div class="block"><p>Submit a topology to be run in local mode.</p></div> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/ILocalCluster.html#submitTopology-java.lang.String-java.util.Map-org.apache.storm.generated.StormTopology-">submitTopology</a></code> in interface <code><a href="../../../org/apache/storm/ILocalCluster.html" title="interface in org.apache.storm">ILocalCluster</a></code></dd> |
| <dt><span class="paramLabel">Parameters:</span></dt> |
| <dd><code>topologyName</code> - the name of the topology to use</dd> |
| <dd><code>conf</code> - the config for the topology</dd> |
| <dd><code>topology</code> - the topology itself.</dd> |
| <dt><span class="returnLabel">Returns:</span></dt> |
| <dd>an AutoCloseable that will kill the topology.</dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code>org.apache.storm.thrift.TException</code> - on any error from nimbus</dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="submitTopology-java.lang.String-java.util.Map-org.apache.storm.testing.TrackedTopology-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>submitTopology</h4> |
| <pre>public <a href="../../../org/apache/storm/LocalCluster.LocalTopology.html" title="class in org.apache.storm">LocalCluster.LocalTopology</a> submitTopology(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> topologyName, |
| <a href="https://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="https://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="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a>> conf, |
| <a href="../../../org/apache/storm/testing/TrackedTopology.html" title="class in org.apache.storm.testing">TrackedTopology</a> topology) |
| throws org.apache.storm.thrift.TException</pre> |
| <div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../org/apache/storm/ILocalClusterTrackedTopologyAware.html#submitTopology-java.lang.String-java.util.Map-org.apache.storm.testing.TrackedTopology-">ILocalClusterTrackedTopologyAware</a></code></span></div> |
| <div class="block"><p>Submit a tracked topology to be run in local mode.</p></div> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/ILocalClusterTrackedTopologyAware.html#submitTopology-java.lang.String-java.util.Map-org.apache.storm.testing.TrackedTopology-">submitTopology</a></code> in interface <code><a href="../../../org/apache/storm/ILocalClusterTrackedTopologyAware.html" title="interface in org.apache.storm">ILocalClusterTrackedTopologyAware</a></code></dd> |
| <dt><span class="paramLabel">Parameters:</span></dt> |
| <dd><code>topologyName</code> - the name of the topology to use</dd> |
| <dd><code>conf</code> - the config for the topology</dd> |
| <dd><code>topology</code> - the topology itself.</dd> |
| <dt><span class="returnLabel">Returns:</span></dt> |
| <dd>an AutoCloseable that will kill the topology.</dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code>org.apache.storm.thrift.TException</code> - on any error from nimbus</dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="submitTopology-java.lang.String-java.lang.String-java.lang.String-org.apache.storm.generated.StormTopology-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>submitTopology</h4> |
| <pre>public void submitTopology(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> name, |
| <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> uploadedJarLocation, |
| <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> jsonConf, |
| <a href="../../../org/apache/storm/generated/StormTopology.html" title="class in org.apache.storm.generated">StormTopology</a> topology) |
| throws <a href="../../../org/apache/storm/generated/AlreadyAliveException.html" title="class in org.apache.storm.generated">AlreadyAliveException</a>, |
| <a href="../../../org/apache/storm/generated/InvalidTopologyException.html" title="class in org.apache.storm.generated">InvalidTopologyException</a>, |
| <a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a>, |
| org.apache.storm.thrift.TException</pre> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#submitTopology-java.lang.String-java.lang.String-java.lang.String-org.apache.storm.generated.StormTopology-">submitTopology</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/AlreadyAliveException.html" title="class in org.apache.storm.generated">AlreadyAliveException</a></code></dd> |
| <dd><code><a href="../../../org/apache/storm/generated/InvalidTopologyException.html" title="class in org.apache.storm.generated">InvalidTopologyException</a></code></dd> |
| <dd><code><a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a></code></dd> |
| <dd><code>org.apache.storm.thrift.TException</code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="submitTopologyWithOpts-java.lang.String-java.util.Map-org.apache.storm.generated.StormTopology-org.apache.storm.generated.SubmitOptions-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>submitTopologyWithOpts</h4> |
| <pre>public <a href="../../../org/apache/storm/LocalCluster.LocalTopology.html" title="class in org.apache.storm">LocalCluster.LocalTopology</a> submitTopologyWithOpts(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> topologyName, |
| <a href="https://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="https://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="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a>> conf, |
| <a href="../../../org/apache/storm/generated/StormTopology.html" title="class in org.apache.storm.generated">StormTopology</a> topology, |
| <a href="../../../org/apache/storm/generated/SubmitOptions.html" title="class in org.apache.storm.generated">SubmitOptions</a> submitOpts) |
| throws org.apache.storm.thrift.TException</pre> |
| <div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../org/apache/storm/ILocalCluster.html#submitTopologyWithOpts-java.lang.String-java.util.Map-org.apache.storm.generated.StormTopology-org.apache.storm.generated.SubmitOptions-">ILocalCluster</a></code></span></div> |
| <div class="block"><p>Submit a topology to be run in local mode.</p></div> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/ILocalCluster.html#submitTopologyWithOpts-java.lang.String-java.util.Map-org.apache.storm.generated.StormTopology-org.apache.storm.generated.SubmitOptions-">submitTopologyWithOpts</a></code> in interface <code><a href="../../../org/apache/storm/ILocalCluster.html" title="interface in org.apache.storm">ILocalCluster</a></code></dd> |
| <dt><span class="paramLabel">Parameters:</span></dt> |
| <dd><code>topologyName</code> - the name of the topology to use</dd> |
| <dd><code>conf</code> - the config for the topology</dd> |
| <dd><code>topology</code> - the topology itself.</dd> |
| <dd><code>submitOpts</code> - options for topology</dd> |
| <dt><span class="returnLabel">Returns:</span></dt> |
| <dd>an AutoCloseable that will kill the topology.</dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code>org.apache.storm.thrift.TException</code> - on any error from nimbus</dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="submitTopologyWithOpts-java.lang.String-java.util.Map-org.apache.storm.testing.TrackedTopology-org.apache.storm.generated.SubmitOptions-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>submitTopologyWithOpts</h4> |
| <pre>public <a href="../../../org/apache/storm/LocalCluster.LocalTopology.html" title="class in org.apache.storm">LocalCluster.LocalTopology</a> submitTopologyWithOpts(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> topologyName, |
| <a href="https://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="https://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="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a>> conf, |
| <a href="../../../org/apache/storm/testing/TrackedTopology.html" title="class in org.apache.storm.testing">TrackedTopology</a> topology, |
| <a href="../../../org/apache/storm/generated/SubmitOptions.html" title="class in org.apache.storm.generated">SubmitOptions</a> submitOpts) |
| throws org.apache.storm.thrift.TException</pre> |
| <div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../org/apache/storm/ILocalClusterTrackedTopologyAware.html#submitTopologyWithOpts-java.lang.String-java.util.Map-org.apache.storm.testing.TrackedTopology-org.apache.storm.generated.SubmitOptions-">ILocalClusterTrackedTopologyAware</a></code></span></div> |
| <div class="block"><p>Submit a tracked topology to be run in local mode.</p></div> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/ILocalClusterTrackedTopologyAware.html#submitTopologyWithOpts-java.lang.String-java.util.Map-org.apache.storm.testing.TrackedTopology-org.apache.storm.generated.SubmitOptions-">submitTopologyWithOpts</a></code> in interface <code><a href="../../../org/apache/storm/ILocalClusterTrackedTopologyAware.html" title="interface in org.apache.storm">ILocalClusterTrackedTopologyAware</a></code></dd> |
| <dt><span class="paramLabel">Parameters:</span></dt> |
| <dd><code>topologyName</code> - the name of the topology to use</dd> |
| <dd><code>conf</code> - the config for the topology</dd> |
| <dd><code>topology</code> - the topology itself.</dd> |
| <dd><code>submitOpts</code> - options for topology</dd> |
| <dt><span class="returnLabel">Returns:</span></dt> |
| <dd>an AutoCloseable that will kill the topology.</dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code>org.apache.storm.thrift.TException</code> - on any error from nimbus</dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="submitTopologyWithOpts-java.lang.String-java.lang.String-java.lang.String-org.apache.storm.generated.StormTopology-org.apache.storm.generated.SubmitOptions-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>submitTopologyWithOpts</h4> |
| <pre>public void submitTopologyWithOpts(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> name, |
| <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> uploadedJarLocation, |
| <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> jsonConf, |
| <a href="../../../org/apache/storm/generated/StormTopology.html" title="class in org.apache.storm.generated">StormTopology</a> topology, |
| <a href="../../../org/apache/storm/generated/SubmitOptions.html" title="class in org.apache.storm.generated">SubmitOptions</a> options) |
| throws <a href="../../../org/apache/storm/generated/AlreadyAliveException.html" title="class in org.apache.storm.generated">AlreadyAliveException</a>, |
| <a href="../../../org/apache/storm/generated/InvalidTopologyException.html" title="class in org.apache.storm.generated">InvalidTopologyException</a>, |
| <a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a>, |
| org.apache.storm.thrift.TException</pre> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#submitTopologyWithOpts-java.lang.String-java.lang.String-java.lang.String-org.apache.storm.generated.StormTopology-org.apache.storm.generated.SubmitOptions-">submitTopologyWithOpts</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/AlreadyAliveException.html" title="class in org.apache.storm.generated">AlreadyAliveException</a></code></dd> |
| <dd><code><a href="../../../org/apache/storm/generated/InvalidTopologyException.html" title="class in org.apache.storm.generated">InvalidTopologyException</a></code></dd> |
| <dd><code><a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a></code></dd> |
| <dd><code>org.apache.storm.thrift.TException</code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="uploadNewCredentials-java.lang.String-org.apache.storm.generated.Credentials-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>uploadNewCredentials</h4> |
| <pre>public void uploadNewCredentials(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> topologyName, |
| <a href="../../../org/apache/storm/generated/Credentials.html" title="class in org.apache.storm.generated">Credentials</a> creds) |
| throws org.apache.storm.thrift.TException</pre> |
| <div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../org/apache/storm/ILocalCluster.html#uploadNewCredentials-java.lang.String-org.apache.storm.generated.Credentials-">ILocalCluster</a></code></span></div> |
| <div class="block"><p>Upload new credentials to a topology.</p></div> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#uploadNewCredentials-java.lang.String-org.apache.storm.generated.Credentials-">uploadNewCredentials</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/ILocalCluster.html#uploadNewCredentials-java.lang.String-org.apache.storm.generated.Credentials-">uploadNewCredentials</a></code> in interface <code><a href="../../../org/apache/storm/ILocalCluster.html" title="interface in org.apache.storm">ILocalCluster</a></code></dd> |
| <dt><span class="paramLabel">Parameters:</span></dt> |
| <dd><code>topologyName</code> - the name of the topology</dd> |
| <dd><code>creds</code> - the new credentails for the topology.</dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code>org.apache.storm.thrift.TException</code> - on any error from nimbus</dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="killTopology-java.lang.String-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>killTopology</h4> |
| <pre>public void killTopology(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> topologyName) |
| throws org.apache.storm.thrift.TException</pre> |
| <div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../org/apache/storm/ILocalCluster.html#killTopology-java.lang.String-">ILocalCluster</a></code></span></div> |
| <div class="block"><p>Kill a topology (if you are not using ILocalTopology).</p></div> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#killTopology-java.lang.String-">killTopology</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/ILocalCluster.html#killTopology-java.lang.String-">killTopology</a></code> in interface <code><a href="../../../org/apache/storm/ILocalCluster.html" title="interface in org.apache.storm">ILocalCluster</a></code></dd> |
| <dt><span class="paramLabel">Parameters:</span></dt> |
| <dd><code>topologyName</code> - the name of the topology</dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code>org.apache.storm.thrift.TException</code> - on any error from nimbus</dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="killTopologyWithOpts-java.lang.String-org.apache.storm.generated.KillOptions-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>killTopologyWithOpts</h4> |
| <pre>public void killTopologyWithOpts(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> name, |
| <a href="../../../org/apache/storm/generated/KillOptions.html" title="class in org.apache.storm.generated">KillOptions</a> options) |
| throws org.apache.storm.thrift.TException</pre> |
| <div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../org/apache/storm/ILocalCluster.html#killTopologyWithOpts-java.lang.String-org.apache.storm.generated.KillOptions-">ILocalCluster</a></code></span></div> |
| <div class="block"><p>Kill a topology (if you are not using ILocalTopology).</p></div> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#killTopologyWithOpts-java.lang.String-org.apache.storm.generated.KillOptions-">killTopologyWithOpts</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/ILocalCluster.html#killTopologyWithOpts-java.lang.String-org.apache.storm.generated.KillOptions-">killTopologyWithOpts</a></code> in interface <code><a href="../../../org/apache/storm/ILocalCluster.html" title="interface in org.apache.storm">ILocalCluster</a></code></dd> |
| <dd><code>options</code> - for how to kill the topology</dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code>org.apache.storm.thrift.TException</code> - on any error from nimbus</dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="activate-java.lang.String-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>activate</h4> |
| <pre>public void activate(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> topologyName) |
| throws org.apache.storm.thrift.TException</pre> |
| <div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../org/apache/storm/ILocalCluster.html#activate-java.lang.String-">ILocalCluster</a></code></span></div> |
| <div class="block"><p>Activate a topology.</p></div> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#activate-java.lang.String-">activate</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/ILocalCluster.html#activate-java.lang.String-">activate</a></code> in interface <code><a href="../../../org/apache/storm/ILocalCluster.html" title="interface in org.apache.storm">ILocalCluster</a></code></dd> |
| <dt><span class="paramLabel">Parameters:</span></dt> |
| <dd><code>topologyName</code> - the name of the topology to activate</dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code>org.apache.storm.thrift.TException</code> - on any error from nimbus</dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="deactivate-java.lang.String-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>deactivate</h4> |
| <pre>public void deactivate(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> topologyName) |
| throws org.apache.storm.thrift.TException</pre> |
| <div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../org/apache/storm/ILocalCluster.html#deactivate-java.lang.String-">ILocalCluster</a></code></span></div> |
| <div class="block"><p>Deactivate a topology.</p></div> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#deactivate-java.lang.String-">deactivate</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/ILocalCluster.html#deactivate-java.lang.String-">deactivate</a></code> in interface <code><a href="../../../org/apache/storm/ILocalCluster.html" title="interface in org.apache.storm">ILocalCluster</a></code></dd> |
| <dt><span class="paramLabel">Parameters:</span></dt> |
| <dd><code>topologyName</code> - the name of the topology to deactivate</dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code>org.apache.storm.thrift.TException</code> - on any error from nimbus</dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="rebalance-java.lang.String-org.apache.storm.generated.RebalanceOptions-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>rebalance</h4> |
| <pre>public void rebalance(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> name, |
| <a href="../../../org/apache/storm/generated/RebalanceOptions.html" title="class in org.apache.storm.generated">RebalanceOptions</a> options) |
| throws org.apache.storm.thrift.TException</pre> |
| <div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../org/apache/storm/ILocalCluster.html#rebalance-java.lang.String-org.apache.storm.generated.RebalanceOptions-">ILocalCluster</a></code></span></div> |
| <div class="block"><p>Rebalance a topology.</p></div> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#rebalance-java.lang.String-org.apache.storm.generated.RebalanceOptions-">rebalance</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/ILocalCluster.html#rebalance-java.lang.String-org.apache.storm.generated.RebalanceOptions-">rebalance</a></code> in interface <code><a href="../../../org/apache/storm/ILocalCluster.html" title="interface in org.apache.storm">ILocalCluster</a></code></dd> |
| <dt><span class="paramLabel">Parameters:</span></dt> |
| <dd><code>name</code> - the name of the topology</dd> |
| <dd><code>options</code> - options for rebalanceing the topology.</dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code>org.apache.storm.thrift.TException</code> - on any error from nimbus</dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="shutdown--"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>shutdown</h4> |
| <pre>public void shutdown()</pre> |
| <div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../org/apache/storm/ILocalCluster.html#shutdown--">ILocalCluster</a></code></span></div> |
| <div class="block"><p>Shut down the cluster.</p></div> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/ILocalCluster.html#shutdown--">shutdown</a></code> in interface <code><a href="../../../org/apache/storm/ILocalCluster.html" title="interface in org.apache.storm">ILocalCluster</a></code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="getTopologyConf-java.lang.String-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>getTopologyConf</h4> |
| <pre>public <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> getTopologyConf(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> id) |
| throws org.apache.storm.thrift.TException</pre> |
| <div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../org/apache/storm/ILocalCluster.html#getTopologyConf-java.lang.String-">ILocalCluster</a></code></span></div> |
| <div class="block"><p>The config of a topology as a JSON string.</p></div> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#getTopologyConf-java.lang.String-">getTopologyConf</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/ILocalCluster.html#getTopologyConf-java.lang.String-">getTopologyConf</a></code> in interface <code><a href="../../../org/apache/storm/ILocalCluster.html" title="interface in org.apache.storm">ILocalCluster</a></code></dd> |
| <dt><span class="paramLabel">Parameters:</span></dt> |
| <dd><code>id</code> - the id of the topology (not the name)</dd> |
| <dt><span class="returnLabel">Returns:</span></dt> |
| <dd>The config of a topology as a JSON string</dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code>org.apache.storm.thrift.TException</code> - on any error from nimbus</dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="getTopology-java.lang.String-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>getTopology</h4> |
| <pre>public <a href="../../../org/apache/storm/generated/StormTopology.html" title="class in org.apache.storm.generated">StormTopology</a> getTopology(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> id) |
| throws org.apache.storm.thrift.TException</pre> |
| <div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../org/apache/storm/ILocalCluster.html#getTopology-java.lang.String-">ILocalCluster</a></code></span></div> |
| <div class="block"><p>Get the compiled storm topology.</p></div> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#getTopology-java.lang.String-">getTopology</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/ILocalCluster.html#getTopology-java.lang.String-">getTopology</a></code> in interface <code><a href="../../../org/apache/storm/ILocalCluster.html" title="interface in org.apache.storm">ILocalCluster</a></code></dd> |
| <dt><span class="paramLabel">Parameters:</span></dt> |
| <dd><code>id</code> - the id of the topology (not the name)</dd> |
| <dt><span class="returnLabel">Returns:</span></dt> |
| <dd>the compiled storm topology</dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code>org.apache.storm.thrift.TException</code> - on any error from nimbus</dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="getClusterInfo--"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>getClusterInfo</h4> |
| <pre>public <a href="../../../org/apache/storm/generated/ClusterSummary.html" title="class in org.apache.storm.generated">ClusterSummary</a> getClusterInfo() |
| throws org.apache.storm.thrift.TException</pre> |
| <div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../org/apache/storm/ILocalCluster.html#getClusterInfo--">ILocalCluster</a></code></span></div> |
| <div class="block"><p>Get cluster information.</p></div> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#getClusterInfo--">getClusterInfo</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/ILocalCluster.html#getClusterInfo--">getClusterInfo</a></code> in interface <code><a href="../../../org/apache/storm/ILocalCluster.html" title="interface in org.apache.storm">ILocalCluster</a></code></dd> |
| <dt><span class="returnLabel">Returns:</span></dt> |
| <dd>a summary of the current state of the cluster</dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code>org.apache.storm.thrift.TException</code> - on any error from nimbus</dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="getTopologySummaries--"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>getTopologySummaries</h4> |
| <pre>public <a href="https://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="../../../org/apache/storm/generated/TopologySummary.html" title="class in org.apache.storm.generated">TopologySummary</a>> getTopologySummaries() |
| throws org.apache.storm.thrift.TException</pre> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#getTopologySummaries--">getTopologySummaries</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/ILocalCluster.html#getTopologySummaries--">getTopologySummaries</a></code> in interface <code><a href="../../../org/apache/storm/ILocalCluster.html" title="interface in org.apache.storm">ILocalCluster</a></code></dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code>org.apache.storm.thrift.TException</code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="getTopologySummaryByName-java.lang.String-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>getTopologySummaryByName</h4> |
| <pre>public <a href="../../../org/apache/storm/generated/TopologySummary.html" title="class in org.apache.storm.generated">TopologySummary</a> getTopologySummaryByName(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> name) |
| throws org.apache.storm.thrift.TException</pre> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#getTopologySummaryByName-java.lang.String-">getTopologySummaryByName</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/ILocalCluster.html#getTopologySummaryByName-java.lang.String-">getTopologySummaryByName</a></code> in interface <code><a href="../../../org/apache/storm/ILocalCluster.html" title="interface in org.apache.storm">ILocalCluster</a></code></dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code>org.apache.storm.thrift.TException</code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="getTopologySummary-java.lang.String-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>getTopologySummary</h4> |
| <pre>public <a href="../../../org/apache/storm/generated/TopologySummary.html" title="class in org.apache.storm.generated">TopologySummary</a> getTopologySummary(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> id) |
| throws org.apache.storm.thrift.TException</pre> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#getTopologySummary-java.lang.String-">getTopologySummary</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/ILocalCluster.html#getTopologySummary-java.lang.String-">getTopologySummary</a></code> in interface <code><a href="../../../org/apache/storm/ILocalCluster.html" title="interface in org.apache.storm">ILocalCluster</a></code></dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code>org.apache.storm.thrift.TException</code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="getTopologyInfo-java.lang.String-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>getTopologyInfo</h4> |
| <pre>public <a href="../../../org/apache/storm/generated/TopologyInfo.html" title="class in org.apache.storm.generated">TopologyInfo</a> getTopologyInfo(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> id) |
| throws org.apache.storm.thrift.TException</pre> |
| <div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../org/apache/storm/ILocalCluster.html#getTopologyInfo-java.lang.String-">ILocalCluster</a></code></span></div> |
| <div class="block"><p>Get the state of a topology.</p></div> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#getTopologyInfo-java.lang.String-">getTopologyInfo</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/ILocalCluster.html#getTopologyInfo-java.lang.String-">getTopologyInfo</a></code> in interface <code><a href="../../../org/apache/storm/ILocalCluster.html" title="interface in org.apache.storm">ILocalCluster</a></code></dd> |
| <dt><span class="paramLabel">Parameters:</span></dt> |
| <dd><code>id</code> - the id of the topology (not the name)</dd> |
| <dt><span class="returnLabel">Returns:</span></dt> |
| <dd>the state of a topology</dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code>org.apache.storm.thrift.TException</code> - on any error from nimbus</dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="getTopologyInfoByName-java.lang.String-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>getTopologyInfoByName</h4> |
| <pre>public <a href="../../../org/apache/storm/generated/TopologyInfo.html" title="class in org.apache.storm.generated">TopologyInfo</a> getTopologyInfoByName(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> name) |
| throws org.apache.storm.thrift.TException</pre> |
| <div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../org/apache/storm/ILocalCluster.html#getTopologyInfoByName-java.lang.String-">ILocalCluster</a></code></span></div> |
| <div class="block"><p>Get the state of a topology.</p></div> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#getTopologyInfoByName-java.lang.String-">getTopologyInfoByName</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/ILocalCluster.html#getTopologyInfoByName-java.lang.String-">getTopologyInfoByName</a></code> in interface <code><a href="../../../org/apache/storm/ILocalCluster.html" title="interface in org.apache.storm">ILocalCluster</a></code></dd> |
| <dt><span class="paramLabel">Parameters:</span></dt> |
| <dd><code>name</code> - the name of the topology (not the id)</dd> |
| <dt><span class="returnLabel">Returns:</span></dt> |
| <dd>the state of a topology</dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code>org.apache.storm.thrift.TException</code> - on any error from nimbus</dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="getTopologyInfoWithOpts-java.lang.String-org.apache.storm.generated.GetInfoOptions-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>getTopologyInfoWithOpts</h4> |
| <pre>public <a href="../../../org/apache/storm/generated/TopologyInfo.html" title="class in org.apache.storm.generated">TopologyInfo</a> getTopologyInfoWithOpts(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> id, |
| <a href="../../../org/apache/storm/generated/GetInfoOptions.html" title="class in org.apache.storm.generated">GetInfoOptions</a> options) |
| throws org.apache.storm.thrift.TException</pre> |
| <div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../org/apache/storm/ILocalCluster.html#getTopologyInfoWithOpts-java.lang.String-org.apache.storm.generated.GetInfoOptions-">ILocalCluster</a></code></span></div> |
| <div class="block"><p>Get the state of a topology.</p></div> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#getTopologyInfoWithOpts-java.lang.String-org.apache.storm.generated.GetInfoOptions-">getTopologyInfoWithOpts</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/ILocalCluster.html#getTopologyInfoWithOpts-java.lang.String-org.apache.storm.generated.GetInfoOptions-">getTopologyInfoWithOpts</a></code> in interface <code><a href="../../../org/apache/storm/ILocalCluster.html" title="interface in org.apache.storm">ILocalCluster</a></code></dd> |
| <dt><span class="paramLabel">Parameters:</span></dt> |
| <dd><code>id</code> - the id of the topology (not the name)</dd> |
| <dd><code>options</code> - This is to choose number of Error(s) in TopologyInfo.</dd> |
| <dt><span class="returnLabel">Returns:</span></dt> |
| <dd>the state of a topology</dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code>org.apache.storm.thrift.TException</code> - on any error from nimbus</dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="getTopologyInfoByNameWithOpts-java.lang.String-org.apache.storm.generated.GetInfoOptions-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>getTopologyInfoByNameWithOpts</h4> |
| <pre>public <a href="../../../org/apache/storm/generated/TopologyInfo.html" title="class in org.apache.storm.generated">TopologyInfo</a> getTopologyInfoByNameWithOpts(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> name, |
| <a href="../../../org/apache/storm/generated/GetInfoOptions.html" title="class in org.apache.storm.generated">GetInfoOptions</a> options) |
| throws org.apache.storm.thrift.TException</pre> |
| <div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../org/apache/storm/ILocalCluster.html#getTopologyInfoByNameWithOpts-java.lang.String-org.apache.storm.generated.GetInfoOptions-">ILocalCluster</a></code></span></div> |
| <div class="block"><p>Get the state of a topology.</p></div> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#getTopologyInfoByNameWithOpts-java.lang.String-org.apache.storm.generated.GetInfoOptions-">getTopologyInfoByNameWithOpts</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/ILocalCluster.html#getTopologyInfoByNameWithOpts-java.lang.String-org.apache.storm.generated.GetInfoOptions-">getTopologyInfoByNameWithOpts</a></code> in interface <code><a href="../../../org/apache/storm/ILocalCluster.html" title="interface in org.apache.storm">ILocalCluster</a></code></dd> |
| <dt><span class="paramLabel">Parameters:</span></dt> |
| <dd><code>name</code> - the name of the topology (not the id)</dd> |
| <dd><code>options</code> - This is GetInfoOptions to choose Error(s) in on TopologyInfo.</dd> |
| <dt><span class="returnLabel">Returns:</span></dt> |
| <dd>the state of a topology</dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code>org.apache.storm.thrift.TException</code> - on any error from nimbus</dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="getThriftServerPort--"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>getThriftServerPort</h4> |
| <pre>public int getThriftServerPort()</pre> |
| </li> |
| </ul> |
| <a name="isRemoteBlobExists-java.lang.String-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>isRemoteBlobExists</h4> |
| <pre>public boolean isRemoteBlobExists(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> blobKey) |
| throws <a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a>, |
| org.apache.storm.thrift.TException</pre> |
| <div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#isRemoteBlobExists-java.lang.String-">Nimbus.Iface</a></code></span></div> |
| <div class="block"><p>Decide if the blob is removed from cluster.</p></div> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#isRemoteBlobExists-java.lang.String-">isRemoteBlobExists</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a></code></dd> |
| <dd><code>org.apache.storm.thrift.TException</code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="close--"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>close</h4> |
| <pre>public void close() |
| throws <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true" title="class or interface in java.lang">Exception</a></pre> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="https://docs.oracle.com/javase/8/docs/api/java/lang/AutoCloseable.html?is-external=true#close--" title="class or interface in java.lang">close</a></code> in interface <code><a href="https://docs.oracle.com/javase/8/docs/api/java/lang/AutoCloseable.html?is-external=true" title="class or interface in java.lang">AutoCloseable</a></code></dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code><a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true" title="class or interface in java.lang">Exception</a></code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="getSupervisor-java.lang.String-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>getSupervisor</h4> |
| <pre>public <a href="../../../org/apache/storm/daemon/supervisor/Supervisor.html" title="class in org.apache.storm.daemon.supervisor">Supervisor</a> getSupervisor(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> id)</pre> |
| <div class="block"><p>Get a specific Supervisor. This is intended mostly for internal testing.</p></div> |
| <dl> |
| <dt><span class="paramLabel">Parameters:</span></dt> |
| <dd><code>id</code> - the id of the supervisor</dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="killSupervisor-java.lang.String-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>killSupervisor</h4> |
| <pre>public void killSupervisor(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> id)</pre> |
| <div class="block"><p>Kill a specific supervisor. This is intended mostly for internal testing.</p></div> |
| <dl> |
| <dt><span class="paramLabel">Parameters:</span></dt> |
| <dd><code>id</code> - the id of the supervisor</dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="addSupervisor--"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>addSupervisor</h4> |
| <pre>public <a href="../../../org/apache/storm/daemon/supervisor/Supervisor.html" title="class in org.apache.storm.daemon.supervisor">Supervisor</a> addSupervisor() |
| throws <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true" title="class or interface in java.lang">Exception</a></pre> |
| <div class="block"><p>Add another supervisor to the topology. This is intended mostly for internal testing.</p></div> |
| <dl> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code><a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true" title="class or interface in java.lang">Exception</a></code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="addSupervisor-java.lang.Number-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>addSupervisor</h4> |
| <pre>public <a href="../../../org/apache/storm/daemon/supervisor/Supervisor.html" title="class in org.apache.storm.daemon.supervisor">Supervisor</a> addSupervisor(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Number.html?is-external=true" title="class or interface in java.lang">Number</a> ports) |
| throws <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true" title="class or interface in java.lang">Exception</a></pre> |
| <div class="block"><p>Add another supervisor to the topology. This is intended mostly for internal testing.</p></div> |
| <dl> |
| <dt><span class="paramLabel">Parameters:</span></dt> |
| <dd><code>ports</code> - the number of ports/slots the supervisor should have</dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code><a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true" title="class or interface in java.lang">Exception</a></code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="addSupervisor-java.lang.Number-java.lang.String-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>addSupervisor</h4> |
| <pre>public <a href="../../../org/apache/storm/daemon/supervisor/Supervisor.html" title="class in org.apache.storm.daemon.supervisor">Supervisor</a> addSupervisor(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Number.html?is-external=true" title="class or interface in java.lang">Number</a> ports, |
| <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> id) |
| throws <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true" title="class or interface in java.lang">Exception</a></pre> |
| <div class="block"><p>Add another supervisor to the topology. This is intended mostly for internal testing.</p></div> |
| <dl> |
| <dt><span class="paramLabel">Parameters:</span></dt> |
| <dd><code>ports</code> - the number of ports/slots the supervisor should have</dd> |
| <dd><code>id</code> - the id of the new supervisor, so you can find it later.</dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code><a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true" title="class or interface in java.lang">Exception</a></code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="addSupervisor-java.lang.Number-java.util.Map-java.lang.String-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>addSupervisor</h4> |
| <pre>public <a href="../../../org/apache/storm/daemon/supervisor/Supervisor.html" title="class in org.apache.storm.daemon.supervisor">Supervisor</a> addSupervisor(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Number.html?is-external=true" title="class or interface in java.lang">Number</a> ports, |
| <a href="https://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="https://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="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a>> conf, |
| <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> id) |
| throws <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true" title="class or interface in java.lang">Exception</a></pre> |
| <div class="block"><p>Add another supervisor to the topology. This is intended mostly for internal testing.</p></div> |
| <dl> |
| <dt><span class="paramLabel">Parameters:</span></dt> |
| <dd><code>ports</code> - the number of ports/slots the supervisor should have</dd> |
| <dd><code>conf</code> - any config values that should be added/over written in the daemon conf of the cluster.</dd> |
| <dd><code>id</code> - the id of the new supervisor, so you can find it later.</dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code><a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true" title="class or interface in java.lang">Exception</a></code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="waitForIdle--"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>waitForIdle</h4> |
| <pre>public void waitForIdle() |
| throws <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/InterruptedException.html?is-external=true" title="class or interface in java.lang">InterruptedException</a></pre> |
| <div class="block"><p>Wait for the cluster to be idle. This is intended to be used with Simulated time and is for internal testing. Note that this does not wait for spout or bolt executors to be idle.</p></div> |
| <dl> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code><a href="https://docs.oracle.com/javase/8/docs/api/java/lang/InterruptedException.html?is-external=true" title="class or interface in java.lang">InterruptedException</a></code> - if interrupted while waiting.</dd> |
| <dd><code><a href="https://docs.oracle.com/javase/8/docs/api/java/lang/AssertionError.html?is-external=true" title="class or interface in java.lang">AssertionError</a></code> - if the cluster did not come to an idle point with a timeout.</dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="waitForIdle-long-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>waitForIdle</h4> |
| <pre>public void waitForIdle(long timeoutMs) |
| throws <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/InterruptedException.html?is-external=true" title="class or interface in java.lang">InterruptedException</a></pre> |
| <div class="block"><p>Wait for the cluster to be idle. This is intended to be used with Simulated time and is for internal testing. Note that this does not wait for spout or bolt executors to be idle.</p></div> |
| <dl> |
| <dt><span class="paramLabel">Parameters:</span></dt> |
| <dd><code>timeoutMs</code> - the number of ms to wait before throwing an error.</dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code><a href="https://docs.oracle.com/javase/8/docs/api/java/lang/InterruptedException.html?is-external=true" title="class or interface in java.lang">InterruptedException</a></code> - if interrupted while waiting.</dd> |
| <dd><code><a href="https://docs.oracle.com/javase/8/docs/api/java/lang/AssertionError.html?is-external=true" title="class or interface in java.lang">AssertionError</a></code> - if the cluster did not come to an idle point with a timeout.</dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="advanceClusterTime-int-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>advanceClusterTime</h4> |
| <pre>public void advanceClusterTime(int secs) |
| throws <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/InterruptedException.html?is-external=true" title="class or interface in java.lang">InterruptedException</a></pre> |
| <div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../org/apache/storm/ILocalCluster.html#advanceClusterTime-int-">ILocalCluster</a></code></span></div> |
| <div class="block"><p>Advance the cluster time when the cluster is using SimulatedTime. This is intended for internal testing only.</p></div> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/ILocalCluster.html#advanceClusterTime-int-">advanceClusterTime</a></code> in interface <code><a href="../../../org/apache/storm/ILocalCluster.html" title="interface in org.apache.storm">ILocalCluster</a></code></dd> |
| <dt><span class="paramLabel">Parameters:</span></dt> |
| <dd><code>secs</code> - the number of seconds to advance time</dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code><a href="https://docs.oracle.com/javase/8/docs/api/java/lang/InterruptedException.html?is-external=true" title="class or interface in java.lang">InterruptedException</a></code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="advanceClusterTime-int-int-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>advanceClusterTime</h4> |
| <pre>public void advanceClusterTime(int secs, |
| int incSecs) |
| throws <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/InterruptedException.html?is-external=true" title="class or interface in java.lang">InterruptedException</a></pre> |
| <div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../org/apache/storm/ILocalCluster.html#advanceClusterTime-int-int-">ILocalCluster</a></code></span></div> |
| <div class="block"><p>Advance the cluster time when the cluster is using SimulatedTime. This is intended for internal testing only.</p></div> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/ILocalCluster.html#advanceClusterTime-int-int-">advanceClusterTime</a></code> in interface <code><a href="../../../org/apache/storm/ILocalCluster.html" title="interface in org.apache.storm">ILocalCluster</a></code></dd> |
| <dt><span class="paramLabel">Parameters:</span></dt> |
| <dd><code>secs</code> - the number of seconds to advance time</dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code><a href="https://docs.oracle.com/javase/8/docs/api/java/lang/InterruptedException.html?is-external=true" title="class or interface in java.lang">InterruptedException</a></code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="getClusterState--"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>getClusterState</h4> |
| <pre>public <a href="../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a> getClusterState()</pre> |
| <div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../org/apache/storm/ILocalCluster.html#getClusterState--">ILocalCluster</a></code></span></div> |
| <div class="block"><p>This is intended for internal testing only.</p></div> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/ILocalCluster.html#getClusterState--">getClusterState</a></code> in interface <code><a href="../../../org/apache/storm/ILocalCluster.html" title="interface in org.apache.storm">ILocalCluster</a></code></dd> |
| <dt><span class="returnLabel">Returns:</span></dt> |
| <dd>an internal class that holds the state of the cluster.</dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="getTrackedId--"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>getTrackedId</h4> |
| <pre>public <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> getTrackedId()</pre> |
| <div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../org/apache/storm/ILocalCluster.html#getTrackedId--">ILocalCluster</a></code></span></div> |
| <div class="block"><p>If the cluster is tracked get the id for the tracked cluster. This is intended for internal testing only.</p></div> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/ILocalCluster.html#getTrackedId--">getTrackedId</a></code> in interface <code><a href="../../../org/apache/storm/ILocalCluster.html" title="interface in org.apache.storm">ILocalCluster</a></code></dd> |
| <dt><span class="returnLabel">Returns:</span></dt> |
| <dd>the id of the tracked cluster</dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="setLogConfig-java.lang.String-org.apache.storm.generated.LogConfig-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setLogConfig</h4> |
| <pre>public void setLogConfig(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> name, |
| <a href="../../../org/apache/storm/generated/LogConfig.html" title="class in org.apache.storm.generated">LogConfig</a> config) |
| throws org.apache.storm.thrift.TException</pre> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#setLogConfig-java.lang.String-org.apache.storm.generated.LogConfig-">setLogConfig</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code>org.apache.storm.thrift.TException</code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="getLogConfig-java.lang.String-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>getLogConfig</h4> |
| <pre>public <a href="../../../org/apache/storm/generated/LogConfig.html" title="class in org.apache.storm.generated">LogConfig</a> getLogConfig(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> name) |
| throws org.apache.storm.thrift.TException</pre> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#getLogConfig-java.lang.String-">getLogConfig</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code>org.apache.storm.thrift.TException</code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="debug-java.lang.String-java.lang.String-boolean-double-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>debug</h4> |
| <pre>public void debug(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> name, |
| <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> component, |
| boolean enable, |
| double samplingPercentage) |
| throws <a href="../../../org/apache/storm/generated/NotAliveException.html" title="class in org.apache.storm.generated">NotAliveException</a>, |
| <a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a>, |
| org.apache.storm.thrift.TException</pre> |
| <div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#debug-java.lang.String-java.lang.String-boolean-double-">Nimbus.Iface</a></code></span></div> |
| <div class="block"><p>Enable/disable logging the tuples generated in topology via an internal EventLogger bolt. The component name is optional and if null or empty, the debug flag will apply to the entire topology.</p><p>The ‘samplingPercentage’ will limit loggging to a percentage of generated tuples.</p></div> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#debug-java.lang.String-java.lang.String-boolean-double-">debug</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/NotAliveException.html" title="class in org.apache.storm.generated">NotAliveException</a></code></dd> |
| <dd><code><a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a></code></dd> |
| <dd><code>org.apache.storm.thrift.TException</code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="setWorkerProfiler-java.lang.String-org.apache.storm.generated.ProfileRequest-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setWorkerProfiler</h4> |
| <pre>public void setWorkerProfiler(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> id, |
| <a href="../../../org/apache/storm/generated/ProfileRequest.html" title="class in org.apache.storm.generated">ProfileRequest</a> profileRequest) |
| throws org.apache.storm.thrift.TException</pre> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#setWorkerProfiler-java.lang.String-org.apache.storm.generated.ProfileRequest-">setWorkerProfiler</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code>org.apache.storm.thrift.TException</code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="getComponentPendingProfileActions-java.lang.String-java.lang.String-org.apache.storm.generated.ProfileAction-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>getComponentPendingProfileActions</h4> |
| <pre>public <a href="https://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="../../../org/apache/storm/generated/ProfileRequest.html" title="class in org.apache.storm.generated">ProfileRequest</a>> getComponentPendingProfileActions(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> id, |
| <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> componentId, |
| <a href="../../../org/apache/storm/generated/ProfileAction.html" title="enum in org.apache.storm.generated">ProfileAction</a> action) |
| throws org.apache.storm.thrift.TException</pre> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#getComponentPendingProfileActions-java.lang.String-java.lang.String-org.apache.storm.generated.ProfileAction-">getComponentPendingProfileActions</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code>org.apache.storm.thrift.TException</code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="beginCreateBlob-java.lang.String-org.apache.storm.generated.SettableBlobMeta-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>beginCreateBlob</h4> |
| <pre>public <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> beginCreateBlob(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> key, |
| <a href="../../../org/apache/storm/generated/SettableBlobMeta.html" title="class in org.apache.storm.generated">SettableBlobMeta</a> meta) |
| throws <a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a>, |
| <a href="../../../org/apache/storm/generated/KeyAlreadyExistsException.html" title="class in org.apache.storm.generated">KeyAlreadyExistsException</a>, |
| org.apache.storm.thrift.TException</pre> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#beginCreateBlob-java.lang.String-org.apache.storm.generated.SettableBlobMeta-">beginCreateBlob</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a></code></dd> |
| <dd><code><a href="../../../org/apache/storm/generated/KeyAlreadyExistsException.html" title="class in org.apache.storm.generated">KeyAlreadyExistsException</a></code></dd> |
| <dd><code>org.apache.storm.thrift.TException</code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="beginUpdateBlob-java.lang.String-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>beginUpdateBlob</h4> |
| <pre>public <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> beginUpdateBlob(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> key) |
| throws <a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a>, |
| <a href="../../../org/apache/storm/generated/KeyNotFoundException.html" title="class in org.apache.storm.generated">KeyNotFoundException</a>, |
| org.apache.storm.thrift.TException</pre> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#beginUpdateBlob-java.lang.String-">beginUpdateBlob</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a></code></dd> |
| <dd><code><a href="../../../org/apache/storm/generated/KeyNotFoundException.html" title="class in org.apache.storm.generated">KeyNotFoundException</a></code></dd> |
| <dd><code>org.apache.storm.thrift.TException</code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="uploadBlobChunk-java.lang.String-java.nio.ByteBuffer-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>uploadBlobChunk</h4> |
| <pre>public void uploadBlobChunk(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> session, |
| <a href="https://docs.oracle.com/javase/8/docs/api/java/nio/ByteBuffer.html?is-external=true" title="class or interface in java.nio">ByteBuffer</a> chunk) |
| throws <a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a>, |
| org.apache.storm.thrift.TException</pre> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#uploadBlobChunk-java.lang.String-java.nio.ByteBuffer-">uploadBlobChunk</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a></code></dd> |
| <dd><code>org.apache.storm.thrift.TException</code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="finishBlobUpload-java.lang.String-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>finishBlobUpload</h4> |
| <pre>public void finishBlobUpload(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> session) |
| throws <a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a>, |
| org.apache.storm.thrift.TException</pre> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#finishBlobUpload-java.lang.String-">finishBlobUpload</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a></code></dd> |
| <dd><code>org.apache.storm.thrift.TException</code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="cancelBlobUpload-java.lang.String-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>cancelBlobUpload</h4> |
| <pre>public void cancelBlobUpload(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> session) |
| throws <a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a>, |
| org.apache.storm.thrift.TException</pre> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#cancelBlobUpload-java.lang.String-">cancelBlobUpload</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a></code></dd> |
| <dd><code>org.apache.storm.thrift.TException</code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="getBlobMeta-java.lang.String-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>getBlobMeta</h4> |
| <pre>public <a href="../../../org/apache/storm/generated/ReadableBlobMeta.html" title="class in org.apache.storm.generated">ReadableBlobMeta</a> getBlobMeta(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> key) |
| throws <a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a>, |
| <a href="../../../org/apache/storm/generated/KeyNotFoundException.html" title="class in org.apache.storm.generated">KeyNotFoundException</a>, |
| org.apache.storm.thrift.TException</pre> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#getBlobMeta-java.lang.String-">getBlobMeta</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a></code></dd> |
| <dd><code><a href="../../../org/apache/storm/generated/KeyNotFoundException.html" title="class in org.apache.storm.generated">KeyNotFoundException</a></code></dd> |
| <dd><code>org.apache.storm.thrift.TException</code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="setBlobMeta-java.lang.String-org.apache.storm.generated.SettableBlobMeta-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setBlobMeta</h4> |
| <pre>public void setBlobMeta(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> key, |
| <a href="../../../org/apache/storm/generated/SettableBlobMeta.html" title="class in org.apache.storm.generated">SettableBlobMeta</a> meta) |
| throws <a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a>, |
| <a href="../../../org/apache/storm/generated/KeyNotFoundException.html" title="class in org.apache.storm.generated">KeyNotFoundException</a>, |
| org.apache.storm.thrift.TException</pre> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#setBlobMeta-java.lang.String-org.apache.storm.generated.SettableBlobMeta-">setBlobMeta</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a></code></dd> |
| <dd><code><a href="../../../org/apache/storm/generated/KeyNotFoundException.html" title="class in org.apache.storm.generated">KeyNotFoundException</a></code></dd> |
| <dd><code>org.apache.storm.thrift.TException</code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="beginBlobDownload-java.lang.String-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>beginBlobDownload</h4> |
| <pre>public <a href="../../../org/apache/storm/generated/BeginDownloadResult.html" title="class in org.apache.storm.generated">BeginDownloadResult</a> beginBlobDownload(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> key) |
| throws <a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a>, |
| <a href="../../../org/apache/storm/generated/KeyNotFoundException.html" title="class in org.apache.storm.generated">KeyNotFoundException</a>, |
| org.apache.storm.thrift.TException</pre> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#beginBlobDownload-java.lang.String-">beginBlobDownload</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a></code></dd> |
| <dd><code><a href="../../../org/apache/storm/generated/KeyNotFoundException.html" title="class in org.apache.storm.generated">KeyNotFoundException</a></code></dd> |
| <dd><code>org.apache.storm.thrift.TException</code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="downloadBlobChunk-java.lang.String-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>downloadBlobChunk</h4> |
| <pre>public <a href="https://docs.oracle.com/javase/8/docs/api/java/nio/ByteBuffer.html?is-external=true" title="class or interface in java.nio">ByteBuffer</a> downloadBlobChunk(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> session) |
| throws <a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a>, |
| org.apache.storm.thrift.TException</pre> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#downloadBlobChunk-java.lang.String-">downloadBlobChunk</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a></code></dd> |
| <dd><code>org.apache.storm.thrift.TException</code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="deleteBlob-java.lang.String-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>deleteBlob</h4> |
| <pre>public void deleteBlob(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> key) |
| throws <a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a>, |
| <a href="../../../org/apache/storm/generated/KeyNotFoundException.html" title="class in org.apache.storm.generated">KeyNotFoundException</a>, |
| org.apache.storm.thrift.TException</pre> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#deleteBlob-java.lang.String-">deleteBlob</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a></code></dd> |
| <dd><code><a href="../../../org/apache/storm/generated/KeyNotFoundException.html" title="class in org.apache.storm.generated">KeyNotFoundException</a></code></dd> |
| <dd><code>org.apache.storm.thrift.TException</code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="listBlobs-java.lang.String-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>listBlobs</h4> |
| <pre>public <a href="../../../org/apache/storm/generated/ListBlobsResult.html" title="class in org.apache.storm.generated">ListBlobsResult</a> listBlobs(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> session) |
| throws org.apache.storm.thrift.TException</pre> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#listBlobs-java.lang.String-">listBlobs</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code>org.apache.storm.thrift.TException</code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="getBlobReplication-java.lang.String-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>getBlobReplication</h4> |
| <pre>public int getBlobReplication(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> key) |
| throws <a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a>, |
| <a href="../../../org/apache/storm/generated/KeyNotFoundException.html" title="class in org.apache.storm.generated">KeyNotFoundException</a>, |
| org.apache.storm.thrift.TException</pre> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#getBlobReplication-java.lang.String-">getBlobReplication</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a></code></dd> |
| <dd><code><a href="../../../org/apache/storm/generated/KeyNotFoundException.html" title="class in org.apache.storm.generated">KeyNotFoundException</a></code></dd> |
| <dd><code>org.apache.storm.thrift.TException</code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="updateBlobReplication-java.lang.String-int-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>updateBlobReplication</h4> |
| <pre>public int updateBlobReplication(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> key, |
| int replication) |
| throws <a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a>, |
| <a href="../../../org/apache/storm/generated/KeyNotFoundException.html" title="class in org.apache.storm.generated">KeyNotFoundException</a>, |
| org.apache.storm.thrift.TException</pre> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#updateBlobReplication-java.lang.String-int-">updateBlobReplication</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a></code></dd> |
| <dd><code><a href="../../../org/apache/storm/generated/KeyNotFoundException.html" title="class in org.apache.storm.generated">KeyNotFoundException</a></code></dd> |
| <dd><code>org.apache.storm.thrift.TException</code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="createStateInZookeeper-java.lang.String-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>createStateInZookeeper</h4> |
| <pre>public void createStateInZookeeper(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> key) |
| throws org.apache.storm.thrift.TException</pre> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#createStateInZookeeper-java.lang.String-">createStateInZookeeper</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code>org.apache.storm.thrift.TException</code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="beginFileUpload--"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>beginFileUpload</h4> |
| <pre>public <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> beginFileUpload() |
| throws <a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a>, |
| org.apache.storm.thrift.TException</pre> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#beginFileUpload--">beginFileUpload</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a></code></dd> |
| <dd><code>org.apache.storm.thrift.TException</code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="uploadChunk-java.lang.String-java.nio.ByteBuffer-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>uploadChunk</h4> |
| <pre>public void uploadChunk(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> location, |
| <a href="https://docs.oracle.com/javase/8/docs/api/java/nio/ByteBuffer.html?is-external=true" title="class or interface in java.nio">ByteBuffer</a> chunk) |
| throws <a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a>, |
| org.apache.storm.thrift.TException</pre> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#uploadChunk-java.lang.String-java.nio.ByteBuffer-">uploadChunk</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a></code></dd> |
| <dd><code>org.apache.storm.thrift.TException</code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="finishFileUpload-java.lang.String-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>finishFileUpload</h4> |
| <pre>public void finishFileUpload(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> location) |
| throws <a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a>, |
| org.apache.storm.thrift.TException</pre> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#finishFileUpload-java.lang.String-">finishFileUpload</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a></code></dd> |
| <dd><code>org.apache.storm.thrift.TException</code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="downloadChunk-java.lang.String-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>downloadChunk</h4> |
| <pre>public <a href="https://docs.oracle.com/javase/8/docs/api/java/nio/ByteBuffer.html?is-external=true" title="class or interface in java.nio">ByteBuffer</a> downloadChunk(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> id) |
| throws <a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a>, |
| org.apache.storm.thrift.TException</pre> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#downloadChunk-java.lang.String-">downloadChunk</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a></code></dd> |
| <dd><code>org.apache.storm.thrift.TException</code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="getNimbusConf--"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>getNimbusConf</h4> |
| <pre>public <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> getNimbusConf() |
| throws <a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a>, |
| org.apache.storm.thrift.TException</pre> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#getNimbusConf--">getNimbusConf</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a></code></dd> |
| <dd><code>org.apache.storm.thrift.TException</code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="getLeader--"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>getLeader</h4> |
| <pre>public <a href="../../../org/apache/storm/generated/NimbusSummary.html" title="class in org.apache.storm.generated">NimbusSummary</a> getLeader() |
| throws <a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a>, |
| org.apache.storm.thrift.TException</pre> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#getLeader--">getLeader</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a></code></dd> |
| <dd><code>org.apache.storm.thrift.TException</code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="isTopologyNameAllowed-java.lang.String-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>isTopologyNameAllowed</h4> |
| <pre>public boolean isTopologyNameAllowed(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> name) |
| throws <a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a>, |
| org.apache.storm.thrift.TException</pre> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#isTopologyNameAllowed-java.lang.String-">isTopologyNameAllowed</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a></code></dd> |
| <dd><code>org.apache.storm.thrift.TException</code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="getTopologyPageInfo-java.lang.String-java.lang.String-boolean-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>getTopologyPageInfo</h4> |
| <pre>public <a href="../../../org/apache/storm/generated/TopologyPageInfo.html" title="class in org.apache.storm.generated">TopologyPageInfo</a> getTopologyPageInfo(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> id, |
| <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> window, |
| boolean isIncludeSys) |
| throws <a href="../../../org/apache/storm/generated/NotAliveException.html" title="class in org.apache.storm.generated">NotAliveException</a>, |
| <a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a>, |
| org.apache.storm.thrift.TException</pre> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#getTopologyPageInfo-java.lang.String-java.lang.String-boolean-">getTopologyPageInfo</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/NotAliveException.html" title="class in org.apache.storm.generated">NotAliveException</a></code></dd> |
| <dd><code><a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a></code></dd> |
| <dd><code>org.apache.storm.thrift.TException</code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="getSupervisorPageInfo-java.lang.String-java.lang.String-boolean-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>getSupervisorPageInfo</h4> |
| <pre>public <a href="../../../org/apache/storm/generated/SupervisorPageInfo.html" title="class in org.apache.storm.generated">SupervisorPageInfo</a> getSupervisorPageInfo(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> id, |
| <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> host, |
| boolean isIncludeSys) |
| throws <a href="../../../org/apache/storm/generated/NotAliveException.html" title="class in org.apache.storm.generated">NotAliveException</a>, |
| <a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a>, |
| org.apache.storm.thrift.TException</pre> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#getSupervisorPageInfo-java.lang.String-java.lang.String-boolean-">getSupervisorPageInfo</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/NotAliveException.html" title="class in org.apache.storm.generated">NotAliveException</a></code></dd> |
| <dd><code><a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a></code></dd> |
| <dd><code>org.apache.storm.thrift.TException</code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="getComponentPageInfo-java.lang.String-java.lang.String-java.lang.String-boolean-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>getComponentPageInfo</h4> |
| <pre>public <a href="../../../org/apache/storm/generated/ComponentPageInfo.html" title="class in org.apache.storm.generated">ComponentPageInfo</a> getComponentPageInfo(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> topologyId, |
| <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> componentId, |
| <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> window, |
| boolean isIncludeSys) |
| throws <a href="../../../org/apache/storm/generated/NotAliveException.html" title="class in org.apache.storm.generated">NotAliveException</a>, |
| <a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a>, |
| org.apache.storm.thrift.TException</pre> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#getComponentPageInfo-java.lang.String-java.lang.String-java.lang.String-boolean-">getComponentPageInfo</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/NotAliveException.html" title="class in org.apache.storm.generated">NotAliveException</a></code></dd> |
| <dd><code><a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a></code></dd> |
| <dd><code>org.apache.storm.thrift.TException</code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="getUserTopology-java.lang.String-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>getUserTopology</h4> |
| <pre>public <a href="../../../org/apache/storm/generated/StormTopology.html" title="class in org.apache.storm.generated">StormTopology</a> getUserTopology(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> id) |
| throws <a href="../../../org/apache/storm/generated/NotAliveException.html" title="class in org.apache.storm.generated">NotAliveException</a>, |
| <a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a>, |
| org.apache.storm.thrift.TException</pre> |
| <div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#getUserTopology-java.lang.String-">Nimbus.Iface</a></code></span></div> |
| <div class="block"><p>Returns the user specified topology as submitted originally. Compare <a href="../../../org/apache/storm/generated/Nimbus.Iface.html#getTopology-java.lang.String-"><code>Nimbus.Iface.getTopology(String id)</code></a>.</p></div> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#getUserTopology-java.lang.String-">getUserTopology</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/NotAliveException.html" title="class in org.apache.storm.generated">NotAliveException</a></code></dd> |
| <dd><code><a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a></code></dd> |
| <dd><code>org.apache.storm.thrift.TException</code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="getTopologyHistory-java.lang.String-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>getTopologyHistory</h4> |
| <pre>public <a href="../../../org/apache/storm/generated/TopologyHistoryInfo.html" title="class in org.apache.storm.generated">TopologyHistoryInfo</a> getTopologyHistory(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> user) |
| throws <a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a>, |
| org.apache.storm.thrift.TException</pre> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#getTopologyHistory-java.lang.String-">getTopologyHistory</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a></code></dd> |
| <dd><code>org.apache.storm.thrift.TException</code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="getOwnerResourceSummaries-java.lang.String-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>getOwnerResourceSummaries</h4> |
| <pre>public <a href="https://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="../../../org/apache/storm/generated/OwnerResourceSummary.html" title="class in org.apache.storm.generated">OwnerResourceSummary</a>> getOwnerResourceSummaries(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> owner) |
| throws <a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a>, |
| org.apache.storm.thrift.TException</pre> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#getOwnerResourceSummaries-java.lang.String-">getOwnerResourceSummaries</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a></code></dd> |
| <dd><code>org.apache.storm.thrift.TException</code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="getSupervisorAssignments-java.lang.String-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>getSupervisorAssignments</h4> |
| <pre>public <a href="../../../org/apache/storm/generated/SupervisorAssignments.html" title="class in org.apache.storm.generated">SupervisorAssignments</a> getSupervisorAssignments(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> node) |
| throws <a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a>, |
| org.apache.storm.thrift.TException</pre> |
| <div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#getSupervisorAssignments-java.lang.String-">Nimbus.Iface</a></code></span></div> |
| <div class="block"><p>Get assigned assignments for a specific supervisor</p></div> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#getSupervisorAssignments-java.lang.String-">getSupervisorAssignments</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a></code></dd> |
| <dd><code>org.apache.storm.thrift.TException</code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="sendSupervisorWorkerHeartbeats-org.apache.storm.generated.SupervisorWorkerHeartbeats-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>sendSupervisorWorkerHeartbeats</h4> |
| <pre>public void sendSupervisorWorkerHeartbeats(<a href="../../../org/apache/storm/generated/SupervisorWorkerHeartbeats.html" title="class in org.apache.storm.generated">SupervisorWorkerHeartbeats</a> heartbeats) |
| throws <a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a>, |
| org.apache.storm.thrift.TException</pre> |
| <div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#sendSupervisorWorkerHeartbeats-org.apache.storm.generated.SupervisorWorkerHeartbeats-">Nimbus.Iface</a></code></span></div> |
| <div class="block"><p>Send supervisor worker heartbeats for a specific supervisor</p></div> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#sendSupervisorWorkerHeartbeats-org.apache.storm.generated.SupervisorWorkerHeartbeats-">sendSupervisorWorkerHeartbeats</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a></code></dd> |
| <dd><code>org.apache.storm.thrift.TException</code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="sendSupervisorWorkerHeartbeat-org.apache.storm.generated.SupervisorWorkerHeartbeat-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>sendSupervisorWorkerHeartbeat</h4> |
| <pre>public void sendSupervisorWorkerHeartbeat(<a href="../../../org/apache/storm/generated/SupervisorWorkerHeartbeat.html" title="class in org.apache.storm.generated">SupervisorWorkerHeartbeat</a> heatbeat) |
| throws <a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a>, |
| org.apache.storm.thrift.TException</pre> |
| <div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#sendSupervisorWorkerHeartbeat-org.apache.storm.generated.SupervisorWorkerHeartbeat-">Nimbus.Iface</a></code></span></div> |
| <div class="block"><p>Send supervisor local worker heartbeat when a supervisor is unreachable</p></div> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#sendSupervisorWorkerHeartbeat-org.apache.storm.generated.SupervisorWorkerHeartbeat-">sendSupervisorWorkerHeartbeat</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/AuthorizationException.html" title="class in org.apache.storm.generated">AuthorizationException</a></code></dd> |
| <dd><code>org.apache.storm.thrift.TException</code></dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="processWorkerMetrics-org.apache.storm.generated.WorkerMetrics-"> |
| <!-- --> |
| </a> |
| <ul class="blockListLast"> |
| <li class="blockList"> |
| <h4>processWorkerMetrics</h4> |
| <pre>public void processWorkerMetrics(<a href="../../../org/apache/storm/generated/WorkerMetrics.html" title="class in org.apache.storm.generated">WorkerMetrics</a> metrics) |
| throws org.apache.storm.thrift.TException</pre> |
| <dl> |
| <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> |
| <dd><code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html#processWorkerMetrics-org.apache.storm.generated.WorkerMetrics-">processWorkerMetrics</a></code> in interface <code><a href="../../../org/apache/storm/generated/Nimbus.Iface.html" title="interface in org.apache.storm.generated">Nimbus.Iface</a></code></dd> |
| <dt><span class="throwsLabel">Throws:</span></dt> |
| <dd><code>org.apache.storm.thrift.TException</code></dd> |
| </dl> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </div> |
| </div> |
| <!-- ========= END OF CLASS DATA ========= --> |
| <!-- ======= START OF BOTTOM NAVBAR ====== --> |
| <div class="bottomNav"><a name="navbar.bottom"> |
| <!-- --> |
| </a> |
| <div class="skipNav"><a href="#skip.navbar.bottom" title="Skip navigation links">Skip navigation links</a></div> |
| <a name="navbar.bottom.firstrow"> |
| <!-- --> |
| </a> |
| <ul class="navList" title="Navigation"> |
| <li><a href="../../../overview-summary.html">Overview</a></li> |
| <li><a href="package-summary.html">Package</a></li> |
| <li class="navBarCell1Rev">Class</li> |
| <li><a href="class-use/LocalCluster.html">Use</a></li> |
| <li><a href="package-tree.html">Tree</a></li> |
| <li><a href="../../../deprecated-list.html">Deprecated</a></li> |
| <li><a href="../../../index-all.html">Index</a></li> |
| <li><a href="../../../help-doc.html">Help</a></li> |
| </ul> |
| <div class="aboutLanguage"><script type="text/javascript" src="../../../highlight.pack.js"></script> |
| <script type="text/javascript"><!-- |
| hljs.initHighlightingOnLoad(); |
| //--></script></div> |
| </div> |
| <div class="subNav"> |
| <ul class="navList"> |
| <li><a href="../../../org/apache/storm/ISubmitterHook.html" title="interface in org.apache.storm"><span class="typeNameLink">Prev Class</span></a></li> |
| <li><a href="../../../org/apache/storm/LocalCluster.Builder.html" title="class in org.apache.storm"><span class="typeNameLink">Next Class</span></a></li> |
| </ul> |
| <ul class="navList"> |
| <li><a href="../../../index.html?org/apache/storm/LocalCluster.html" target="_top">Frames</a></li> |
| <li><a href="LocalCluster.html" target="_top">No Frames</a></li> |
| </ul> |
| <ul class="navList" id="allclasses_navbar_bottom"> |
| <li><a href="../../../allclasses-noframe.html">All Classes</a></li> |
| </ul> |
| <div> |
| <script type="text/javascript"><!-- |
| allClassesLink = document.getElementById("allclasses_navbar_bottom"); |
| if(window==top) { |
| allClassesLink.style.display = "block"; |
| } |
| else { |
| allClassesLink.style.display = "none"; |
| } |
| //--> |
| </script> |
| </div> |
| <div> |
| <ul class="subNavList"> |
| <li>Summary: </li> |
| <li><a href="#nested.class.summary">Nested</a> | </li> |
| <li><a href="#field.summary">Field</a> | </li> |
| <li><a href="#constructor.summary">Constr</a> | </li> |
| <li><a href="#method.summary">Method</a></li> |
| </ul> |
| <ul class="subNavList"> |
| <li>Detail: </li> |
| <li><a href="#field.detail">Field</a> | </li> |
| <li><a href="#constructor.detail">Constr</a> | </li> |
| <li><a href="#method.detail">Method</a></li> |
| </ul> |
| </div> |
| <a name="skip.navbar.bottom"> |
| <!-- --> |
| </a></div> |
| <!-- ======== END OF BOTTOM NAVBAR ======= --> |
| <p class="legalCopy"><small>Copyright © 2022 <a href="https://www.apache.org/">The Apache Software Foundation</a>. All rights reserved.</small></p> |
| </body> |
| </html> |
