| <!DOCTYPE HTML> |
| <!-- NewPage --> |
| <html lang="en"> |
| <head> |
| <!-- Generated by javadoc (11.0.18) on Wed Mar 01 02:01:42 GMT 2023 --> |
| <title>Config (Heron Java API)</title> |
| <meta http-equiv="Content-Type" content="text/html; charset=UTF-8"> |
| <meta name="dc.created" content="2023-03-01"> |
| <link rel="stylesheet" type="text/css" href="../../../stylesheet.css" title="Style"> |
| <link rel="stylesheet" type="text/css" href="../../../jquery/jquery-ui.min.css" title="Style"> |
| <link rel="stylesheet" type="text/css" href="../../../jquery-ui.overrides.css" title="Style"> |
| <script type="text/javascript" src="../../../script.js"></script> |
| <script type="text/javascript" src="../../../jquery/jszip/dist/jszip.min.js"></script> |
| <script type="text/javascript" src="../../../jquery/jszip-utils/dist/jszip-utils.min.js"></script> |
| <!--[if IE]> |
| <script type="text/javascript" src="../../../jquery/jszip-utils/dist/jszip-utils-ie.min.js"></script> |
| <![endif]--> |
| <script type="text/javascript" src="../../../jquery/jquery-3.6.0.min.js"></script> |
| <script type="text/javascript" src="../../../jquery/jquery-ui.min.js"></script> |
| </head> |
| <body> |
| <script type="text/javascript"><!-- |
| try { |
| if (location.href.indexOf('is-external=true') == -1) { |
| parent.document.title="Config (Heron Java API)"; |
| } |
| } |
| catch(err) { |
| } |
| //--> |
| var data = {"i0":10,"i1":9,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":9,"i8":9,"i9":10,"i10":9,"i11":9,"i12":10,"i13":9,"i14":10,"i15":9,"i16":10,"i17":9,"i18":10,"i19":9,"i20":10,"i21":9,"i22":10,"i23":9,"i24":10,"i25":9,"i26":42,"i27":10,"i28":9,"i29":10,"i30":9,"i31":10,"i32":9,"i33":10,"i34":9,"i35":10,"i36":9,"i37":10,"i38":9}; |
| var tabs = {65535:["t0","All Methods"],1:["t1","Static Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"],32:["t6","Deprecated Methods"]}; |
| var altColor = "altColor"; |
| var rowColor = "rowColor"; |
| var tableTab = "tableTab"; |
| var activeTableTab = "activeTableTab"; |
| var pathtoroot = "../../../"; |
| var useModuleDirectories = true; |
| loadScripts(document, 'script');</script> |
| <noscript> |
| <div>JavaScript is disabled on your browser.</div> |
| </noscript> |
| <header role="banner"> |
| <nav role="navigation"> |
| <div class="fixedNav"> |
| <!-- ========= START OF TOP NAVBAR ======= --> |
| <div class="topNav"><a id="navbar.top"> |
| <!-- --> |
| </a> |
| <div class="skipNav"><a href="#skip.navbar.top" title="Skip navigation links">Skip navigation links</a></div> |
| <a id="navbar.top.firstrow"> |
| <!-- --> |
| </a> |
| <ul class="navList" title="Navigation"> |
| <li><a href="../../../index.html">Overview</a></li> |
| <li><a href="package-summary.html">Package</a></li> |
| <li class="navBarCell1Rev">Class</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" id="allclasses_navbar_top"> |
| <li><a href="../../../allclasses.html">All Classes</a></li> |
| </ul> |
| <ul class="navListSearch"> |
| <li><label for="search">SEARCH:</label> |
| <input type="text" id="search" value="search" disabled="disabled"> |
| <input type="reset" id="reset" value="reset" disabled="disabled"> |
| </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> |
| <noscript> |
| <div>JavaScript is disabled on your browser.</div> |
| </noscript> |
| </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 id="skip.navbar.top"> |
| <!-- --> |
| </a></div> |
| <!-- ========= END OF TOP NAVBAR ========= --> |
| </div> |
| <div class="navPadding"> </div> |
| <script type="text/javascript"><!-- |
| $('.navPadding').css('padding-top', $('.fixedNav').css("height")); |
| //--> |
| </script> |
| </nav> |
| </header> |
| <!-- ======== START OF CLASS DATA ======== --> |
| <main role="main"> |
| <div class="header"> |
| <div class="subTitle"><span class="packageLabelInType">Package</span> <a href="package-summary.html">org.apache.storm</a></div> |
| <h2 title="Class Config" class="title">Class Config</h2> |
| </div> |
| <div class="contentContainer"> |
| <ul class="inheritance"> |
| <li>java.lang.Object</li> |
| <li> |
| <ul class="inheritance"> |
| <li>java.util.AbstractMap<K,​V></li> |
| <li> |
| <ul class="inheritance"> |
| <li>java.util.HashMap<java.lang.String,​java.lang.Object></li> |
| <li> |
| <ul class="inheritance"> |
| <li>org.apache.storm.Config</li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| <div class="description"> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <dl> |
| <dt>All Implemented Interfaces:</dt> |
| <dd><code>java.io.Serializable</code>, <code>java.lang.Cloneable</code>, <code>java.util.Map<java.lang.String,​java.lang.Object></code></dd> |
| </dl> |
| <hr> |
| <pre>public class <span class="typeNameLabel">Config</span> |
| extends java.util.HashMap<java.lang.String,​java.lang.Object></pre> |
| <div class="block">Topology configs are specified as a plain old map. This class provides a |
| convenient way to create a topology config map by providing setter methods for |
| all the configs that can be set. It also makes it easier to do things like add |
| serializations. |
| <p> |
| <p>This class also provides constants for all the configurations possible on a Storm |
| cluster and Storm topology. Default values for these configs can be found in |
| defaults.yaml.</p> |
| <p> |
| <p>Note that you may put other configurations in any of the configs. Storm |
| will ignore anything it doesn't recognize, but your topologies are free to make |
| use of them by reading them in the prepare method of Bolts or the open method of |
| Spouts. .</p></div> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../serialized-form.html#org.apache.storm.Config">Serialized Form</a></dd> |
| </dl> |
| </li> |
| </ul> |
| </div> |
| <div class="summary"> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <!-- ======== NESTED CLASS SUMMARY ======== --> |
| <section> |
| <ul class="blockList"> |
| <li class="blockList"><a id="nested.class.summary"> |
| <!-- --> |
| </a> |
| <h3>Nested Class Summary</h3> |
| <ul class="blockList"> |
| <li class="blockList"><a id="nested.classes.inherited.from.class.java.util.AbstractMap"> |
| <!-- --> |
| </a> |
| <h3>Nested classes/interfaces inherited from class java.util.AbstractMap</h3> |
| <code>java.util.AbstractMap.SimpleEntry<K extends java.lang.Object,​V extends java.lang.Object>, java.util.AbstractMap.SimpleImmutableEntry<K extends java.lang.Object,​V extends java.lang.Object></code></li> |
| </ul> |
| <ul class="blockList"> |
| <li class="blockList"><a id="nested.classes.inherited.from.class.java.util.Map"> |
| <!-- --> |
| </a> |
| <h3>Nested classes/interfaces inherited from interface java.util.Map</h3> |
| <code>java.util.Map.Entry<K extends java.lang.Object,​V extends java.lang.Object></code></li> |
| </ul> |
| </li> |
| </ul> |
| </section> |
| <!-- =========== FIELD SUMMARY =========== --> |
| <section> |
| <ul class="blockList"> |
| <li class="blockList"><a id="field.summary"> |
| <!-- --> |
| </a> |
| <h3>Field Summary</h3> |
| <table class="memberSummary"> |
| <caption><span>Fields</span><span class="tabEnd"> </span></caption> |
| <tr> |
| <th class="colFirst" scope="col">Modifier and Type</th> |
| <th class="colSecond" scope="col">Field</th> |
| <th class="colLast" scope="col">Description</th> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#STORM_ZOOKEEPER_CONNECTION_TIMEOUT">STORM_ZOOKEEPER_CONNECTION_TIMEOUT</a></span></code></th> |
| <td class="colLast"> |
| <div class="block">The connection timeout for clients to ZooKeeper.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#STORM_ZOOKEEPER_PORT">STORM_ZOOKEEPER_PORT</a></span></code></th> |
| <td class="colLast"> |
| <div class="block">The port Storm will use to connect to each of the ZooKeeper servers.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#STORM_ZOOKEEPER_RETRY_INTERVAL">STORM_ZOOKEEPER_RETRY_INTERVAL</a></span></code></th> |
| <td class="colLast"> |
| <div class="block">The interval between retries of a Zookeeper operation.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#STORM_ZOOKEEPER_RETRY_TIMES">STORM_ZOOKEEPER_RETRY_TIMES</a></span></code></th> |
| <td class="colLast"> |
| <div class="block">The number of times to retry a Zookeeper operation.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#STORM_ZOOKEEPER_SERVERS">STORM_ZOOKEEPER_SERVERS</a></span></code></th> |
| <td class="colLast"> |
| <div class="block">A list of hosts of ZooKeeper servers used to manage the cluster.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#STORM_ZOOKEEPER_SESSION_TIMEOUT">STORM_ZOOKEEPER_SESSION_TIMEOUT</a></span></code></th> |
| <td class="colLast"> |
| <div class="block">The session timeout for clients to ZooKeeper.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#STORMCOMPAT_TOPOLOGY_AUTO_TASK_HOOKS">STORMCOMPAT_TOPOLOGY_AUTO_TASK_HOOKS</a></span></code></th> |
| <td class="colLast"> |
| <div class="block">---- DO NOT USE ----- |
| This variable is used to rewrite the TOPOLOGY_AUTO_TASK_HOOKS variable.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#TOPOLOGY_ACKER_EXECUTORS">TOPOLOGY_ACKER_EXECUTORS</a></span></code></th> |
| <td class="colLast"> |
| <div class="block">How many executors to spawn for ackers.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#TOPOLOGY_AUTO_TASK_HOOKS">TOPOLOGY_AUTO_TASK_HOOKS</a></span></code></th> |
| <td class="colLast"> |
| <div class="block">A list of task hooks that are automatically added to every spout and bolt in the topology.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#TOPOLOGY_BOLTS_LATE_TUPLE_STREAM">TOPOLOGY_BOLTS_LATE_TUPLE_STREAM</a></span></code></th> |
| <td class="colLast"> |
| <div class="block">Bolt-specific configuration for windowed bolts to specify the name of the stream on which late tuples are |
| going to be emitted.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#TOPOLOGY_BOLTS_SLIDING_INTERVAL_COUNT">TOPOLOGY_BOLTS_SLIDING_INTERVAL_COUNT</a></span></code></th> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#TOPOLOGY_BOLTS_SLIDING_INTERVAL_DURATION_MS">TOPOLOGY_BOLTS_SLIDING_INTERVAL_DURATION_MS</a></span></code></th> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#TOPOLOGY_BOLTS_TUPLE_TIMESTAMP_MAX_LAG_MS">TOPOLOGY_BOLTS_TUPLE_TIMESTAMP_MAX_LAG_MS</a></span></code></th> |
| <td class="colLast"> |
| <div class="block">Bolt-specific configuration for windowed bolts to specify the maximum time lag of the tuple timestamp |
| in milliseconds.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#TOPOLOGY_BOLTS_WATERMARK_EVENT_INTERVAL_MS">TOPOLOGY_BOLTS_WATERMARK_EVENT_INTERVAL_MS</a></span></code></th> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#TOPOLOGY_BOLTS_WINDOW_LENGTH_COUNT">TOPOLOGY_BOLTS_WINDOW_LENGTH_COUNT</a></span></code></th> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#TOPOLOGY_BOLTS_WINDOW_LENGTH_DURATION_MS">TOPOLOGY_BOLTS_WINDOW_LENGTH_DURATION_MS</a></span></code></th> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#TOPOLOGY_CAP_TICKET">TOPOLOGY_CAP_TICKET</a></span></code></th> |
| <td class="colLast"> |
| <div class="block">Cap ticket (if filed) for the topology.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#TOPOLOGY_DEBUG">TOPOLOGY_DEBUG</a></span></code></th> |
| <td class="colLast"> |
| <div class="block">When set to true, Storm will log every message that's emitted.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#TOPOLOGY_ENABLE_MESSAGE_TIMEOUTS">TOPOLOGY_ENABLE_MESSAGE_TIMEOUTS</a></span></code></th> |
| <td class="colLast"> |
| <div class="block">True if Storm should timeout messages or not.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#TOPOLOGY_ENVIRONMENT">TOPOLOGY_ENVIRONMENT</a></span></code></th> |
| <td class="colLast"> |
| <div class="block">Topology-specific environment variables for the worker child process.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#TOPOLOGY_ERROR_THROTTLE_INTERVAL_SECS">TOPOLOGY_ERROR_THROTTLE_INTERVAL_SECS</a></span></code></th> |
| <td class="colLast"> |
| <div class="block">The interval in seconds to use for determining whether to throttle error reported to Zookeeper.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#TOPOLOGY_FALL_BACK_ON_JAVA_SERIALIZATION">TOPOLOGY_FALL_BACK_ON_JAVA_SERIALIZATION</a></span></code></th> |
| <td class="colLast"> |
| <div class="block">Whether or not to use Java serialization in a topology.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#TOPOLOGY_KRYO_DECORATORS">TOPOLOGY_KRYO_DECORATORS</a></span></code></th> |
| <td class="colLast"> |
| <div class="block">A list of classes that customize storm's kryo instance during start-up.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#TOPOLOGY_KRYO_FACTORY">TOPOLOGY_KRYO_FACTORY</a></span></code></th> |
| <td class="colLast"> |
| <div class="block">Class that specifies how to create a Kryo instance for serialization.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#TOPOLOGY_KRYO_REGISTER">TOPOLOGY_KRYO_REGISTER</a></span></code></th> |
| <td class="colLast"> |
| <div class="block">A list of serialization registrations for Kryo ( http://code.google.com/p/kryo/ ), |
| the underlying serialization framework for Storm.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#TOPOLOGY_MAX_ERROR_REPORT_PER_INTERVAL">TOPOLOGY_MAX_ERROR_REPORT_PER_INTERVAL</a></span></code></th> |
| <td class="colLast"> |
| <div class="block">See doc for TOPOLOGY_ERROR_THROTTLE_INTERVAL_SECS.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#TOPOLOGY_MAX_SPOUT_PENDING">TOPOLOGY_MAX_SPOUT_PENDING</a></span></code></th> |
| <td class="colLast"> |
| <div class="block">The maximum number of tuples that can be pending on a spout task at any given time.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#TOPOLOGY_MAX_TASK_PARALLELISM">TOPOLOGY_MAX_TASK_PARALLELISM</a></span></code></th> |
| <td class="colLast"> |
| <div class="block">The maximum parallelism allowed for a component in this topology.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#TOPOLOGY_MESSAGE_TIMEOUT_SECS">TOPOLOGY_MESSAGE_TIMEOUT_SECS</a></span></code></th> |
| <td class="colLast"> |
| <div class="block">The maximum amount of time given to the topology to fully process a message |
| emitted by a spout.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#TOPOLOGY_METRICS_CONSUMER_REGISTER">TOPOLOGY_METRICS_CONSUMER_REGISTER</a></span></code></th> |
| <td class="colLast"> </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#TOPOLOGY_NAME">TOPOLOGY_NAME</a></span></code></th> |
| <td class="colLast"> |
| <div class="block">Name of the topology.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#TOPOLOGY_OPTIMIZE">TOPOLOGY_OPTIMIZE</a></span></code></th> |
| <td class="colLast"> |
| <div class="block">Whether or not the master should optimize topologies by running multiple |
| tasks in a single thread where appropriate.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#TOPOLOGY_PROJECT_NAME">TOPOLOGY_PROJECT_NAME</a></span></code></th> |
| <td class="colLast"> |
| <div class="block">Project name of the topology, to help us with tagging which topologies are part of which project.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#TOPOLOGY_SKIP_MISSING_KRYO_REGISTRATIONS">TOPOLOGY_SKIP_MISSING_KRYO_REGISTRATIONS</a></span></code></th> |
| <td class="colLast"> |
| <div class="block">Whether or not Storm should skip the loading of kryo registrations for which it |
| does not know the class or have the serializer implementation.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#TOPOLOGY_SLEEP_SPOUT_WAIT_STRATEGY_TIME_MS">TOPOLOGY_SLEEP_SPOUT_WAIT_STRATEGY_TIME_MS</a></span></code></th> |
| <td class="colLast"> |
| <div class="block">The amount of milliseconds the SleepEmptyEmitStrategy should sleep for.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#TOPOLOGY_SPOUT_WAIT_STRATEGY">TOPOLOGY_SPOUT_WAIT_STRATEGY</a></span></code></th> |
| <td class="colLast"> |
| <div class="block">A class that implements a strategy for what to do when a spout needs to wait.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#TOPOLOGY_STATE_SYNCHRONIZATION_TIMEOUT_SECS">TOPOLOGY_STATE_SYNCHRONIZATION_TIMEOUT_SECS</a></span></code></th> |
| <td class="colLast"> |
| <div class="block">The maximum amount of time a component gives a source of state to synchronize before it requests |
| synchronization again.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#TOPOLOGY_STATS_SAMPLE_RATE">TOPOLOGY_STATS_SAMPLE_RATE</a></span></code></th> |
| <td class="colLast"> |
| <div class="block">The percentage of tuples to sample to produce stats for a task.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#TOPOLOGY_TASKS">TOPOLOGY_TASKS</a></span></code></th> |
| <td class="colLast"> |
| <div class="block">How many instances to create for a spout/bolt.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#TOPOLOGY_TEAM_EMAIL">TOPOLOGY_TEAM_EMAIL</a></span></code></th> |
| <td class="colLast"> |
| <div class="block">Email of the team which owns this topology.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#TOPOLOGY_TEAM_NAME">TOPOLOGY_TEAM_NAME</a></span></code></th> |
| <td class="colLast"> |
| <div class="block">Name of the team which owns this topology.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#TOPOLOGY_TICK_TUPLE_FREQ_SECS">TOPOLOGY_TICK_TUPLE_FREQ_SECS</a></span></code></th> |
| <td class="colLast"> |
| <div class="block">How often a tick tuple from the "__system" component and "__tick" stream should be sent |
| to tasks.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#TOPOLOGY_TRANSACTIONAL_ID">TOPOLOGY_TRANSACTIONAL_ID</a></span></code></th> |
| <td class="colLast"> |
| <div class="block">This config is available for TransactionalSpouts, and contains the id ( a String) for |
| the transactional topology.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#TOPOLOGY_WORKER_CHILDOPTS">TOPOLOGY_WORKER_CHILDOPTS</a></span></code></th> |
| <td class="colLast"> |
| <div class="block">Topology-specific options for the worker child process.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#TOPOLOGY_WORKERS">TOPOLOGY_WORKERS</a></span></code></th> |
| <td class="colLast"> |
| <div class="block">This currently gets translated to TOPOLOGY_STMGRS.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#TRANSACTIONAL_ZOOKEEPER_PORT">TRANSACTIONAL_ZOOKEEPER_PORT</a></span></code></th> |
| <td class="colLast"> |
| <div class="block">The port to use to connect to the transactional zookeeper servers.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#TRANSACTIONAL_ZOOKEEPER_ROOT">TRANSACTIONAL_ZOOKEEPER_ROOT</a></span></code></th> |
| <td class="colLast"> |
| <div class="block">The root directory in ZooKeeper for metadata about TransactionalSpouts.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><code>static java.lang.String</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#TRANSACTIONAL_ZOOKEEPER_SERVERS">TRANSACTIONAL_ZOOKEEPER_SERVERS</a></span></code></th> |
| <td class="colLast"> |
| <div class="block">The list of zookeeper servers in which to keep the transactional state.</div> |
| </td> |
| </tr> |
| </table> |
| </li> |
| </ul> |
| </section> |
| <!-- ======== CONSTRUCTOR SUMMARY ======== --> |
| <section> |
| <ul class="blockList"> |
| <li class="blockList"><a id="constructor.summary"> |
| <!-- --> |
| </a> |
| <h3>Constructor Summary</h3> |
| <table class="memberSummary"> |
| <caption><span>Constructors</span><span class="tabEnd"> </span></caption> |
| <tr> |
| <th class="colFirst" scope="col">Constructor</th> |
| <th class="colLast" scope="col">Description</th> |
| </tr> |
| <tr class="altColor"> |
| <th class="colConstructorName" scope="row"><code><span class="memberNameLink"><a href="#%3Cinit%3E()">Config</a></span>()</code></th> |
| <td class="colLast"> </td> |
| </tr> |
| </table> |
| </li> |
| </ul> |
| </section> |
| <!-- ========== METHOD SUMMARY =========== --> |
| <section> |
| <ul class="blockList"> |
| <li class="blockList"><a id="method.summary"> |
| <!-- --> |
| </a> |
| <h3>Method Summary</h3> |
| <table class="memberSummary"> |
| <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><span id="t6" class="tableTab"><span><a href="javascript:show(32);">Deprecated Methods</a></span><span class="tabEnd"> </span></span></caption> |
| <tr> |
| <th class="colFirst" scope="col">Modifier and Type</th> |
| <th class="colSecond" scope="col">Method</th> |
| <th class="colLast" scope="col">Description</th> |
| </tr> |
| <tr id="i0" class="altColor"> |
| <td class="colFirst"><code>void</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#registerDecorator(java.lang.Class)">registerDecorator</a></span>​(java.lang.Class<? extends <a href="serialization/IKryoDecorator.html" title="interface in org.apache.storm.serialization">IKryoDecorator</a>> klass)</code></th> |
| <td class="colLast"> </td> |
| </tr> |
| <tr id="i1" class="rowColor"> |
| <td class="colFirst"><code>static void</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#registerDecorator(java.util.Map,java.lang.Class)">registerDecorator</a></span>​(java.util.Map conf, |
| java.lang.Class<? extends <a href="serialization/IKryoDecorator.html" title="interface in org.apache.storm.serialization">IKryoDecorator</a>> klass)</code></th> |
| <td class="colLast"> </td> |
| </tr> |
| <tr id="i2" class="altColor"> |
| <td class="colFirst"><code>void</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#registerMetricsConsumer(java.lang.Class)">registerMetricsConsumer</a></span>​(java.lang.Class klass)</code></th> |
| <td class="colLast"> </td> |
| </tr> |
| <tr id="i3" class="rowColor"> |
| <td class="colFirst"><code>void</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#registerMetricsConsumer(java.lang.Class,long)">registerMetricsConsumer</a></span>​(java.lang.Class klass, |
| long parallelismHint)</code></th> |
| <td class="colLast"> </td> |
| </tr> |
| <tr id="i4" class="altColor"> |
| <td class="colFirst"><code>void</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#registerMetricsConsumer(java.lang.Class,java.lang.Object,long)">registerMetricsConsumer</a></span>​(java.lang.Class klass, |
| java.lang.Object argument, |
| long parallelismHint)</code></th> |
| <td class="colLast"> </td> |
| </tr> |
| <tr id="i5" class="rowColor"> |
| <td class="colFirst"><code>void</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#registerSerialization(java.lang.Class)">registerSerialization</a></span>​(java.lang.Class klass)</code></th> |
| <td class="colLast"> </td> |
| </tr> |
| <tr id="i6" class="altColor"> |
| <td class="colFirst"><code>void</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#registerSerialization(java.lang.Class,java.lang.Class)">registerSerialization</a></span>​(java.lang.Class klass, |
| java.lang.Class<? extends com.esotericsoftware.kryo.Serializer> serializerClass)</code></th> |
| <td class="colLast"> </td> |
| </tr> |
| <tr id="i7" class="rowColor"> |
| <td class="colFirst"><code>static void</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#registerSerialization(java.util.Map,java.lang.Class)">registerSerialization</a></span>​(java.util.Map conf, |
| java.lang.Class klass)</code></th> |
| <td class="colLast"> </td> |
| </tr> |
| <tr id="i8" class="altColor"> |
| <td class="colFirst"><code>static void</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#registerSerialization(java.util.Map,java.lang.Class,java.lang.Class)">registerSerialization</a></span>​(java.util.Map conf, |
| java.lang.Class klass, |
| java.lang.Class<? extends com.esotericsoftware.kryo.Serializer> serializerClass)</code></th> |
| <td class="colLast"> </td> |
| </tr> |
| <tr id="i9" class="rowColor"> |
| <td class="colFirst"><code>void</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#setDebug(boolean)">setDebug</a></span>​(boolean isOn)</code></th> |
| <td class="colLast"> </td> |
| </tr> |
| <tr id="i10" class="altColor"> |
| <td class="colFirst"><code>static void</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#setDebug(java.util.Map,boolean)">setDebug</a></span>​(java.util.Map conf, |
| boolean isOn)</code></th> |
| <td class="colLast"> </td> |
| </tr> |
| <tr id="i11" class="rowColor"> |
| <td class="colFirst"><code>static void</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#setEnvironment(java.util.Map,java.util.Map)">setEnvironment</a></span>​(java.util.Map<java.lang.String,​java.lang.Object> conf, |
| java.util.Map env)</code></th> |
| <td class="colLast"> </td> |
| </tr> |
| <tr id="i12" class="altColor"> |
| <td class="colFirst"><code>void</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#setFallBackOnJavaSerialization(boolean)">setFallBackOnJavaSerialization</a></span>​(boolean fallback)</code></th> |
| <td class="colLast"> </td> |
| </tr> |
| <tr id="i13" class="rowColor"> |
| <td class="colFirst"><code>static void</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#setFallBackOnJavaSerialization(java.util.Map,boolean)">setFallBackOnJavaSerialization</a></span>​(java.util.Map conf, |
| boolean fallback)</code></th> |
| <td class="colLast"> </td> |
| </tr> |
| <tr id="i14" class="altColor"> |
| <td class="colFirst"><code>void</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#setKryoFactory(java.lang.Class)">setKryoFactory</a></span>​(java.lang.Class<? extends <a href="serialization/IKryoFactory.html" title="interface in org.apache.storm.serialization">IKryoFactory</a>> klass)</code></th> |
| <td class="colLast"> </td> |
| </tr> |
| <tr id="i15" class="rowColor"> |
| <td class="colFirst"><code>static void</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#setKryoFactory(java.util.Map,java.lang.Class)">setKryoFactory</a></span>​(java.util.Map conf, |
| java.lang.Class<? extends <a href="serialization/IKryoFactory.html" title="interface in org.apache.storm.serialization">IKryoFactory</a>> klass)</code></th> |
| <td class="colLast"> </td> |
| </tr> |
| <tr id="i16" class="altColor"> |
| <td class="colFirst"><code>void</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#setMaxSpoutPending(int)">setMaxSpoutPending</a></span>​(int max)</code></th> |
| <td class="colLast"> </td> |
| </tr> |
| <tr id="i17" class="rowColor"> |
| <td class="colFirst"><code>static void</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#setMaxSpoutPending(java.util.Map,int)">setMaxSpoutPending</a></span>​(java.util.Map conf, |
| int max)</code></th> |
| <td class="colLast"> </td> |
| </tr> |
| <tr id="i18" class="altColor"> |
| <td class="colFirst"><code>void</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#setMaxTaskParallelism(int)">setMaxTaskParallelism</a></span>​(int max)</code></th> |
| <td class="colLast"> </td> |
| </tr> |
| <tr id="i19" class="rowColor"> |
| <td class="colFirst"><code>static void</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#setMaxTaskParallelism(java.util.Map,int)">setMaxTaskParallelism</a></span>​(java.util.Map conf, |
| int max)</code></th> |
| <td class="colLast"> </td> |
| </tr> |
| <tr id="i20" class="altColor"> |
| <td class="colFirst"><code>void</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#setMessageTimeoutSecs(int)">setMessageTimeoutSecs</a></span>​(int secs)</code></th> |
| <td class="colLast"> </td> |
| </tr> |
| <tr id="i21" class="rowColor"> |
| <td class="colFirst"><code>static void</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#setMessageTimeoutSecs(java.util.Map,int)">setMessageTimeoutSecs</a></span>​(java.util.Map conf, |
| int secs)</code></th> |
| <td class="colLast"> </td> |
| </tr> |
| <tr id="i22" class="altColor"> |
| <td class="colFirst"><code>void</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#setNumAckers(int)">setNumAckers</a></span>​(int numExecutors)</code></th> |
| <td class="colLast"> </td> |
| </tr> |
| <tr id="i23" class="rowColor"> |
| <td class="colFirst"><code>static void</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#setNumAckers(java.util.Map,int)">setNumAckers</a></span>​(java.util.Map conf, |
| int numExecutors)</code></th> |
| <td class="colLast"> </td> |
| </tr> |
| <tr id="i24" class="altColor"> |
| <td class="colFirst"><code>void</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#setNumWorkers(int)">setNumWorkers</a></span>​(int workers)</code></th> |
| <td class="colLast"> </td> |
| </tr> |
| <tr id="i25" class="rowColor"> |
| <td class="colFirst"><code>static void</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#setNumWorkers(java.util.Map,int)">setNumWorkers</a></span>​(java.util.Map conf, |
| int workers)</code></th> |
| <td class="colLast"> </td> |
| </tr> |
| <tr id="i26" class="altColor"> |
| <td class="colFirst"><code>void</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#setOptimize(boolean)">setOptimize</a></span>​(boolean isOn)</code></th> |
| <td class="colLast"> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span> |
| <div class="deprecationComment">we don't have optimization</div> |
| </div> |
| </td> |
| </tr> |
| <tr id="i27" class="rowColor"> |
| <td class="colFirst"><code>void</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#setSkipMissingKryoRegistrations(boolean)">setSkipMissingKryoRegistrations</a></span>​(boolean skip)</code></th> |
| <td class="colLast"> </td> |
| </tr> |
| <tr id="i28" class="altColor"> |
| <td class="colFirst"><code>static void</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#setSkipMissingKryoRegistrations(java.util.Map,boolean)">setSkipMissingKryoRegistrations</a></span>​(java.util.Map conf, |
| boolean skip)</code></th> |
| <td class="colLast"> </td> |
| </tr> |
| <tr id="i29" class="rowColor"> |
| <td class="colFirst"><code>void</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#setStatsSampleRate(double)">setStatsSampleRate</a></span>​(double rate)</code></th> |
| <td class="colLast"> </td> |
| </tr> |
| <tr id="i30" class="altColor"> |
| <td class="colFirst"><code>static void</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#setStatsSampleRate(java.util.Map,double)">setStatsSampleRate</a></span>​(java.util.Map conf, |
| double rate)</code></th> |
| <td class="colLast"> </td> |
| </tr> |
| <tr id="i31" class="rowColor"> |
| <td class="colFirst"><code>void</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#setTeamEmail(java.lang.String)">setTeamEmail</a></span>​(java.lang.String teamEmail)</code></th> |
| <td class="colLast"> </td> |
| </tr> |
| <tr id="i32" class="altColor"> |
| <td class="colFirst"><code>static void</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#setTeamEmail(java.util.Map,java.lang.String)">setTeamEmail</a></span>​(java.util.Map conf, |
| java.lang.String teamEmail)</code></th> |
| <td class="colLast"> </td> |
| </tr> |
| <tr id="i33" class="rowColor"> |
| <td class="colFirst"><code>void</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#setTeamName(java.lang.String)">setTeamName</a></span>​(java.lang.String teamName)</code></th> |
| <td class="colLast"> </td> |
| </tr> |
| <tr id="i34" class="altColor"> |
| <td class="colFirst"><code>static void</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#setTeamName(java.util.Map,java.lang.String)">setTeamName</a></span>​(java.util.Map conf, |
| java.lang.String teamName)</code></th> |
| <td class="colLast"> </td> |
| </tr> |
| <tr id="i35" class="rowColor"> |
| <td class="colFirst"><code>void</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#setTopologyCapTicket(java.lang.String)">setTopologyCapTicket</a></span>​(java.lang.String ticket)</code></th> |
| <td class="colLast"> </td> |
| </tr> |
| <tr id="i36" class="altColor"> |
| <td class="colFirst"><code>static void</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#setTopologyCapTicket(java.util.Map,java.lang.String)">setTopologyCapTicket</a></span>​(java.util.Map conf, |
| java.lang.String ticket)</code></th> |
| <td class="colLast"> </td> |
| </tr> |
| <tr id="i37" class="rowColor"> |
| <td class="colFirst"><code>void</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#setTopologyProjectName(java.lang.String)">setTopologyProjectName</a></span>​(java.lang.String project)</code></th> |
| <td class="colLast"> </td> |
| </tr> |
| <tr id="i38" class="altColor"> |
| <td class="colFirst"><code>static void</code></td> |
| <th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#setTopologyProjectName(java.util.Map,java.lang.String)">setTopologyProjectName</a></span>​(java.util.Map conf, |
| java.lang.String project)</code></th> |
| <td class="colLast"> </td> |
| </tr> |
| </table> |
| <ul class="blockList"> |
| <li class="blockList"><a id="methods.inherited.from.class.java.util.HashMap"> |
| <!-- --> |
| </a> |
| <h3>Methods inherited from class java.util.HashMap</h3> |
| <code>clear, clone, compute, computeIfAbsent, computeIfPresent, containsKey, containsValue, entrySet, forEach, get, getOrDefault, isEmpty, keySet, merge, put, putAll, putIfAbsent, remove, remove, replace, replace, replaceAll, size, values</code></li> |
| </ul> |
| <ul class="blockList"> |
| <li class="blockList"><a id="methods.inherited.from.class.java.util.AbstractMap"> |
| <!-- --> |
| </a> |
| <h3>Methods inherited from class java.util.AbstractMap</h3> |
| <code>equals, hashCode, toString</code></li> |
| </ul> |
| <ul class="blockList"> |
| <li class="blockList"><a id="methods.inherited.from.class.java.lang.Object"> |
| <!-- --> |
| </a> |
| <h3>Methods inherited from class java.lang.Object</h3> |
| <code>finalize, getClass, notify, notifyAll, wait, wait, wait</code></li> |
| </ul> |
| <ul class="blockList"> |
| <li class="blockList"><a id="methods.inherited.from.class.java.util.Map"> |
| <!-- --> |
| </a> |
| <h3>Methods inherited from interface java.util.Map</h3> |
| <code>equals, hashCode</code></li> |
| </ul> |
| </li> |
| </ul> |
| </section> |
| </li> |
| </ul> |
| </div> |
| <div class="details"> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <!-- ============ FIELD DETAIL =========== --> |
| <section> |
| <ul class="blockList"> |
| <li class="blockList"><a id="field.detail"> |
| <!-- --> |
| </a> |
| <h3>Field Detail</h3> |
| <a id="TOPOLOGY_ENABLE_MESSAGE_TIMEOUTS"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>TOPOLOGY_ENABLE_MESSAGE_TIMEOUTS</h4> |
| <pre>public static final java.lang.String TOPOLOGY_ENABLE_MESSAGE_TIMEOUTS</pre> |
| <div class="block">True if Storm should timeout messages or not. Defaults to true. This is meant to be used |
| in unit tests to prevent tuples from being accidentally timed out during the test. |
| Same functionality in Heron.</div> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.TOPOLOGY_ENABLE_MESSAGE_TIMEOUTS">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="TOPOLOGY_OPTIMIZE"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>TOPOLOGY_OPTIMIZE</h4> |
| <pre>public static final java.lang.String TOPOLOGY_OPTIMIZE</pre> |
| <div class="block">Whether or not the master should optimize topologies by running multiple |
| tasks in a single thread where appropriate. |
| This has no impact in Heron</div> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.TOPOLOGY_OPTIMIZE">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="TOPOLOGY_TASKS"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>TOPOLOGY_TASKS</h4> |
| <pre>public static final java.lang.String TOPOLOGY_TASKS</pre> |
| <div class="block">How many instances to create for a spout/bolt. A task runs on a thread with zero or more |
| other tasks for the same spout/bolt. The number of tasks for a spout/bolt is always |
| the same throughout the lifetime of a topology, but the number of executors (threads) for |
| a spout/bolt can change over time. This allows a topology to scale to more or less resources |
| without redeploying the topology or violating the constraints of Storm (such as a fields grouping |
| guaranteeing that the same value goes to the same task). |
| This has no impact on Heron.</div> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.TOPOLOGY_TASKS">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="TOPOLOGY_KRYO_REGISTER"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>TOPOLOGY_KRYO_REGISTER</h4> |
| <pre>public static final java.lang.String TOPOLOGY_KRYO_REGISTER</pre> |
| <div class="block">A list of serialization registrations for Kryo ( http://code.google.com/p/kryo/ ), |
| the underlying serialization framework for Storm. A serialization can either |
| be the name of a class (in which case Kryo will automatically create a serializer for the class |
| that saves all the object's fields), or an implementation of com.esotericsoftware.kryo.Serializer. |
| <p> |
| See Kryo's documentation for more information about writing custom serializers. |
| Same in Heron.</div> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.TOPOLOGY_KRYO_REGISTER">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="TOPOLOGY_KRYO_DECORATORS"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>TOPOLOGY_KRYO_DECORATORS</h4> |
| <pre>public static final java.lang.String TOPOLOGY_KRYO_DECORATORS</pre> |
| <div class="block">A list of classes that customize storm's kryo instance during start-up. |
| Each listed class name must implement IKryoDecorator. During start-up the |
| listed class is instantiated with 0 arguments, then its 'decorate' method |
| is called with storm's kryo instance as the only argument. |
| Same in Heron.</div> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.TOPOLOGY_KRYO_DECORATORS">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="TOPOLOGY_KRYO_FACTORY"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>TOPOLOGY_KRYO_FACTORY</h4> |
| <pre>public static final java.lang.String TOPOLOGY_KRYO_FACTORY</pre> |
| <div class="block">Class that specifies how to create a Kryo instance for serialization. Storm will then apply |
| topology.kryo.register and topology.kryo.decorators on top of this. The default implementation |
| implements topology.fall.back.on.java.serialization and turns references off. |
| Same in Heron.</div> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.TOPOLOGY_KRYO_FACTORY">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="TOPOLOGY_SKIP_MISSING_KRYO_REGISTRATIONS"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>TOPOLOGY_SKIP_MISSING_KRYO_REGISTRATIONS</h4> |
| <pre>public static final java.lang.String TOPOLOGY_SKIP_MISSING_KRYO_REGISTRATIONS</pre> |
| <div class="block">Whether or not Storm should skip the loading of kryo registrations for which it |
| does not know the class or have the serializer implementation. Otherwise, the task will |
| fail to load and will throw an error at runtime. The use case of this is if you want to |
| declare your serializations on the storm.yaml files on the cluster rather than every single |
| time you submit a topology. Different applications may use different serializations and so |
| a single application may not have the code for the other serializers used by other apps. |
| By setting this config to true, Storm will ignore that it doesn't have those other serializations |
| rather than throw an error. |
| Same in Heron.</div> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.TOPOLOGY_SKIP_MISSING_KRYO_REGISTRATIONS">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="TOPOLOGY_STATE_SYNCHRONIZATION_TIMEOUT_SECS"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>TOPOLOGY_STATE_SYNCHRONIZATION_TIMEOUT_SECS</h4> |
| <pre>public static final java.lang.String TOPOLOGY_STATE_SYNCHRONIZATION_TIMEOUT_SECS</pre> |
| <div class="block">The maximum amount of time a component gives a source of state to synchronize before it requests |
| synchronization again. |
| This is not implemented in Heron.</div> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.TOPOLOGY_STATE_SYNCHRONIZATION_TIMEOUT_SECS">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="TOPOLOGY_FALL_BACK_ON_JAVA_SERIALIZATION"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>TOPOLOGY_FALL_BACK_ON_JAVA_SERIALIZATION</h4> |
| <pre>public static final java.lang.String TOPOLOGY_FALL_BACK_ON_JAVA_SERIALIZATION</pre> |
| <div class="block">Whether or not to use Java serialization in a topology. |
| This has the same meaning in Heron.</div> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.TOPOLOGY_FALL_BACK_ON_JAVA_SERIALIZATION">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="TOPOLOGY_WORKER_CHILDOPTS"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>TOPOLOGY_WORKER_CHILDOPTS</h4> |
| <pre>public static final java.lang.String TOPOLOGY_WORKER_CHILDOPTS</pre> |
| <div class="block">Topology-specific options for the worker child process. This is used in addition to WORKER_CHILDOPTS. |
| Not yet implemented in Heron.</div> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.TOPOLOGY_WORKER_CHILDOPTS">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="TOPOLOGY_TRANSACTIONAL_ID"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>TOPOLOGY_TRANSACTIONAL_ID</h4> |
| <pre>public static final java.lang.String TOPOLOGY_TRANSACTIONAL_ID</pre> |
| <div class="block">This config is available for TransactionalSpouts, and contains the id ( a String) for |
| the transactional topology. This id is used to store the state of the transactional |
| topology in Zookeeper. |
| This is not implemented in Heron.</div> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.TOPOLOGY_TRANSACTIONAL_ID">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="TOPOLOGY_TICK_TUPLE_FREQ_SECS"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>TOPOLOGY_TICK_TUPLE_FREQ_SECS</h4> |
| <pre>public static final java.lang.String TOPOLOGY_TICK_TUPLE_FREQ_SECS</pre> |
| <div class="block">How often a tick tuple from the "__system" component and "__tick" stream should be sent |
| to tasks. Meant to be used as a component-specific configuration. |
| Same meaning in Heron.</div> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.TOPOLOGY_TICK_TUPLE_FREQ_SECS">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="TOPOLOGY_ERROR_THROTTLE_INTERVAL_SECS"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>TOPOLOGY_ERROR_THROTTLE_INTERVAL_SECS</h4> |
| <pre>public static final java.lang.String TOPOLOGY_ERROR_THROTTLE_INTERVAL_SECS</pre> |
| <div class="block">The interval in seconds to use for determining whether to throttle error reported to Zookeeper. For example, |
| an interval of 10 seconds with topology.max.error.report.per.interval set to 5 will only allow 5 errors to be |
| reported to Zookeeper per task for every 10 second interval of time. |
| This is not supported in Heron.</div> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.TOPOLOGY_ERROR_THROTTLE_INTERVAL_SECS">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="TOPOLOGY_MAX_ERROR_REPORT_PER_INTERVAL"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>TOPOLOGY_MAX_ERROR_REPORT_PER_INTERVAL</h4> |
| <pre>public static final java.lang.String TOPOLOGY_MAX_ERROR_REPORT_PER_INTERVAL</pre> |
| <div class="block">See doc for TOPOLOGY_ERROR_THROTTLE_INTERVAL_SECS. |
| This is not supported in Heron</div> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.TOPOLOGY_MAX_ERROR_REPORT_PER_INTERVAL">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="TOPOLOGY_DEBUG"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>TOPOLOGY_DEBUG</h4> |
| <pre>public static final java.lang.String TOPOLOGY_DEBUG</pre> |
| <div class="block">When set to true, Storm will log every message that's emitted.</div> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.TOPOLOGY_DEBUG">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="TOPOLOGY_WORKERS"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>TOPOLOGY_WORKERS</h4> |
| <pre>public static final java.lang.String TOPOLOGY_WORKERS</pre> |
| <div class="block">This currently gets translated to TOPOLOGY_STMGRS. Please see the |
| documentation for TOPOLOGY_STMGRS.</div> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.TOPOLOGY_WORKERS">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="TOPOLOGY_ACKER_EXECUTORS"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>TOPOLOGY_ACKER_EXECUTORS</h4> |
| <pre>public static final java.lang.String TOPOLOGY_ACKER_EXECUTORS</pre> |
| <div class="block">How many executors to spawn for ackers. |
| <p>If this is set to 0, then Storm will immediately ack tuples as soon |
| as they come off the spout, effectively disabling reliability. |
| In Heron any values of > 0 means to enable acking.</div> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.TOPOLOGY_ACKER_EXECUTORS">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="TOPOLOGY_MESSAGE_TIMEOUT_SECS"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>TOPOLOGY_MESSAGE_TIMEOUT_SECS</h4> |
| <pre>public static final java.lang.String TOPOLOGY_MESSAGE_TIMEOUT_SECS</pre> |
| <div class="block">The maximum amount of time given to the topology to fully process a message |
| emitted by a spout. If the message is not acked within this time frame, Storm |
| will fail the message on the spout. Some spouts implementations will then replay |
| the message at a later time. |
| This has the same meaning in Heron.</div> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.TOPOLOGY_MESSAGE_TIMEOUT_SECS">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="TOPOLOGY_METRICS_CONSUMER_REGISTER"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>TOPOLOGY_METRICS_CONSUMER_REGISTER</h4> |
| <pre>public static final java.lang.String TOPOLOGY_METRICS_CONSUMER_REGISTER</pre> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.TOPOLOGY_METRICS_CONSUMER_REGISTER">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="TOPOLOGY_MAX_TASK_PARALLELISM"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>TOPOLOGY_MAX_TASK_PARALLELISM</h4> |
| <pre>public static final java.lang.String TOPOLOGY_MAX_TASK_PARALLELISM</pre> |
| <div class="block">The maximum parallelism allowed for a component in this topology. This configuration is |
| typically used in testing to limit the number of threads spawned in simulator. |
| This does not have any impact in Heron</div> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.TOPOLOGY_MAX_TASK_PARALLELISM">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="TOPOLOGY_MAX_SPOUT_PENDING"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>TOPOLOGY_MAX_SPOUT_PENDING</h4> |
| <pre>public static final java.lang.String TOPOLOGY_MAX_SPOUT_PENDING</pre> |
| <div class="block">The maximum number of tuples that can be pending on a spout task at any given time. |
| This config applies to individual tasks, not to spouts or topologies as a whole. |
| <p> |
| A pending tuple is one that has been emitted from a spout but has not been acked or failed yet. |
| Note that this config parameter has no effect for unreliable spouts that don't tag |
| their tuples with a message id. |
| This has same meaning in Heron.</div> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.TOPOLOGY_MAX_SPOUT_PENDING">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="TOPOLOGY_SPOUT_WAIT_STRATEGY"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>TOPOLOGY_SPOUT_WAIT_STRATEGY</h4> |
| <pre>public static final java.lang.String TOPOLOGY_SPOUT_WAIT_STRATEGY</pre> |
| <div class="block">A class that implements a strategy for what to do when a spout needs to wait. Waiting is |
| triggered in one of two conditions: |
| <p> |
| 1. nextTuple emits no tuples |
| 2. The spout has hit maxSpoutPending and can't emit any more tuples |
| This is not yet implemented in Heron.</div> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.TOPOLOGY_SPOUT_WAIT_STRATEGY">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="TOPOLOGY_SLEEP_SPOUT_WAIT_STRATEGY_TIME_MS"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>TOPOLOGY_SLEEP_SPOUT_WAIT_STRATEGY_TIME_MS</h4> |
| <pre>public static final java.lang.String TOPOLOGY_SLEEP_SPOUT_WAIT_STRATEGY_TIME_MS</pre> |
| <div class="block">The amount of milliseconds the SleepEmptyEmitStrategy should sleep for. |
| This is not yet implemented in Heron</div> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.TOPOLOGY_SLEEP_SPOUT_WAIT_STRATEGY_TIME_MS">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="TOPOLOGY_STATS_SAMPLE_RATE"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>TOPOLOGY_STATS_SAMPLE_RATE</h4> |
| <pre>public static final java.lang.String TOPOLOGY_STATS_SAMPLE_RATE</pre> |
| <div class="block">The percentage of tuples to sample to produce stats for a task. |
| This is not implemented in Heron.</div> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.TOPOLOGY_STATS_SAMPLE_RATE">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="TOPOLOGY_AUTO_TASK_HOOKS"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>TOPOLOGY_AUTO_TASK_HOOKS</h4> |
| <pre>public static final java.lang.String TOPOLOGY_AUTO_TASK_HOOKS</pre> |
| <div class="block">A list of task hooks that are automatically added to every spout and bolt in the topology. An example |
| of when you'd do this is to add a hook that integrates with your internal |
| monitoring system. These hooks are instantiated using the zero-arg constructor.</div> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.TOPOLOGY_AUTO_TASK_HOOKS">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="TOPOLOGY_NAME"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>TOPOLOGY_NAME</h4> |
| <pre>public static final java.lang.String TOPOLOGY_NAME</pre> |
| <div class="block">Name of the topology. This config is automatically set by Storm when the topology is submitted. |
| Same in Heron</div> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.TOPOLOGY_NAME">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="TOPOLOGY_TEAM_NAME"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>TOPOLOGY_TEAM_NAME</h4> |
| <pre>public static final java.lang.String TOPOLOGY_TEAM_NAME</pre> |
| <div class="block">Name of the team which owns this topology. |
| Same in Heron</div> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.TOPOLOGY_TEAM_NAME">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="TOPOLOGY_TEAM_EMAIL"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>TOPOLOGY_TEAM_EMAIL</h4> |
| <pre>public static final java.lang.String TOPOLOGY_TEAM_EMAIL</pre> |
| <div class="block">Email of the team which owns this topology. |
| Same in Heron</div> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.TOPOLOGY_TEAM_EMAIL">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="TOPOLOGY_CAP_TICKET"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>TOPOLOGY_CAP_TICKET</h4> |
| <pre>public static final java.lang.String TOPOLOGY_CAP_TICKET</pre> |
| <div class="block">Cap ticket (if filed) for the topology. If the topology is in prod this has to be set or it |
| cannot be deployed. |
| Same in Heron</div> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.TOPOLOGY_CAP_TICKET">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="TOPOLOGY_PROJECT_NAME"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>TOPOLOGY_PROJECT_NAME</h4> |
| <pre>public static final java.lang.String TOPOLOGY_PROJECT_NAME</pre> |
| <div class="block">Project name of the topology, to help us with tagging which topologies are part of which project. For example, if topology A and |
| Topology B are part of the same project, we will like to aggregate them as part of the same project. This is required by Cap team. |
| Same in Heron</div> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.TOPOLOGY_PROJECT_NAME">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="STORM_ZOOKEEPER_SERVERS"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>STORM_ZOOKEEPER_SERVERS</h4> |
| <pre>public static final java.lang.String STORM_ZOOKEEPER_SERVERS</pre> |
| <div class="block">A list of hosts of ZooKeeper servers used to manage the cluster.</div> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.STORM_ZOOKEEPER_SERVERS">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="STORM_ZOOKEEPER_PORT"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>STORM_ZOOKEEPER_PORT</h4> |
| <pre>public static final java.lang.String STORM_ZOOKEEPER_PORT</pre> |
| <div class="block">The port Storm will use to connect to each of the ZooKeeper servers.</div> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.STORM_ZOOKEEPER_PORT">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="TRANSACTIONAL_ZOOKEEPER_ROOT"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>TRANSACTIONAL_ZOOKEEPER_ROOT</h4> |
| <pre>public static final java.lang.String TRANSACTIONAL_ZOOKEEPER_ROOT</pre> |
| <div class="block">The root directory in ZooKeeper for metadata about TransactionalSpouts.</div> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.TRANSACTIONAL_ZOOKEEPER_ROOT">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="STORM_ZOOKEEPER_SESSION_TIMEOUT"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>STORM_ZOOKEEPER_SESSION_TIMEOUT</h4> |
| <pre>public static final java.lang.String STORM_ZOOKEEPER_SESSION_TIMEOUT</pre> |
| <div class="block">The session timeout for clients to ZooKeeper.</div> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.STORM_ZOOKEEPER_SESSION_TIMEOUT">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="STORM_ZOOKEEPER_CONNECTION_TIMEOUT"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>STORM_ZOOKEEPER_CONNECTION_TIMEOUT</h4> |
| <pre>public static final java.lang.String STORM_ZOOKEEPER_CONNECTION_TIMEOUT</pre> |
| <div class="block">The connection timeout for clients to ZooKeeper.</div> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.STORM_ZOOKEEPER_CONNECTION_TIMEOUT">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="STORM_ZOOKEEPER_RETRY_TIMES"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>STORM_ZOOKEEPER_RETRY_TIMES</h4> |
| <pre>public static final java.lang.String STORM_ZOOKEEPER_RETRY_TIMES</pre> |
| <div class="block">The number of times to retry a Zookeeper operation.</div> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.STORM_ZOOKEEPER_RETRY_TIMES">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="STORM_ZOOKEEPER_RETRY_INTERVAL"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>STORM_ZOOKEEPER_RETRY_INTERVAL</h4> |
| <pre>public static final java.lang.String STORM_ZOOKEEPER_RETRY_INTERVAL</pre> |
| <div class="block">The interval between retries of a Zookeeper operation.</div> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.STORM_ZOOKEEPER_RETRY_INTERVAL">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="TRANSACTIONAL_ZOOKEEPER_SERVERS"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>TRANSACTIONAL_ZOOKEEPER_SERVERS</h4> |
| <pre>public static final java.lang.String TRANSACTIONAL_ZOOKEEPER_SERVERS</pre> |
| <div class="block">The list of zookeeper servers in which to keep the transactional state. If null (which is default), |
| will use storm.zookeeper.servers</div> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.TRANSACTIONAL_ZOOKEEPER_SERVERS">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="TRANSACTIONAL_ZOOKEEPER_PORT"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>TRANSACTIONAL_ZOOKEEPER_PORT</h4> |
| <pre>public static final java.lang.String TRANSACTIONAL_ZOOKEEPER_PORT</pre> |
| <div class="block">The port to use to connect to the transactional zookeeper servers. If null (which is default), |
| will use storm.zookeeper.port</div> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.TRANSACTIONAL_ZOOKEEPER_PORT">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="TOPOLOGY_BOLTS_WINDOW_LENGTH_COUNT"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>TOPOLOGY_BOLTS_WINDOW_LENGTH_COUNT</h4> |
| <pre>public static final java.lang.String TOPOLOGY_BOLTS_WINDOW_LENGTH_COUNT</pre> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.TOPOLOGY_BOLTS_WINDOW_LENGTH_COUNT">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="TOPOLOGY_BOLTS_WINDOW_LENGTH_DURATION_MS"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>TOPOLOGY_BOLTS_WINDOW_LENGTH_DURATION_MS</h4> |
| <pre>public static final java.lang.String TOPOLOGY_BOLTS_WINDOW_LENGTH_DURATION_MS</pre> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.TOPOLOGY_BOLTS_WINDOW_LENGTH_DURATION_MS">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="TOPOLOGY_BOLTS_SLIDING_INTERVAL_COUNT"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>TOPOLOGY_BOLTS_SLIDING_INTERVAL_COUNT</h4> |
| <pre>public static final java.lang.String TOPOLOGY_BOLTS_SLIDING_INTERVAL_COUNT</pre> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.TOPOLOGY_BOLTS_SLIDING_INTERVAL_COUNT">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="TOPOLOGY_BOLTS_SLIDING_INTERVAL_DURATION_MS"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>TOPOLOGY_BOLTS_SLIDING_INTERVAL_DURATION_MS</h4> |
| <pre>public static final java.lang.String TOPOLOGY_BOLTS_SLIDING_INTERVAL_DURATION_MS</pre> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.TOPOLOGY_BOLTS_SLIDING_INTERVAL_DURATION_MS">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="TOPOLOGY_BOLTS_LATE_TUPLE_STREAM"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>TOPOLOGY_BOLTS_LATE_TUPLE_STREAM</h4> |
| <pre>public static final java.lang.String TOPOLOGY_BOLTS_LATE_TUPLE_STREAM</pre> |
| <div class="block">Bolt-specific configuration for windowed bolts to specify the name of the stream on which late tuples are |
| going to be emitted. This configuration should only be used from the BaseWindowedBolt.withLateTupleStream builder |
| method, and not as global parameter, otherwise IllegalArgumentException is going to be thrown.</div> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.TOPOLOGY_BOLTS_LATE_TUPLE_STREAM">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="TOPOLOGY_BOLTS_TUPLE_TIMESTAMP_MAX_LAG_MS"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>TOPOLOGY_BOLTS_TUPLE_TIMESTAMP_MAX_LAG_MS</h4> |
| <pre>public static final java.lang.String TOPOLOGY_BOLTS_TUPLE_TIMESTAMP_MAX_LAG_MS</pre> |
| <div class="block">Bolt-specific configuration for windowed bolts to specify the maximum time lag of the tuple timestamp |
| in milliseconds. It means that the tuple timestamps cannot be out of order by more than this amount. |
| This config will be effective only if <a href="windowing/TimestampExtractor.html" title="interface in org.apache.storm.windowing"><code>TimestampExtractor</code></a> is specified.</div> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.TOPOLOGY_BOLTS_TUPLE_TIMESTAMP_MAX_LAG_MS">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="TOPOLOGY_BOLTS_WATERMARK_EVENT_INTERVAL_MS"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>TOPOLOGY_BOLTS_WATERMARK_EVENT_INTERVAL_MS</h4> |
| <pre>public static final java.lang.String TOPOLOGY_BOLTS_WATERMARK_EVENT_INTERVAL_MS</pre> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.TOPOLOGY_BOLTS_WATERMARK_EVENT_INTERVAL_MS">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="TOPOLOGY_ENVIRONMENT"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>TOPOLOGY_ENVIRONMENT</h4> |
| <pre>public static final java.lang.String TOPOLOGY_ENVIRONMENT</pre> |
| <div class="block">Topology-specific environment variables for the worker child process. |
| This is added to the existing environment (that of the supervisor)</div> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.TOPOLOGY_ENVIRONMENT">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="STORMCOMPAT_TOPOLOGY_AUTO_TASK_HOOKS"> |
| <!-- --> |
| </a> |
| <ul class="blockListLast"> |
| <li class="blockList"> |
| <h4>STORMCOMPAT_TOPOLOGY_AUTO_TASK_HOOKS</h4> |
| <pre>public static final java.lang.String STORMCOMPAT_TOPOLOGY_AUTO_TASK_HOOKS</pre> |
| <div class="block">---- DO NOT USE ----- |
| This variable is used to rewrite the TOPOLOGY_AUTO_TASK_HOOKS variable. |
| As such this is a strictly internal config variable that is not exposed the user</div> |
| <dl> |
| <dt><span class="seeLabel">See Also:</span></dt> |
| <dd><a href="../../../constant-values.html#org.apache.storm.Config.STORMCOMPAT_TOPOLOGY_AUTO_TASK_HOOKS">Constant Field Values</a></dd> |
| </dl> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </section> |
| <!-- ========= CONSTRUCTOR DETAIL ======== --> |
| <section> |
| <ul class="blockList"> |
| <li class="blockList"><a id="constructor.detail"> |
| <!-- --> |
| </a> |
| <h3>Constructor Detail</h3> |
| <a id="<init>()"> |
| <!-- --> |
| </a> |
| <ul class="blockListLast"> |
| <li class="blockList"> |
| <h4>Config</h4> |
| <pre>public Config()</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </section> |
| <!-- ============ METHOD DETAIL ========== --> |
| <section> |
| <ul class="blockList"> |
| <li class="blockList"><a id="method.detail"> |
| <!-- --> |
| </a> |
| <h3>Method Detail</h3> |
| <a id="setDebug(java.util.Map,boolean)"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setDebug</h4> |
| <pre class="methodSignature">public static void setDebug​(java.util.Map conf, |
| boolean isOn)</pre> |
| </li> |
| </ul> |
| <a id="setTeamName(java.util.Map,java.lang.String)"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setTeamName</h4> |
| <pre class="methodSignature">public static void setTeamName​(java.util.Map conf, |
| java.lang.String teamName)</pre> |
| </li> |
| </ul> |
| <a id="setTeamEmail(java.util.Map,java.lang.String)"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setTeamEmail</h4> |
| <pre class="methodSignature">public static void setTeamEmail​(java.util.Map conf, |
| java.lang.String teamEmail)</pre> |
| </li> |
| </ul> |
| <a id="setTopologyCapTicket(java.util.Map,java.lang.String)"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setTopologyCapTicket</h4> |
| <pre class="methodSignature">public static void setTopologyCapTicket​(java.util.Map conf, |
| java.lang.String ticket)</pre> |
| </li> |
| </ul> |
| <a id="setTopologyProjectName(java.util.Map,java.lang.String)"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setTopologyProjectName</h4> |
| <pre class="methodSignature">public static void setTopologyProjectName​(java.util.Map conf, |
| java.lang.String project)</pre> |
| </li> |
| </ul> |
| <a id="setNumWorkers(java.util.Map,int)"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setNumWorkers</h4> |
| <pre class="methodSignature">public static void setNumWorkers​(java.util.Map conf, |
| int workers)</pre> |
| </li> |
| </ul> |
| <a id="setNumAckers(java.util.Map,int)"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setNumAckers</h4> |
| <pre class="methodSignature">public static void setNumAckers​(java.util.Map conf, |
| int numExecutors)</pre> |
| </li> |
| </ul> |
| <a id="setMessageTimeoutSecs(java.util.Map,int)"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setMessageTimeoutSecs</h4> |
| <pre class="methodSignature">public static void setMessageTimeoutSecs​(java.util.Map conf, |
| int secs)</pre> |
| </li> |
| </ul> |
| <a id="registerSerialization(java.util.Map,java.lang.Class)"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>registerSerialization</h4> |
| <pre class="methodSignature">public static void registerSerialization​(java.util.Map conf, |
| java.lang.Class klass)</pre> |
| </li> |
| </ul> |
| <a id="registerSerialization(java.util.Map,java.lang.Class,java.lang.Class)"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>registerSerialization</h4> |
| <pre class="methodSignature">public static void registerSerialization​(java.util.Map conf, |
| java.lang.Class klass, |
| java.lang.Class<? extends com.esotericsoftware.kryo.Serializer> serializerClass)</pre> |
| </li> |
| </ul> |
| <a id="registerDecorator(java.util.Map,java.lang.Class)"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>registerDecorator</h4> |
| <pre class="methodSignature">public static void registerDecorator​(java.util.Map conf, |
| java.lang.Class<? extends <a href="serialization/IKryoDecorator.html" title="interface in org.apache.storm.serialization">IKryoDecorator</a>> klass)</pre> |
| </li> |
| </ul> |
| <a id="setKryoFactory(java.util.Map,java.lang.Class)"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setKryoFactory</h4> |
| <pre class="methodSignature">public static void setKryoFactory​(java.util.Map conf, |
| java.lang.Class<? extends <a href="serialization/IKryoFactory.html" title="interface in org.apache.storm.serialization">IKryoFactory</a>> klass)</pre> |
| </li> |
| </ul> |
| <a id="setSkipMissingKryoRegistrations(java.util.Map,boolean)"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setSkipMissingKryoRegistrations</h4> |
| <pre class="methodSignature">public static void setSkipMissingKryoRegistrations​(java.util.Map conf, |
| boolean skip)</pre> |
| </li> |
| </ul> |
| <a id="setMaxTaskParallelism(java.util.Map,int)"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setMaxTaskParallelism</h4> |
| <pre class="methodSignature">public static void setMaxTaskParallelism​(java.util.Map conf, |
| int max)</pre> |
| </li> |
| </ul> |
| <a id="setMaxSpoutPending(java.util.Map,int)"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setMaxSpoutPending</h4> |
| <pre class="methodSignature">public static void setMaxSpoutPending​(java.util.Map conf, |
| int max)</pre> |
| </li> |
| </ul> |
| <a id="setStatsSampleRate(java.util.Map,double)"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setStatsSampleRate</h4> |
| <pre class="methodSignature">public static void setStatsSampleRate​(java.util.Map conf, |
| double rate)</pre> |
| </li> |
| </ul> |
| <a id="setFallBackOnJavaSerialization(java.util.Map,boolean)"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setFallBackOnJavaSerialization</h4> |
| <pre class="methodSignature">public static void setFallBackOnJavaSerialization​(java.util.Map conf, |
| boolean fallback)</pre> |
| </li> |
| </ul> |
| <a id="setEnvironment(java.util.Map,java.util.Map)"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setEnvironment</h4> |
| <pre class="methodSignature">public static void setEnvironment​(java.util.Map<java.lang.String,​java.lang.Object> conf, |
| java.util.Map env)</pre> |
| </li> |
| </ul> |
| <a id="setDebug(boolean)"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setDebug</h4> |
| <pre class="methodSignature">public void setDebug​(boolean isOn)</pre> |
| </li> |
| </ul> |
| <a id="setTeamName(java.lang.String)"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setTeamName</h4> |
| <pre class="methodSignature">public void setTeamName​(java.lang.String teamName)</pre> |
| </li> |
| </ul> |
| <a id="setTeamEmail(java.lang.String)"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setTeamEmail</h4> |
| <pre class="methodSignature">public void setTeamEmail​(java.lang.String teamEmail)</pre> |
| </li> |
| </ul> |
| <a id="setTopologyCapTicket(java.lang.String)"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setTopologyCapTicket</h4> |
| <pre class="methodSignature">public void setTopologyCapTicket​(java.lang.String ticket)</pre> |
| </li> |
| </ul> |
| <a id="setTopologyProjectName(java.lang.String)"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setTopologyProjectName</h4> |
| <pre class="methodSignature">public void setTopologyProjectName​(java.lang.String project)</pre> |
| </li> |
| </ul> |
| <a id="setOptimize(boolean)"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setOptimize</h4> |
| <pre class="methodSignature">@Deprecated |
| public void setOptimize​(boolean isOn)</pre> |
| <div class="deprecationBlock"><span class="deprecatedLabel">Deprecated.</span> |
| <div class="deprecationComment">we don't have optimization</div> |
| </div> |
| <div class="block">Set topology optimization</div> |
| <dl> |
| <dt><span class="paramLabel">Parameters:</span></dt> |
| <dd><code>isOn</code> - </dd> |
| </dl> |
| </li> |
| </ul> |
| <a id="setNumWorkers(int)"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setNumWorkers</h4> |
| <pre class="methodSignature">public void setNumWorkers​(int workers)</pre> |
| </li> |
| </ul> |
| <a id="setNumAckers(int)"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setNumAckers</h4> |
| <pre class="methodSignature">public void setNumAckers​(int numExecutors)</pre> |
| </li> |
| </ul> |
| <a id="setMessageTimeoutSecs(int)"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setMessageTimeoutSecs</h4> |
| <pre class="methodSignature">public void setMessageTimeoutSecs​(int secs)</pre> |
| </li> |
| </ul> |
| <a id="registerSerialization(java.lang.Class)"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>registerSerialization</h4> |
| <pre class="methodSignature">public void registerSerialization​(java.lang.Class klass)</pre> |
| </li> |
| </ul> |
| <a id="registerSerialization(java.lang.Class,java.lang.Class)"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>registerSerialization</h4> |
| <pre class="methodSignature">public void registerSerialization​(java.lang.Class klass, |
| java.lang.Class<? extends com.esotericsoftware.kryo.Serializer> serializerClass)</pre> |
| </li> |
| </ul> |
| <a id="registerMetricsConsumer(java.lang.Class,java.lang.Object,long)"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>registerMetricsConsumer</h4> |
| <pre class="methodSignature">public void registerMetricsConsumer​(java.lang.Class klass, |
| java.lang.Object argument, |
| long parallelismHint)</pre> |
| </li> |
| </ul> |
| <a id="registerMetricsConsumer(java.lang.Class,long)"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>registerMetricsConsumer</h4> |
| <pre class="methodSignature">public void registerMetricsConsumer​(java.lang.Class klass, |
| long parallelismHint)</pre> |
| </li> |
| </ul> |
| <a id="registerMetricsConsumer(java.lang.Class)"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>registerMetricsConsumer</h4> |
| <pre class="methodSignature">public void registerMetricsConsumer​(java.lang.Class klass)</pre> |
| </li> |
| </ul> |
| <a id="registerDecorator(java.lang.Class)"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>registerDecorator</h4> |
| <pre class="methodSignature">public void registerDecorator​(java.lang.Class<? extends <a href="serialization/IKryoDecorator.html" title="interface in org.apache.storm.serialization">IKryoDecorator</a>> klass)</pre> |
| </li> |
| </ul> |
| <a id="setKryoFactory(java.lang.Class)"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setKryoFactory</h4> |
| <pre class="methodSignature">public void setKryoFactory​(java.lang.Class<? extends <a href="serialization/IKryoFactory.html" title="interface in org.apache.storm.serialization">IKryoFactory</a>> klass)</pre> |
| </li> |
| </ul> |
| <a id="setSkipMissingKryoRegistrations(boolean)"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setSkipMissingKryoRegistrations</h4> |
| <pre class="methodSignature">public void setSkipMissingKryoRegistrations​(boolean skip)</pre> |
| </li> |
| </ul> |
| <a id="setMaxTaskParallelism(int)"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setMaxTaskParallelism</h4> |
| <pre class="methodSignature">public void setMaxTaskParallelism​(int max)</pre> |
| </li> |
| </ul> |
| <a id="setMaxSpoutPending(int)"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setMaxSpoutPending</h4> |
| <pre class="methodSignature">public void setMaxSpoutPending​(int max)</pre> |
| </li> |
| </ul> |
| <a id="setStatsSampleRate(double)"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setStatsSampleRate</h4> |
| <pre class="methodSignature">public void setStatsSampleRate​(double rate)</pre> |
| </li> |
| </ul> |
| <a id="setFallBackOnJavaSerialization(boolean)"> |
| <!-- --> |
| </a> |
| <ul class="blockListLast"> |
| <li class="blockList"> |
| <h4>setFallBackOnJavaSerialization</h4> |
| <pre class="methodSignature">public void setFallBackOnJavaSerialization​(boolean fallback)</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </section> |
| </li> |
| </ul> |
| </div> |
| </div> |
| </main> |
| <!-- ========= END OF CLASS DATA ========= --> |
| <footer role="contentinfo"> |
| <nav role="navigation"> |
| <!-- ======= START OF BOTTOM NAVBAR ====== --> |
| <div class="bottomNav"><a id="navbar.bottom"> |
| <!-- --> |
| </a> |
| <div class="skipNav"><a href="#skip.navbar.bottom" title="Skip navigation links">Skip navigation links</a></div> |
| <a id="navbar.bottom.firstrow"> |
| <!-- --> |
| </a> |
| <ul class="navList" title="Navigation"> |
| <li><a href="../../../index.html">Overview</a></li> |
| <li><a href="package-summary.html">Package</a></li> |
| <li class="navBarCell1Rev">Class</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" id="allclasses_navbar_bottom"> |
| <li><a href="../../../allclasses.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> |
| <noscript> |
| <div>JavaScript is disabled on your browser.</div> |
| </noscript> |
| </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 id="skip.navbar.bottom"> |
| <!-- --> |
| </a></div> |
| <!-- ======== END OF BOTTOM NAVBAR ======= --> |
| </nav> |
| </footer> |
| </body> |
| </html> |