blob: c299acb45a3be151687b6ec18abadb3eebf01fed [file] [log] [blame]
<!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>StormClusterStateImpl (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="StormClusterStateImpl (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":10,"i58":10,"i59":10,"i60":10,"i61":10,"i62":10,"i63":10,"i64":10,"i65":10};
var tabs = {65535:["t0","All 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/StormClusterStateImpl.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/cluster/StateStorageFactory.html" title="interface in org.apache.storm.cluster"><span class="typeNameLink">Prev&nbsp;Class</span></a></li>
<li><a href="../../../../org/apache/storm/cluster/VersionedData.html" title="class in org.apache.storm.cluster"><span class="typeNameLink">Next&nbsp;Class</span></a></li>
</ul>
<ul class="navList">
<li><a href="../../../../index.html?org/apache/storm/cluster/StormClusterStateImpl.html" target="_top">Frames</a></li>
<li><a href="StormClusterStateImpl.html" target="_top">No&nbsp;Frames</a></li>
</ul>
<ul class="navList" id="allclasses_navbar_top">
<li><a href="../../../../allclasses-noframe.html">All&nbsp;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:&nbsp;</li>
<li>Nested&nbsp;|&nbsp;</li>
<li>Field&nbsp;|&nbsp;</li>
<li><a href="#constructor.summary">Constr</a>&nbsp;|&nbsp;</li>
<li><a href="#method.summary">Method</a></li>
</ul>
<ul class="subNavList">
<li>Detail:&nbsp;</li>
<li>Field&nbsp;|&nbsp;</li>
<li><a href="#constructor.detail">Constr</a>&nbsp;|&nbsp;</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.cluster</div>
<h2 title="Class StormClusterStateImpl" class="title">Class StormClusterStateImpl</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.cluster.StormClusterStateImpl</li>
</ul>
</li>
</ul>
<div class="description">
<ul class="blockList">
<li class="blockList">
<dl>
<dt>All Implemented Interfaces:</dt>
<dd><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></dd>
</dl>
<hr>
<br>
<pre>public class <span class="typeNameLabel">StormClusterStateImpl</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/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></pre>
</li>
</ul>
</div>
<div class="summary">
<ul class="blockList">
<li class="blockList">
<!-- ======== 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">&nbsp;</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/cluster/StormClusterStateImpl.html#StormClusterStateImpl-org.apache.storm.cluster.IStateStorage-org.apache.storm.assignments.ILocalAssignmentsBackend-org.apache.storm.cluster.ClusterStateContext-boolean-">StormClusterStateImpl</a></span>(<a href="../../../../org/apache/storm/cluster/IStateStorage.html" title="interface in org.apache.storm.cluster">IStateStorage</a>&nbsp;stateStorage,
<a href="../../../../org/apache/storm/assignments/ILocalAssignmentsBackend.html" title="interface in org.apache.storm.assignments">ILocalAssignmentsBackend</a>&nbsp;assignmentsassignmentsBackend,
<a href="../../../../org/apache/storm/cluster/ClusterStateContext.html" title="class in org.apache.storm.cluster">ClusterStateContext</a>&nbsp;context,
boolean&nbsp;shouldCloseStateStorageOnDisconnect)</code>&nbsp;</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">&nbsp;</span></span><span id="t2" class="tableTab"><span><a href="javascript:show(2);">Instance Methods</a></span><span class="tabEnd">&nbsp;</span></span><span id="t4" class="tableTab"><span><a href="javascript:show(8);">Concrete Methods</a></span><span class="tabEnd">&nbsp;</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/cluster/StormClusterStateImpl.html#activateStorm-java.lang.String-org.apache.storm.generated.StormBase-java.util.Map-">activateStorm</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>&nbsp;stormId,
<a href="../../../../org/apache/storm/generated/StormBase.html" title="class in org.apache.storm.generated">StormBase</a>&nbsp;stormBase,
<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>&lt;<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>&gt;&nbsp;topoConf)</code>&nbsp;</td>
</tr>
<tr id="i1" 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>&lt;<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>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#activeKeys--">activeKeys</a></span>()</code>&nbsp;</td>
</tr>
<tr id="i2" 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>&lt;<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>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#activeStorms--">activeStorms</a></span>()</code>&nbsp;</td>
</tr>
<tr id="i3" class="rowColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#addNimbusHost-java.lang.String-org.apache.storm.generated.NimbusSummary-">addNimbusHost</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>&nbsp;nimbusId,
<a href="../../../../org/apache/storm/generated/NimbusSummary.html" title="class in org.apache.storm.generated">NimbusSummary</a>&nbsp;nimbusSummary)</code>&nbsp;</td>
</tr>
<tr id="i4" class="altColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#addPrivateWorkerKey-org.apache.storm.generated.WorkerTokenServiceType-java.lang.String-long-org.apache.storm.generated.PrivateWorkerKey-">addPrivateWorkerKey</a></span>(<a href="../../../../org/apache/storm/generated/WorkerTokenServiceType.html" title="enum in org.apache.storm.generated">WorkerTokenServiceType</a>&nbsp;type,
<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>&nbsp;topologyId,
long&nbsp;keyVersion,
<a href="../../../../org/apache/storm/generated/PrivateWorkerKey.html" title="class in org.apache.storm.generated">PrivateWorkerKey</a>&nbsp;key)</code>
<div class="block">Store a new version of a private key.</div>
</td>
</tr>
<tr id="i5" class="rowColor">
<td class="colFirst"><code><a href="../../../../org/apache/storm/generated/Assignment.html" title="class in org.apache.storm.generated">Assignment</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#assignmentInfo-java.lang.String-java.lang.Runnable-">assignmentInfo</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>&nbsp;stormId,
<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true" title="class or interface in java.lang">Runnable</a>&nbsp;callback)</code>
<div class="block">Get the assignment based on storm id from local backend.</div>
</td>
</tr>
<tr id="i6" class="altColor">
<td class="colFirst"><code><a href="../../../../org/apache/storm/cluster/VersionedData.html" title="class in org.apache.storm.cluster">VersionedData</a>&lt;<a href="../../../../org/apache/storm/generated/Assignment.html" title="class in org.apache.storm.generated">Assignment</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#assignmentInfoWithVersion-java.lang.String-java.lang.Runnable-">assignmentInfoWithVersion</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>&nbsp;stormId,
<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true" title="class or interface in java.lang">Runnable</a>&nbsp;callback)</code>&nbsp;</td>
</tr>
<tr id="i7" 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>&lt;<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>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#assignments-java.lang.Runnable-">assignments</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true" title="class or interface in java.lang">Runnable</a>&nbsp;callback)</code>&nbsp;</td>
</tr>
<tr id="i8" class="altColor">
<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>&lt;<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="../../../../org/apache/storm/generated/Assignment.html" title="class in org.apache.storm.generated">Assignment</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#assignmentsInfo--">assignmentsInfo</a></span>()</code>
<div class="block">Get all the topologies assignments mapping stormId -&gt; Assignment from local backend.</div>
</td>
</tr>
<tr id="i9" class="rowColor">
<td class="colFirst"><code><a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Integer.html?is-external=true" title="class or interface in java.lang">Integer</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#assignmentVersion-java.lang.String-java.lang.Runnable-">assignmentVersion</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>&nbsp;stormId,
<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true" title="class or interface in java.lang">Runnable</a>&nbsp;callback)</code>&nbsp;</td>
</tr>
<tr id="i10" 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>&lt;<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>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#backpressureTopologies--">backpressureTopologies</a></span>()</code>
<div class="block">Get backpressure topologies.</div>
</td>
</tr>
<tr id="i11" 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>&lt;<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>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#blobstore-java.lang.Runnable-">blobstore</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true" title="class or interface in java.lang">Runnable</a>&nbsp;callback)</code>&nbsp;</td>
</tr>
<tr id="i12" 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>&lt;<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>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#blobstoreInfo-java.lang.String-">blobstoreInfo</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>&nbsp;blobKey)</code>&nbsp;</td>
</tr>
<tr id="i13" class="rowColor">
<td class="colFirst"><code><a href="../../../../org/apache/storm/generated/Credentials.html" title="class in org.apache.storm.generated">Credentials</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#credentials-java.lang.String-java.lang.Runnable-">credentials</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>&nbsp;stormId,
<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true" title="class or interface in java.lang">Runnable</a>&nbsp;callback)</code>&nbsp;</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/cluster/StormClusterStateImpl.html#deleteTopologyProfileRequests-java.lang.String-org.apache.storm.generated.ProfileRequest-">deleteTopologyProfileRequests</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>&nbsp;stormId,
<a href="../../../../org/apache/storm/generated/ProfileRequest.html" title="class in org.apache.storm.generated">ProfileRequest</a>&nbsp;profileRequest)</code>&nbsp;</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/cluster/StormClusterStateImpl.html#disconnect--">disconnect</a></span>()</code>&nbsp;</td>
</tr>
<tr id="i16" 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>&lt;<a href="../../../../org/apache/storm/generated/ErrorInfo.html" title="class in org.apache.storm.generated">ErrorInfo</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#errors-java.lang.String-java.lang.String-">errors</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>&nbsp;stormId,
<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>&nbsp;componentId)</code>&nbsp;</td>
</tr>
<tr id="i17" 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>&lt;<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>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#errorTopologies--">errorTopologies</a></span>()</code>&nbsp;</td>
</tr>
<tr id="i18" class="altColor">
<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>&lt;<a href="../../../../org/apache/storm/generated/ExecutorInfo.html" title="class in org.apache.storm.generated">ExecutorInfo</a>,<a href="../../../../org/apache/storm/cluster/ExecutorBeat.html" title="class in org.apache.storm.cluster">ExecutorBeat</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#executorBeats-java.lang.String-java.util.Map-">executorBeats</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>&nbsp;stormId,
<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>&lt;<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>&lt;<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>&gt;,<a href="../../../../org/apache/storm/generated/NodeInfo.html" title="class in org.apache.storm.generated">NodeInfo</a>&gt;&nbsp;executorNodePort)</code>
<div class="block">need to take executor-&gt;node+port in explicitly so that we don&rsquo;t run into a situation where a long dead worker with a skewed clock overrides all the timestamps.</div>
</td>
</tr>
<tr id="i19" class="rowColor">
<td class="colFirst"><code><a href="../../../../org/apache/storm/nimbus/NimbusInfo.html" title="class in org.apache.storm.nimbus">NimbusInfo</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#getLeader-java.lang.Runnable-">getLeader</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true" title="class or interface in java.lang">Runnable</a>&nbsp;callback)</code>
<div class="block">Get leader info from state store, which was written when a master gains leadership.</div>
</td>
</tr>
<tr id="i20" class="altColor">
<td class="colFirst"><code>long</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#getNextPrivateWorkerKeyVersion-org.apache.storm.generated.WorkerTokenServiceType-java.lang.String-">getNextPrivateWorkerKeyVersion</a></span>(<a href="../../../../org/apache/storm/generated/WorkerTokenServiceType.html" title="enum in org.apache.storm.generated">WorkerTokenServiceType</a>&nbsp;type,
<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>&nbsp;topologyId)</code>
<div class="block">Get the next key version number that should be used for this topology id.</div>
</td>
</tr>
<tr id="i21" class="rowColor">
<td class="colFirst"><code><a href="../../../../org/apache/storm/generated/PrivateWorkerKey.html" title="class in org.apache.storm.generated">PrivateWorkerKey</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#getPrivateWorkerKey-org.apache.storm.generated.WorkerTokenServiceType-java.lang.String-long-">getPrivateWorkerKey</a></span>(<a href="../../../../org/apache/storm/generated/WorkerTokenServiceType.html" title="enum in org.apache.storm.generated">WorkerTokenServiceType</a>&nbsp;type,
<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>&nbsp;topologyId,
long&nbsp;keyVersion)</code>
<div class="block">Get a private key used to validate a token is correct.</div>
</td>
</tr>
<tr id="i22" 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>&lt;<a href="../../../../org/apache/storm/generated/ProfileRequest.html" title="class in org.apache.storm.generated">ProfileRequest</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#getTopologyProfileRequests-java.lang.String-">getTopologyProfileRequests</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>&nbsp;stormId)</code>&nbsp;</td>
</tr>
<tr id="i23" class="rowColor">
<td class="colFirst"><code><a href="../../../../org/apache/storm/generated/ClusterWorkerHeartbeat.html" title="class in org.apache.storm.generated">ClusterWorkerHeartbeat</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#getWorkerHeartbeat-java.lang.String-java.lang.String-java.lang.Long-">getWorkerHeartbeat</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>&nbsp;stormId,
<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>&nbsp;node,
<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>&nbsp;port)</code>&nbsp;</td>
</tr>
<tr id="i24" 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>&lt;<a href="../../../../org/apache/storm/generated/ProfileRequest.html" title="class in org.apache.storm.generated">ProfileRequest</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#getWorkerProfileRequests-java.lang.String-org.apache.storm.generated.NodeInfo-">getWorkerProfileRequests</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>&nbsp;stormId,
<a href="../../../../org/apache/storm/generated/NodeInfo.html" title="class in org.apache.storm.generated">NodeInfo</a>&nbsp;nodeInfo)</code>&nbsp;</td>
</tr>
<tr id="i25" 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>&lt;<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>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#heartbeatStorms--">heartbeatStorms</a></span>()</code>&nbsp;</td>
</tr>
<tr id="i26" class="altColor">
<td class="colFirst"><code><a href="https://docs.oracle.com/javase/8/docs/api/java/util/Set.html?is-external=true" title="class or interface in java.util">Set</a>&lt;<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>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#idsOfTopologiesWithPrivateWorkerKeys--">idsOfTopologiesWithPrivateWorkerKeys</a></span>()</code>
<div class="block">Get a list of all topologyIds that currently have private worker keys stored, of any kind.</div>
</td>
</tr>
<tr id="i27" class="rowColor">
<td class="colFirst"><code>boolean</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#isAssignmentsBackendSynchronized--">isAssignmentsBackendSynchronized</a></span>()</code>
<div class="block">Flag to indicate if the assignments synced successfully, see <a href="../../../../org/apache/storm/cluster/IStormClusterState.html#syncRemoteAssignments-java.util.Map-"><code>IStormClusterState.syncRemoteAssignments(Map)</code></a>.</div>
</td>
</tr>
<tr id="i28" class="altColor">
<td class="colFirst"><code>boolean</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#isPacemakerStateStore--">isPacemakerStateStore</a></span>()</code>
<div class="block">Flag to indicate if the Pacameker is backend store.</div>
</td>
</tr>
<tr id="i29" class="rowColor">
<td class="colFirst"><code>protected void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#issueCallback-java.util.concurrent.atomic.AtomicReference-">issueCallback</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/AtomicReference.html?is-external=true" title="class or interface in java.util.concurrent.atomic">AtomicReference</a>&lt;<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true" title="class or interface in java.lang">Runnable</a>&gt;&nbsp;cb)</code>&nbsp;</td>
</tr>
<tr id="i30" class="altColor">
<td class="colFirst"><code>protected void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#issueMapCallback-java.util.concurrent.ConcurrentHashMap-java.lang.String-">issueMapCallback</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ConcurrentHashMap.html?is-external=true" title="class or interface in java.util.concurrent">ConcurrentHashMap</a>&lt;<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/Runnable.html?is-external=true" title="class or interface in java.lang">Runnable</a>&gt;&nbsp;callbackConcurrentHashMap,
<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>&nbsp;key)</code>&nbsp;</td>
</tr>
<tr id="i31" class="rowColor">
<td class="colFirst"><code><a href="../../../../org/apache/storm/generated/ErrorInfo.html" title="class in org.apache.storm.generated">ErrorInfo</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#lastError-java.lang.String-java.lang.String-">lastError</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>&nbsp;stormId,
<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>&nbsp;componentId)</code>&nbsp;</td>
</tr>
<tr id="i32" 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>&lt;<a href="../../../../org/apache/storm/generated/NimbusSummary.html" title="class in org.apache.storm.generated">NimbusSummary</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#nimbuses--">nimbuses</a></span>()</code>&nbsp;</td>
</tr>
<tr id="i33" class="rowColor">
<td class="colFirst"><code><a href="../../../../org/apache/storm/generated/Assignment.html" title="class in org.apache.storm.generated">Assignment</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#remoteAssignmentInfo-java.lang.String-java.lang.Runnable-">remoteAssignmentInfo</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>&nbsp;stormId,
<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true" title="class or interface in java.lang">Runnable</a>&nbsp;callback)</code>
<div class="block">Get the assignment based on storm id from remote state store, eg: ZK.</div>
</td>
</tr>
<tr id="i34" class="altColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#removeAllPrivateWorkerKeys-java.lang.String-">removeAllPrivateWorkerKeys</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>&nbsp;topologyId)</code>
<div class="block">Remove all of the worker keys for a given topology.</div>
</td>
</tr>
<tr id="i35" class="rowColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#removeBackpressure-java.lang.String-">removeBackpressure</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>&nbsp;stormId)</code>
<div class="block">Remove backpressure.</div>
</td>
</tr>
<tr id="i36" class="altColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#removeBlobstoreKey-java.lang.String-">removeBlobstoreKey</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>&nbsp;blobKey)</code>&nbsp;</td>
</tr>
<tr id="i37" class="rowColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#removeExpiredPrivateWorkerKeys-java.lang.String-">removeExpiredPrivateWorkerKeys</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>&nbsp;topologyId)</code>
<div class="block">Remove all keys for the given topology that have expired.</div>
</td>
</tr>
<tr id="i38" class="altColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#removeKeyVersion-java.lang.String-">removeKeyVersion</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>&nbsp;blobKey)</code>&nbsp;</td>
</tr>
<tr id="i39" class="rowColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#removeStorm-java.lang.String-">removeStorm</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>&nbsp;stormId)</code>&nbsp;</td>
</tr>
<tr id="i40" class="altColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#removeStormBase-java.lang.String-">removeStormBase</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>&nbsp;stormId)</code>&nbsp;</td>
</tr>
<tr id="i41" class="rowColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#removeWorkerBackpressure-java.lang.String-java.lang.String-java.lang.Long-">removeWorkerBackpressure</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>&nbsp;stormId,
<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>&nbsp;node,
<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>&nbsp;port)</code>
<div class="block">Remove worker backpressure.</div>
</td>
</tr>
<tr id="i42" class="altColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#removeWorkerHeartbeat-java.lang.String-java.lang.String-java.lang.Long-">removeWorkerHeartbeat</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>&nbsp;stormId,
<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>&nbsp;node,
<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>&nbsp;port)</code>&nbsp;</td>
</tr>
<tr id="i43" class="rowColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#reportError-java.lang.String-java.lang.String-java.lang.String-java.lang.Long-java.lang.Throwable-">reportError</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>&nbsp;stormId,
<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>&nbsp;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>&nbsp;node,
<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>&nbsp;port,
<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true" title="class or interface in java.lang">Throwable</a>&nbsp;error)</code>&nbsp;</td>
</tr>
<tr id="i44" class="altColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#setAssignment-java.lang.String-org.apache.storm.generated.Assignment-java.util.Map-">setAssignment</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>&nbsp;stormId,
<a href="../../../../org/apache/storm/generated/Assignment.html" title="class in org.apache.storm.generated">Assignment</a>&nbsp;info,
<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>&lt;<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>&gt;&nbsp;topoConf)</code>&nbsp;</td>
</tr>
<tr id="i45" class="rowColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#setAssignmentsBackendSynchronized--">setAssignmentsBackendSynchronized</a></span>()</code>
<div class="block">Mark the assignments as synced successfully, see <a href="../../../../org/apache/storm/cluster/IStormClusterState.html#isAssignmentsBackendSynchronized--"><code>IStormClusterState.isAssignmentsBackendSynchronized()</code></a>.</div>
</td>
</tr>
<tr id="i46" class="altColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#setCredentials-java.lang.String-org.apache.storm.generated.Credentials-java.util.Map-">setCredentials</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>&nbsp;stormId,
<a href="../../../../org/apache/storm/generated/Credentials.html" title="class in org.apache.storm.generated">Credentials</a>&nbsp;creds,
<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>&lt;<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>&gt;&nbsp;topoConf)</code>&nbsp;</td>
</tr>
<tr id="i47" class="rowColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#setTopologyLogConfig-java.lang.String-org.apache.storm.generated.LogConfig-java.util.Map-">setTopologyLogConfig</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>&nbsp;stormId,
<a href="../../../../org/apache/storm/generated/LogConfig.html" title="class in org.apache.storm.generated">LogConfig</a>&nbsp;logConfig,
<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>&lt;<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>&gt;&nbsp;topoConf)</code>&nbsp;</td>
</tr>
<tr id="i48" class="altColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#setupBackpressure-java.lang.String-java.util.Map-">setupBackpressure</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>&nbsp;stormId,
<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>&lt;<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>&gt;&nbsp;topoConf)</code>
<div class="block">Setup backpressure.</div>
</td>
</tr>
<tr id="i49" class="rowColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#setupBlob-java.lang.String-org.apache.storm.nimbus.NimbusInfo-java.lang.Integer-">setupBlob</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>&nbsp;key,
<a href="../../../../org/apache/storm/nimbus/NimbusInfo.html" title="class in org.apache.storm.nimbus">NimbusInfo</a>&nbsp;nimbusInfo,
<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Integer.html?is-external=true" title="class or interface in java.lang">Integer</a>&nbsp;versionInfo)</code>&nbsp;</td>
</tr>
<tr id="i50" class="altColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#setupErrors-java.lang.String-java.util.Map-">setupErrors</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>&nbsp;stormId,
<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>&lt;<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>&gt;&nbsp;topoConf)</code>&nbsp;</td>
</tr>
<tr id="i51" class="rowColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#setupHeatbeats-java.lang.String-java.util.Map-">setupHeatbeats</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>&nbsp;stormId,
<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>&lt;<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>&gt;&nbsp;topoConf)</code>&nbsp;</td>
</tr>
<tr id="i52" class="altColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#setWorkerProfileRequest-java.lang.String-org.apache.storm.generated.ProfileRequest-">setWorkerProfileRequest</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>&nbsp;stormId,
<a href="../../../../org/apache/storm/generated/ProfileRequest.html" title="class in org.apache.storm.generated">ProfileRequest</a>&nbsp;profileRequest)</code>&nbsp;</td>
</tr>
<tr id="i53" class="rowColor">
<td class="colFirst"><code><a href="../../../../org/apache/storm/generated/StormBase.html" title="class in org.apache.storm.generated">StormBase</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#stormBase-java.lang.String-java.lang.Runnable-">stormBase</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>&nbsp;stormId,
<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true" title="class or interface in java.lang">Runnable</a>&nbsp;callback)</code>
<div class="block">Get a storm base for a topology.</div>
</td>
</tr>
<tr id="i54" 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/cluster/StormClusterStateImpl.html#stormId-java.lang.String-">stormId</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>&nbsp;stormName)</code>
<div class="block">Get storm id from passed name, null if the name doesn&rsquo;t exist on cluster.</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/cluster/StormClusterStateImpl.html#supervisorHeartbeat-java.lang.String-org.apache.storm.generated.SupervisorInfo-">supervisorHeartbeat</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>&nbsp;supervisorId,
<a href="../../../../org/apache/storm/generated/SupervisorInfo.html" title="class in org.apache.storm.generated">SupervisorInfo</a>&nbsp;info)</code>&nbsp;</td>
</tr>
<tr id="i56" class="altColor">
<td class="colFirst"><code><a href="../../../../org/apache/storm/generated/SupervisorInfo.html" title="class in org.apache.storm.generated">SupervisorInfo</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#supervisorInfo-java.lang.String-">supervisorInfo</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>&nbsp;supervisorId)</code>&nbsp;</td>
</tr>
<tr id="i57" 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>&lt;<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>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#supervisors-java.lang.Runnable-">supervisors</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true" title="class or interface in java.lang">Runnable</a>&nbsp;callback)</code>&nbsp;</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/cluster/StormClusterStateImpl.html#syncRemoteAssignments-java.util.Map-">syncRemoteAssignments</a></span>(<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>&lt;<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>,byte[]&gt;&nbsp;remote)</code>
<div class="block">Sync the remote state store assignments to local backend, used when master gains leadership, see <code>LeaderListenerCallback</code>.</div>
</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/cluster/StormClusterStateImpl.html#syncRemoteIds-java.util.Map-">syncRemoteIds</a></span>(<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>&lt;<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/String.html?is-external=true" title="class or interface in java.lang">String</a>&gt;&nbsp;remote)</code>
<div class="block">Sync all the active storm ids of the cluster, used now when master gains leadership.</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/cluster/StormClusterStateImpl.html#teardownHeartbeats-java.lang.String-">teardownHeartbeats</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>&nbsp;stormId)</code>&nbsp;</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/cluster/StormClusterStateImpl.html#teardownTopologyErrors-java.lang.String-">teardownTopologyErrors</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>&nbsp;stormId)</code>&nbsp;</td>
</tr>
<tr id="i62" class="altColor">
<td class="colFirst"><code>boolean</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/storm/cluster/StormClusterStateImpl.html#topologyBackpressure-java.lang.String-long-java.lang.Runnable-">topologyBackpressure</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>&nbsp;stormId,
long&nbsp;timeoutMs,
<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true" title="class or interface in java.lang">Runnable</a>&nbsp;callback)</code>
<div class="block">Check whether a topology is in throttle-on status or not: if the backpresure/storm-id dir is not empty, this topology has throttle-on, otherwise throttle-off.</div>
</td>
</tr>
<tr id="i63" 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/cluster/StormClusterStateImpl.html#topologyLogConfig-java.lang.String-java.lang.Runnable-">topologyLogConfig</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>&nbsp;stormId,
<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true" title="class or interface in java.lang">Runnable</a>&nbsp;cb)</code>&nbsp;</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/cluster/StormClusterStateImpl.html#updateStorm-java.lang.String-org.apache.storm.generated.StormBase-">updateStorm</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>&nbsp;stormId,
<a href="../../../../org/apache/storm/generated/StormBase.html" title="class in org.apache.storm.generated">StormBase</a>&nbsp;newElems)</code>
<div class="block">To update this function due to APersistentMap/APersistentSet is clojure&rsquo;s structure.</div>
</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/cluster/StormClusterStateImpl.html#workerHeartbeat-java.lang.String-java.lang.String-java.lang.Long-org.apache.storm.generated.ClusterWorkerHeartbeat-">workerHeartbeat</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>&nbsp;stormId,
<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>&nbsp;node,
<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>&nbsp;port,
<a href="../../../../org/apache/storm/generated/ClusterWorkerHeartbeat.html" title="class in org.apache.storm.generated">ClusterWorkerHeartbeat</a>&nbsp;info)</code>&nbsp;</td>
</tr>
</table>
<ul class="blockList">
<li class="blockList"><a name="methods.inherited.from.class.java.lang.Object">
<!-- -->
</a>
<h3>Methods inherited from class&nbsp;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>
<ul class="blockList">
<li class="blockList"><a name="methods.inherited.from.class.org.apache.storm.cluster.IStormClusterState">
<!-- -->
</a>
<h3>Methods inherited from interface&nbsp;org.apache.storm.cluster.<a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></h3>
<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#allSupervisorInfo--">allSupervisorInfo</a>, <a href="../../../../org/apache/storm/cluster/IStormClusterState.html#allSupervisorInfo-java.lang.Runnable-">allSupervisorInfo</a>, <a href="../../../../org/apache/storm/cluster/IStormClusterState.html#getTopoId-java.lang.String-">getTopoId</a>, <a href="../../../../org/apache/storm/cluster/IStormClusterState.html#topologyBases--">topologyBases</a></code></li>
</ul>
</li>
</ul>
</li>
</ul>
</div>
<div class="details">
<ul class="blockList">
<li class="blockList">
<!-- ========= CONSTRUCTOR DETAIL ======== -->
<ul class="blockList">
<li class="blockList"><a name="constructor.detail">
<!-- -->
</a>
<h3>Constructor Detail</h3>
<a name="StormClusterStateImpl-org.apache.storm.cluster.IStateStorage-org.apache.storm.assignments.ILocalAssignmentsBackend-org.apache.storm.cluster.ClusterStateContext-boolean-">
<!-- -->
</a>
<ul class="blockListLast">
<li class="blockList">
<h4>StormClusterStateImpl</h4>
<pre>public&nbsp;StormClusterStateImpl(<a href="../../../../org/apache/storm/cluster/IStateStorage.html" title="interface in org.apache.storm.cluster">IStateStorage</a>&nbsp;stateStorage,
<a href="../../../../org/apache/storm/assignments/ILocalAssignmentsBackend.html" title="interface in org.apache.storm.assignments">ILocalAssignmentsBackend</a>&nbsp;assignmentsassignmentsBackend,
<a href="../../../../org/apache/storm/cluster/ClusterStateContext.html" title="class in org.apache.storm.cluster">ClusterStateContext</a>&nbsp;context,
boolean&nbsp;shouldCloseStateStorageOnDisconnect)
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="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>
</li>
</ul>
<!-- ============ METHOD DETAIL ========== -->
<ul class="blockList">
<li class="blockList"><a name="method.detail">
<!-- -->
</a>
<h3>Method Detail</h3>
<a name="issueCallback-java.util.concurrent.atomic.AtomicReference-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>issueCallback</h4>
<pre>protected&nbsp;void&nbsp;issueCallback(<a href="https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/AtomicReference.html?is-external=true" title="class or interface in java.util.concurrent.atomic">AtomicReference</a>&lt;<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true" title="class or interface in java.lang">Runnable</a>&gt;&nbsp;cb)</pre>
</li>
</ul>
<a name="issueMapCallback-java.util.concurrent.ConcurrentHashMap-java.lang.String-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>issueMapCallback</h4>
<pre>protected&nbsp;void&nbsp;issueMapCallback(<a href="https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ConcurrentHashMap.html?is-external=true" title="class or interface in java.util.concurrent">ConcurrentHashMap</a>&lt;<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/Runnable.html?is-external=true" title="class or interface in java.lang">Runnable</a>&gt;&nbsp;callbackConcurrentHashMap,
<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>&nbsp;key)</pre>
</li>
</ul>
<a name="assignments-java.lang.Runnable-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>assignments</h4>
<pre>public&nbsp;<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>&lt;<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>&gt;&nbsp;assignments(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true" title="class or interface in java.lang">Runnable</a>&nbsp;callback)</pre>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#assignments-java.lang.Runnable-">assignments</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
</dl>
</li>
</ul>
<a name="assignmentInfo-java.lang.String-java.lang.Runnable-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>assignmentInfo</h4>
<pre>public&nbsp;<a href="../../../../org/apache/storm/generated/Assignment.html" title="class in org.apache.storm.generated">Assignment</a>&nbsp;assignmentInfo(<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>&nbsp;stormId,
<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true" title="class or interface in java.lang">Runnable</a>&nbsp;callback)</pre>
<div class="block"><span class="descfrmTypeLabel">Description copied from interface:&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#assignmentInfo-java.lang.String-java.lang.Runnable-">IStormClusterState</a></code></span></div>
<div class="block"><p>Get the assignment based on storm id from local backend.</p></div>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#assignmentInfo-java.lang.String-java.lang.Runnable-">assignmentInfo</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>stormId</code> - topology id</dd>
<dd><code>callback</code> - callback function</dd>
<dt><span class="returnLabel">Returns:</span></dt>
<dd><a href="../../../../org/apache/storm/generated/Assignment.html" title="class in org.apache.storm.generated"><code>Assignment</code></a></dd>
</dl>
</li>
</ul>
<a name="remoteAssignmentInfo-java.lang.String-java.lang.Runnable-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>remoteAssignmentInfo</h4>
<pre>public&nbsp;<a href="../../../../org/apache/storm/generated/Assignment.html" title="class in org.apache.storm.generated">Assignment</a>&nbsp;remoteAssignmentInfo(<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>&nbsp;stormId,
<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true" title="class or interface in java.lang">Runnable</a>&nbsp;callback)</pre>
<div class="block"><span class="descfrmTypeLabel">Description copied from interface:&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#remoteAssignmentInfo-java.lang.String-java.lang.Runnable-">IStormClusterState</a></code></span></div>
<div class="block"><p>Get the assignment based on storm id from remote state store, eg: ZK.</p></div>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#remoteAssignmentInfo-java.lang.String-java.lang.Runnable-">remoteAssignmentInfo</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>stormId</code> - topology id</dd>
<dd><code>callback</code> - callback function</dd>
<dt><span class="returnLabel">Returns:</span></dt>
<dd><a href="../../../../org/apache/storm/generated/Assignment.html" title="class in org.apache.storm.generated"><code>Assignment</code></a></dd>
</dl>
</li>
</ul>
<a name="assignmentsInfo--">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>assignmentsInfo</h4>
<pre>public&nbsp;<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>&lt;<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="../../../../org/apache/storm/generated/Assignment.html" title="class in org.apache.storm.generated">Assignment</a>&gt;&nbsp;assignmentsInfo()</pre>
<div class="block"><span class="descfrmTypeLabel">Description copied from interface:&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#assignmentsInfo--">IStormClusterState</a></code></span></div>
<div class="block"><p>Get all the topologies assignments mapping stormId -&gt; Assignment from local backend.</p></div>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#assignmentsInfo--">assignmentsInfo</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
<dt><span class="returnLabel">Returns:</span></dt>
<dd>stormId -&gt; Assignment mapping</dd>
</dl>
</li>
</ul>
<a name="syncRemoteAssignments-java.util.Map-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>syncRemoteAssignments</h4>
<pre>public&nbsp;void&nbsp;syncRemoteAssignments(<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>&lt;<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>,byte[]&gt;&nbsp;remote)</pre>
<div class="block"><span class="descfrmTypeLabel">Description copied from interface:&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#syncRemoteAssignments-java.util.Map-">IStormClusterState</a></code></span></div>
<div class="block"><p>Sync the remote state store assignments to local backend, used when master gains leadership, see <code>LeaderListenerCallback</code>.</p></div>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#syncRemoteAssignments-java.util.Map-">syncRemoteAssignments</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>remote</code> - assigned assignments for a specific <a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster"><code>IStormClusterState</code></a> instance, usually a supervisor/node.</dd>
</dl>
</li>
</ul>
<a name="isAssignmentsBackendSynchronized--">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>isAssignmentsBackendSynchronized</h4>
<pre>public&nbsp;boolean&nbsp;isAssignmentsBackendSynchronized()</pre>
<div class="block"><span class="descfrmTypeLabel">Description copied from interface:&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#isAssignmentsBackendSynchronized--">IStormClusterState</a></code></span></div>
<div class="block"><p>Flag to indicate if the assignments synced successfully, see <a href="../../../../org/apache/storm/cluster/IStormClusterState.html#syncRemoteAssignments-java.util.Map-"><code>IStormClusterState.syncRemoteAssignments(Map)</code></a>.</p></div>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#isAssignmentsBackendSynchronized--">isAssignmentsBackendSynchronized</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
<dt><span class="returnLabel">Returns:</span></dt>
<dd>true if is synced successfully</dd>
</dl>
</li>
</ul>
<a name="isPacemakerStateStore--">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>isPacemakerStateStore</h4>
<pre>public&nbsp;boolean&nbsp;isPacemakerStateStore()</pre>
<div class="block"><span class="descfrmTypeLabel">Description copied from interface:&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#isPacemakerStateStore--">IStormClusterState</a></code></span></div>
<div class="block"><p>Flag to indicate if the Pacameker is backend store.</p></div>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#isPacemakerStateStore--">isPacemakerStateStore</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
<dt><span class="returnLabel">Returns:</span></dt>
<dd>true if Pacemaker is being used as StateStore</dd>
</dl>
</li>
</ul>
<a name="setAssignmentsBackendSynchronized--">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>setAssignmentsBackendSynchronized</h4>
<pre>public&nbsp;void&nbsp;setAssignmentsBackendSynchronized()</pre>
<div class="block"><span class="descfrmTypeLabel">Description copied from interface:&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#setAssignmentsBackendSynchronized--">IStormClusterState</a></code></span></div>
<div class="block"><p>Mark the assignments as synced successfully, see <a href="../../../../org/apache/storm/cluster/IStormClusterState.html#isAssignmentsBackendSynchronized--"><code>IStormClusterState.isAssignmentsBackendSynchronized()</code></a>.</p></div>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#setAssignmentsBackendSynchronized--">setAssignmentsBackendSynchronized</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
</dl>
</li>
</ul>
<a name="assignmentInfoWithVersion-java.lang.String-java.lang.Runnable-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>assignmentInfoWithVersion</h4>
<pre>public&nbsp;<a href="../../../../org/apache/storm/cluster/VersionedData.html" title="class in org.apache.storm.cluster">VersionedData</a>&lt;<a href="../../../../org/apache/storm/generated/Assignment.html" title="class in org.apache.storm.generated">Assignment</a>&gt;&nbsp;assignmentInfoWithVersion(<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>&nbsp;stormId,
<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true" title="class or interface in java.lang">Runnable</a>&nbsp;callback)</pre>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#assignmentInfoWithVersion-java.lang.String-java.lang.Runnable-">assignmentInfoWithVersion</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
</dl>
</li>
</ul>
<a name="assignmentVersion-java.lang.String-java.lang.Runnable-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>assignmentVersion</h4>
<pre>public&nbsp;<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Integer.html?is-external=true" title="class or interface in java.lang">Integer</a>&nbsp;assignmentVersion(<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>&nbsp;stormId,
<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true" title="class or interface in java.lang">Runnable</a>&nbsp;callback)
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="../../../../org/apache/storm/cluster/IStormClusterState.html#assignmentVersion-java.lang.String-java.lang.Runnable-">assignmentVersion</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</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="blobstoreInfo-java.lang.String-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>blobstoreInfo</h4>
<pre>public&nbsp;<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>&lt;<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>&gt;&nbsp;blobstoreInfo(<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>&nbsp;blobKey)</pre>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#blobstoreInfo-java.lang.String-">blobstoreInfo</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
</dl>
</li>
</ul>
<a name="nimbuses--">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>nimbuses</h4>
<pre>public&nbsp;<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>&lt;<a href="../../../../org/apache/storm/generated/NimbusSummary.html" title="class in org.apache.storm.generated">NimbusSummary</a>&gt;&nbsp;nimbuses()</pre>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#nimbuses--">nimbuses</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
</dl>
</li>
</ul>
<a name="addNimbusHost-java.lang.String-org.apache.storm.generated.NimbusSummary-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>addNimbusHost</h4>
<pre>public&nbsp;void&nbsp;addNimbusHost(<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>&nbsp;nimbusId,
<a href="../../../../org/apache/storm/generated/NimbusSummary.html" title="class in org.apache.storm.generated">NimbusSummary</a>&nbsp;nimbusSummary)</pre>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#addNimbusHost-java.lang.String-org.apache.storm.generated.NimbusSummary-">addNimbusHost</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
</dl>
</li>
</ul>
<a name="activeStorms--">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>activeStorms</h4>
<pre>public&nbsp;<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>&lt;<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>&gt;&nbsp;activeStorms()</pre>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#activeStorms--">activeStorms</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
</dl>
</li>
</ul>
<a name="stormBase-java.lang.String-java.lang.Runnable-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>stormBase</h4>
<pre>public&nbsp;<a href="../../../../org/apache/storm/generated/StormBase.html" title="class in org.apache.storm.generated">StormBase</a>&nbsp;stormBase(<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>&nbsp;stormId,
<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true" title="class or interface in java.lang">Runnable</a>&nbsp;callback)</pre>
<div class="block"><span class="descfrmTypeLabel">Description copied from interface:&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#stormBase-java.lang.String-java.lang.Runnable-">IStormClusterState</a></code></span></div>
<div class="block"><p>Get a storm base for a topology.</p></div>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#stormBase-java.lang.String-java.lang.Runnable-">stormBase</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>stormId</code> - the id of the topology</dd>
<dd><code>callback</code> - something to call if the data changes (best effort)</dd>
<dt><span class="returnLabel">Returns:</span></dt>
<dd>the StormBase or null if it is not alive.</dd>
</dl>
</li>
</ul>
<a name="stormId-java.lang.String-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>stormId</h4>
<pre>public&nbsp;<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>&nbsp;stormId(<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>&nbsp;stormName)</pre>
<div class="block"><span class="descfrmTypeLabel">Description copied from interface:&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#stormId-java.lang.String-">IStormClusterState</a></code></span></div>
<div class="block"><p>Get storm id from passed name, null if the name doesn&rsquo;t exist on cluster.</p></div>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#stormId-java.lang.String-">stormId</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>stormName</code> - storm name</dd>
<dt><span class="returnLabel">Returns:</span></dt>
<dd>storm id</dd>
</dl>
</li>
</ul>
<a name="syncRemoteIds-java.util.Map-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>syncRemoteIds</h4>
<pre>public&nbsp;void&nbsp;syncRemoteIds(<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>&lt;<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/String.html?is-external=true" title="class or interface in java.lang">String</a>&gt;&nbsp;remote)</pre>
<div class="block"><span class="descfrmTypeLabel">Description copied from interface:&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#syncRemoteIds-java.util.Map-">IStormClusterState</a></code></span></div>
<div class="block"><p>Sync all the active storm ids of the cluster, used now when master gains leadership.</p></div>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#syncRemoteIds-java.util.Map-">syncRemoteIds</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>remote</code> - stormName -&gt; stormId mapping</dd>
</dl>
</li>
</ul>
<a name="getWorkerHeartbeat-java.lang.String-java.lang.String-java.lang.Long-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>getWorkerHeartbeat</h4>
<pre>public&nbsp;<a href="../../../../org/apache/storm/generated/ClusterWorkerHeartbeat.html" title="class in org.apache.storm.generated">ClusterWorkerHeartbeat</a>&nbsp;getWorkerHeartbeat(<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>&nbsp;stormId,
<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>&nbsp;node,
<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>&nbsp;port)</pre>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#getWorkerHeartbeat-java.lang.String-java.lang.String-java.lang.Long-">getWorkerHeartbeat</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
</dl>
</li>
</ul>
<a name="getWorkerProfileRequests-java.lang.String-org.apache.storm.generated.NodeInfo-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>getWorkerProfileRequests</h4>
<pre>public&nbsp;<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>&lt;<a href="../../../../org/apache/storm/generated/ProfileRequest.html" title="class in org.apache.storm.generated">ProfileRequest</a>&gt;&nbsp;getWorkerProfileRequests(<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>&nbsp;stormId,
<a href="../../../../org/apache/storm/generated/NodeInfo.html" title="class in org.apache.storm.generated">NodeInfo</a>&nbsp;nodeInfo)</pre>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#getWorkerProfileRequests-java.lang.String-org.apache.storm.generated.NodeInfo-">getWorkerProfileRequests</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
</dl>
</li>
</ul>
<a name="getTopologyProfileRequests-java.lang.String-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>getTopologyProfileRequests</h4>
<pre>public&nbsp;<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>&lt;<a href="../../../../org/apache/storm/generated/ProfileRequest.html" title="class in org.apache.storm.generated">ProfileRequest</a>&gt;&nbsp;getTopologyProfileRequests(<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>&nbsp;stormId)</pre>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#getTopologyProfileRequests-java.lang.String-">getTopologyProfileRequests</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
</dl>
</li>
</ul>
<a name="setWorkerProfileRequest-java.lang.String-org.apache.storm.generated.ProfileRequest-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>setWorkerProfileRequest</h4>
<pre>public&nbsp;void&nbsp;setWorkerProfileRequest(<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>&nbsp;stormId,
<a href="../../../../org/apache/storm/generated/ProfileRequest.html" title="class in org.apache.storm.generated">ProfileRequest</a>&nbsp;profileRequest)</pre>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#setWorkerProfileRequest-java.lang.String-org.apache.storm.generated.ProfileRequest-">setWorkerProfileRequest</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
</dl>
</li>
</ul>
<a name="deleteTopologyProfileRequests-java.lang.String-org.apache.storm.generated.ProfileRequest-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>deleteTopologyProfileRequests</h4>
<pre>public&nbsp;void&nbsp;deleteTopologyProfileRequests(<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>&nbsp;stormId,
<a href="../../../../org/apache/storm/generated/ProfileRequest.html" title="class in org.apache.storm.generated">ProfileRequest</a>&nbsp;profileRequest)</pre>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#deleteTopologyProfileRequests-java.lang.String-org.apache.storm.generated.ProfileRequest-">deleteTopologyProfileRequests</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
</dl>
</li>
</ul>
<a name="executorBeats-java.lang.String-java.util.Map-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>executorBeats</h4>
<pre>public&nbsp;<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>&lt;<a href="../../../../org/apache/storm/generated/ExecutorInfo.html" title="class in org.apache.storm.generated">ExecutorInfo</a>,<a href="../../../../org/apache/storm/cluster/ExecutorBeat.html" title="class in org.apache.storm.cluster">ExecutorBeat</a>&gt;&nbsp;executorBeats(<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>&nbsp;stormId,
<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>&lt;<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>&lt;<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>&gt;,<a href="../../../../org/apache/storm/generated/NodeInfo.html" title="class in org.apache.storm.generated">NodeInfo</a>&gt;&nbsp;executorNodePort)</pre>
<div class="block"><p>need to take executor-&gt;node+port in explicitly so that we don&rsquo;t run into a situation where a long dead worker with a skewed clock overrides all the timestamps. By only checking heartbeats with an assigned node+port, and only reading executors from that heartbeat that are actually assigned, we avoid situations like that.</p></div>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#executorBeats-java.lang.String-java.util.Map-">executorBeats</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>stormId</code> - topology id</dd>
<dd><code>executorNodePort</code> - executor id -&gt; node + port</dd>
<dt><span class="returnLabel">Returns:</span></dt>
<dd>mapping of executorInfo -&gt; executor beat</dd>
</dl>
</li>
</ul>
<a name="supervisors-java.lang.Runnable-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>supervisors</h4>
<pre>public&nbsp;<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>&lt;<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>&gt;&nbsp;supervisors(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true" title="class or interface in java.lang">Runnable</a>&nbsp;callback)</pre>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#supervisors-java.lang.Runnable-">supervisors</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
</dl>
</li>
</ul>
<a name="supervisorInfo-java.lang.String-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>supervisorInfo</h4>
<pre>public&nbsp;<a href="../../../../org/apache/storm/generated/SupervisorInfo.html" title="class in org.apache.storm.generated">SupervisorInfo</a>&nbsp;supervisorInfo(<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>&nbsp;supervisorId)</pre>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#supervisorInfo-java.lang.String-">supervisorInfo</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
</dl>
</li>
</ul>
<a name="setupHeatbeats-java.lang.String-java.util.Map-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>setupHeatbeats</h4>
<pre>public&nbsp;void&nbsp;setupHeatbeats(<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>&nbsp;stormId,
<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>&lt;<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>&gt;&nbsp;topoConf)</pre>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#setupHeatbeats-java.lang.String-java.util.Map-">setupHeatbeats</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
</dl>
</li>
</ul>
<a name="teardownHeartbeats-java.lang.String-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>teardownHeartbeats</h4>
<pre>public&nbsp;void&nbsp;teardownHeartbeats(<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>&nbsp;stormId)</pre>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#teardownHeartbeats-java.lang.String-">teardownHeartbeats</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
</dl>
</li>
</ul>
<a name="teardownTopologyErrors-java.lang.String-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>teardownTopologyErrors</h4>
<pre>public&nbsp;void&nbsp;teardownTopologyErrors(<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>&nbsp;stormId)</pre>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#teardownTopologyErrors-java.lang.String-">teardownTopologyErrors</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
</dl>
</li>
</ul>
<a name="getLeader-java.lang.Runnable-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>getLeader</h4>
<pre>public&nbsp;<a href="../../../../org/apache/storm/nimbus/NimbusInfo.html" title="class in org.apache.storm.nimbus">NimbusInfo</a>&nbsp;getLeader(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true" title="class or interface in java.lang">Runnable</a>&nbsp;callback)</pre>
<div class="block"><span class="descfrmTypeLabel">Description copied from interface:&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#getLeader-java.lang.Runnable-">IStormClusterState</a></code></span></div>
<div class="block"><p>Get leader info from state store, which was written when a master gains leadership.</p><p><p>Caution: it can not be used for fencing and is only for informational purposes because we use ZK as our backend now, which could have a overdue info of nodes.</p></div>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#getLeader-java.lang.Runnable-">getLeader</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>callback</code> - callback func</dd>
<dt><span class="returnLabel">Returns:</span></dt>
<dd><a href="../../../../org/apache/storm/nimbus/NimbusInfo.html" title="class in org.apache.storm.nimbus"><code>NimbusInfo</code></a></dd>
</dl>
</li>
</ul>
<a name="backpressureTopologies--">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>backpressureTopologies</h4>
<pre>public&nbsp;<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>&lt;<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>&gt;&nbsp;backpressureTopologies()</pre>
<div class="block"><span class="descfrmTypeLabel">Description copied from interface:&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#backpressureTopologies--">IStormClusterState</a></code></span></div>
<div class="block"><p>Get backpressure topologies.</p></div>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#backpressureTopologies--">backpressureTopologies</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
</dl>
</li>
</ul>
<a name="heartbeatStorms--">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>heartbeatStorms</h4>
<pre>public&nbsp;<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>&lt;<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>&gt;&nbsp;heartbeatStorms()</pre>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#heartbeatStorms--">heartbeatStorms</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
</dl>
</li>
</ul>
<a name="errorTopologies--">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>errorTopologies</h4>
<pre>public&nbsp;<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>&lt;<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>&gt;&nbsp;errorTopologies()</pre>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#errorTopologies--">errorTopologies</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
</dl>
</li>
</ul>
<a name="setTopologyLogConfig-java.lang.String-org.apache.storm.generated.LogConfig-java.util.Map-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>setTopologyLogConfig</h4>
<pre>public&nbsp;void&nbsp;setTopologyLogConfig(<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>&nbsp;stormId,
<a href="../../../../org/apache/storm/generated/LogConfig.html" title="class in org.apache.storm.generated">LogConfig</a>&nbsp;logConfig,
<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>&lt;<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>&gt;&nbsp;topoConf)</pre>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#setTopologyLogConfig-java.lang.String-org.apache.storm.generated.LogConfig-java.util.Map-">setTopologyLogConfig</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
</dl>
</li>
</ul>
<a name="topologyLogConfig-java.lang.String-java.lang.Runnable-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>topologyLogConfig</h4>
<pre>public&nbsp;<a href="../../../../org/apache/storm/generated/LogConfig.html" title="class in org.apache.storm.generated">LogConfig</a>&nbsp;topologyLogConfig(<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>&nbsp;stormId,
<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true" title="class or interface in java.lang">Runnable</a>&nbsp;cb)</pre>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#topologyLogConfig-java.lang.String-java.lang.Runnable-">topologyLogConfig</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
</dl>
</li>
</ul>
<a name="workerHeartbeat-java.lang.String-java.lang.String-java.lang.Long-org.apache.storm.generated.ClusterWorkerHeartbeat-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>workerHeartbeat</h4>
<pre>public&nbsp;void&nbsp;workerHeartbeat(<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>&nbsp;stormId,
<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>&nbsp;node,
<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>&nbsp;port,
<a href="../../../../org/apache/storm/generated/ClusterWorkerHeartbeat.html" title="class in org.apache.storm.generated">ClusterWorkerHeartbeat</a>&nbsp;info)</pre>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#workerHeartbeat-java.lang.String-java.lang.String-java.lang.Long-org.apache.storm.generated.ClusterWorkerHeartbeat-">workerHeartbeat</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
</dl>
</li>
</ul>
<a name="removeWorkerHeartbeat-java.lang.String-java.lang.String-java.lang.Long-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>removeWorkerHeartbeat</h4>
<pre>public&nbsp;void&nbsp;removeWorkerHeartbeat(<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>&nbsp;stormId,
<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>&nbsp;node,
<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>&nbsp;port)</pre>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#removeWorkerHeartbeat-java.lang.String-java.lang.String-java.lang.Long-">removeWorkerHeartbeat</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
</dl>
</li>
</ul>
<a name="supervisorHeartbeat-java.lang.String-org.apache.storm.generated.SupervisorInfo-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>supervisorHeartbeat</h4>
<pre>public&nbsp;void&nbsp;supervisorHeartbeat(<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>&nbsp;supervisorId,
<a href="../../../../org/apache/storm/generated/SupervisorInfo.html" title="class in org.apache.storm.generated">SupervisorInfo</a>&nbsp;info)</pre>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#supervisorHeartbeat-java.lang.String-org.apache.storm.generated.SupervisorInfo-">supervisorHeartbeat</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
</dl>
</li>
</ul>
<a name="topologyBackpressure-java.lang.String-long-java.lang.Runnable-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>topologyBackpressure</h4>
<pre>public&nbsp;boolean&nbsp;topologyBackpressure(<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>&nbsp;stormId,
long&nbsp;timeoutMs,
<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true" title="class or interface in java.lang">Runnable</a>&nbsp;callback)</pre>
<div class="block"><p>Check whether a topology is in throttle-on status or not: if the backpresure/storm-id dir is not empty, this topology has throttle-on, otherwise throttle-off. But if the backpresure/storm-id dir is not empty and has not been updated for more than timeoutMs, we treat it as throttle-off. This will prevent the spouts from getting stuck indefinitely if something wrong happens.</p></div>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#topologyBackpressure-java.lang.String-long-java.lang.Runnable-">topologyBackpressure</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>stormId</code> - The topology Id</dd>
<dd><code>timeoutMs</code> - How long until the backpressure znode is invalid.</dd>
<dd><code>callback</code> - The callback function</dd>
<dt><span class="returnLabel">Returns:</span></dt>
<dd>True is backpresure/storm-id dir is not empty and at least one of the backpressure znodes has not timed out; false otherwise.</dd>
</dl>
</li>
</ul>
<a name="setupBackpressure-java.lang.String-java.util.Map-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>setupBackpressure</h4>
<pre>public&nbsp;void&nbsp;setupBackpressure(<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>&nbsp;stormId,
<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>&lt;<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>&gt;&nbsp;topoConf)</pre>
<div class="block"><span class="descfrmTypeLabel">Description copied from interface:&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#setupBackpressure-java.lang.String-java.util.Map-">IStormClusterState</a></code></span></div>
<div class="block"><p>Setup backpressure.</p></div>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#setupBackpressure-java.lang.String-java.util.Map-">setupBackpressure</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
</dl>
</li>
</ul>
<a name="removeBackpressure-java.lang.String-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>removeBackpressure</h4>
<pre>public&nbsp;void&nbsp;removeBackpressure(<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>&nbsp;stormId)</pre>
<div class="block"><span class="descfrmTypeLabel">Description copied from interface:&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#removeBackpressure-java.lang.String-">IStormClusterState</a></code></span></div>
<div class="block"><p>Remove backpressure.</p></div>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#removeBackpressure-java.lang.String-">removeBackpressure</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
</dl>
</li>
</ul>
<a name="removeWorkerBackpressure-java.lang.String-java.lang.String-java.lang.Long-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>removeWorkerBackpressure</h4>
<pre>public&nbsp;void&nbsp;removeWorkerBackpressure(<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>&nbsp;stormId,
<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>&nbsp;node,
<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>&nbsp;port)</pre>
<div class="block"><span class="descfrmTypeLabel">Description copied from interface:&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#removeWorkerBackpressure-java.lang.String-java.lang.String-java.lang.Long-">IStormClusterState</a></code></span></div>
<div class="block"><p>Remove worker backpressure.</p></div>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#removeWorkerBackpressure-java.lang.String-java.lang.String-java.lang.Long-">removeWorkerBackpressure</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
</dl>
</li>
</ul>
<a name="activateStorm-java.lang.String-org.apache.storm.generated.StormBase-java.util.Map-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>activateStorm</h4>
<pre>public&nbsp;void&nbsp;activateStorm(<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>&nbsp;stormId,
<a href="../../../../org/apache/storm/generated/StormBase.html" title="class in org.apache.storm.generated">StormBase</a>&nbsp;stormBase,
<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>&lt;<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>&gt;&nbsp;topoConf)</pre>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#activateStorm-java.lang.String-org.apache.storm.generated.StormBase-java.util.Map-">activateStorm</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
</dl>
</li>
</ul>
<a name="updateStorm-java.lang.String-org.apache.storm.generated.StormBase-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>updateStorm</h4>
<pre>public&nbsp;void&nbsp;updateStorm(<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>&nbsp;stormId,
<a href="../../../../org/apache/storm/generated/StormBase.html" title="class in org.apache.storm.generated">StormBase</a>&nbsp;newElems)</pre>
<div class="block"><p>To update this function due to APersistentMap/APersistentSet is clojure&rsquo;s structure.</p></div>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#updateStorm-java.lang.String-org.apache.storm.generated.StormBase-">updateStorm</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
</dl>
</li>
</ul>
<a name="removeStormBase-java.lang.String-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>removeStormBase</h4>
<pre>public&nbsp;void&nbsp;removeStormBase(<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>&nbsp;stormId)</pre>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#removeStormBase-java.lang.String-">removeStormBase</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
</dl>
</li>
</ul>
<a name="setAssignment-java.lang.String-org.apache.storm.generated.Assignment-java.util.Map-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>setAssignment</h4>
<pre>public&nbsp;void&nbsp;setAssignment(<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>&nbsp;stormId,
<a href="../../../../org/apache/storm/generated/Assignment.html" title="class in org.apache.storm.generated">Assignment</a>&nbsp;info,
<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>&lt;<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>&gt;&nbsp;topoConf)</pre>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#setAssignment-java.lang.String-org.apache.storm.generated.Assignment-java.util.Map-">setAssignment</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
</dl>
</li>
</ul>
<a name="setupBlob-java.lang.String-org.apache.storm.nimbus.NimbusInfo-java.lang.Integer-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>setupBlob</h4>
<pre>public&nbsp;void&nbsp;setupBlob(<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>&nbsp;key,
<a href="../../../../org/apache/storm/nimbus/NimbusInfo.html" title="class in org.apache.storm.nimbus">NimbusInfo</a>&nbsp;nimbusInfo,
<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Integer.html?is-external=true" title="class or interface in java.lang">Integer</a>&nbsp;versionInfo)</pre>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#setupBlob-java.lang.String-org.apache.storm.nimbus.NimbusInfo-java.lang.Integer-">setupBlob</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
</dl>
</li>
</ul>
<a name="activeKeys--">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>activeKeys</h4>
<pre>public&nbsp;<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>&lt;<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>&gt;&nbsp;activeKeys()</pre>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#activeKeys--">activeKeys</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
</dl>
</li>
</ul>
<a name="blobstore-java.lang.Runnable-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>blobstore</h4>
<pre>public&nbsp;<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>&lt;<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>&gt;&nbsp;blobstore(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true" title="class or interface in java.lang">Runnable</a>&nbsp;callback)</pre>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#blobstore-java.lang.Runnable-">blobstore</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
</dl>
</li>
</ul>
<a name="removeStorm-java.lang.String-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>removeStorm</h4>
<pre>public&nbsp;void&nbsp;removeStorm(<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>&nbsp;stormId)</pre>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#removeStorm-java.lang.String-">removeStorm</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
</dl>
</li>
</ul>
<a name="removeBlobstoreKey-java.lang.String-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>removeBlobstoreKey</h4>
<pre>public&nbsp;void&nbsp;removeBlobstoreKey(<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>&nbsp;blobKey)</pre>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#removeBlobstoreKey-java.lang.String-">removeBlobstoreKey</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
</dl>
</li>
</ul>
<a name="removeKeyVersion-java.lang.String-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>removeKeyVersion</h4>
<pre>public&nbsp;void&nbsp;removeKeyVersion(<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>&nbsp;blobKey)</pre>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#removeKeyVersion-java.lang.String-">removeKeyVersion</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
</dl>
</li>
</ul>
<a name="setupErrors-java.lang.String-java.util.Map-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>setupErrors</h4>
<pre>public&nbsp;void&nbsp;setupErrors(<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>&nbsp;stormId,
<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>&lt;<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>&gt;&nbsp;topoConf)</pre>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#setupErrors-java.lang.String-java.util.Map-">setupErrors</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
</dl>
</li>
</ul>
<a name="reportError-java.lang.String-java.lang.String-java.lang.String-java.lang.Long-java.lang.Throwable-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>reportError</h4>
<pre>public&nbsp;void&nbsp;reportError(<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>&nbsp;stormId,
<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>&nbsp;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>&nbsp;node,
<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>&nbsp;port,
<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true" title="class or interface in java.lang">Throwable</a>&nbsp;error)</pre>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#reportError-java.lang.String-java.lang.String-java.lang.String-java.lang.Long-java.lang.Throwable-">reportError</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
</dl>
</li>
</ul>
<a name="errors-java.lang.String-java.lang.String-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>errors</h4>
<pre>public&nbsp;<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>&lt;<a href="../../../../org/apache/storm/generated/ErrorInfo.html" title="class in org.apache.storm.generated">ErrorInfo</a>&gt;&nbsp;errors(<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>&nbsp;stormId,
<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>&nbsp;componentId)</pre>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#errors-java.lang.String-java.lang.String-">errors</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
</dl>
</li>
</ul>
<a name="lastError-java.lang.String-java.lang.String-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>lastError</h4>
<pre>public&nbsp;<a href="../../../../org/apache/storm/generated/ErrorInfo.html" title="class in org.apache.storm.generated">ErrorInfo</a>&nbsp;lastError(<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>&nbsp;stormId,
<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>&nbsp;componentId)</pre>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#lastError-java.lang.String-java.lang.String-">lastError</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
</dl>
</li>
</ul>
<a name="setCredentials-java.lang.String-org.apache.storm.generated.Credentials-java.util.Map-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>setCredentials</h4>
<pre>public&nbsp;void&nbsp;setCredentials(<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>&nbsp;stormId,
<a href="../../../../org/apache/storm/generated/Credentials.html" title="class in org.apache.storm.generated">Credentials</a>&nbsp;creds,
<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>&lt;<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>&gt;&nbsp;topoConf)</pre>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#setCredentials-java.lang.String-org.apache.storm.generated.Credentials-java.util.Map-">setCredentials</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
</dl>
</li>
</ul>
<a name="credentials-java.lang.String-java.lang.Runnable-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>credentials</h4>
<pre>public&nbsp;<a href="../../../../org/apache/storm/generated/Credentials.html" title="class in org.apache.storm.generated">Credentials</a>&nbsp;credentials(<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>&nbsp;stormId,
<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true" title="class or interface in java.lang">Runnable</a>&nbsp;callback)</pre>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#credentials-java.lang.String-java.lang.Runnable-">credentials</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
</dl>
</li>
</ul>
<a name="disconnect--">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>disconnect</h4>
<pre>public&nbsp;void&nbsp;disconnect()</pre>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#disconnect--">disconnect</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
</dl>
</li>
</ul>
<a name="getPrivateWorkerKey-org.apache.storm.generated.WorkerTokenServiceType-java.lang.String-long-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>getPrivateWorkerKey</h4>
<pre>public&nbsp;<a href="../../../../org/apache/storm/generated/PrivateWorkerKey.html" title="class in org.apache.storm.generated">PrivateWorkerKey</a>&nbsp;getPrivateWorkerKey(<a href="../../../../org/apache/storm/generated/WorkerTokenServiceType.html" title="enum in org.apache.storm.generated">WorkerTokenServiceType</a>&nbsp;type,
<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>&nbsp;topologyId,
long&nbsp;keyVersion)</pre>
<div class="block"><span class="descfrmTypeLabel">Description copied from interface:&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#getPrivateWorkerKey-org.apache.storm.generated.WorkerTokenServiceType-java.lang.String-long-">IStormClusterState</a></code></span></div>
<div class="block"><p>Get a private key used to validate a token is correct. This is expected to be called from a privileged daemon, and the ACLs should be set up to only allow nimbus and these privileged daemons access to these private keys.</p></div>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#getPrivateWorkerKey-org.apache.storm.generated.WorkerTokenServiceType-java.lang.String-long-">getPrivateWorkerKey</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>type</code> - the type of service the key is for.</dd>
<dd><code>topologyId</code> - the topology id the key is for.</dd>
<dd><code>keyVersion</code> - the version of the key this is for.</dd>
<dt><span class="returnLabel">Returns:</span></dt>
<dd>the private key or null if it could not be found.</dd>
</dl>
</li>
</ul>
<a name="addPrivateWorkerKey-org.apache.storm.generated.WorkerTokenServiceType-java.lang.String-long-org.apache.storm.generated.PrivateWorkerKey-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>addPrivateWorkerKey</h4>
<pre>public&nbsp;void&nbsp;addPrivateWorkerKey(<a href="../../../../org/apache/storm/generated/WorkerTokenServiceType.html" title="enum in org.apache.storm.generated">WorkerTokenServiceType</a>&nbsp;type,
<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>&nbsp;topologyId,
long&nbsp;keyVersion,
<a href="../../../../org/apache/storm/generated/PrivateWorkerKey.html" title="class in org.apache.storm.generated">PrivateWorkerKey</a>&nbsp;key)</pre>
<div class="block"><span class="descfrmTypeLabel">Description copied from interface:&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#addPrivateWorkerKey-org.apache.storm.generated.WorkerTokenServiceType-java.lang.String-long-org.apache.storm.generated.PrivateWorkerKey-">IStormClusterState</a></code></span></div>
<div class="block"><p>Store a new version of a private key. This is expected to only ever be called from nimbus. All ACLs however need to be setup to allow the given services access to the stored information.</p></div>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#addPrivateWorkerKey-org.apache.storm.generated.WorkerTokenServiceType-java.lang.String-long-org.apache.storm.generated.PrivateWorkerKey-">addPrivateWorkerKey</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>type</code> - the type of service this key is for.</dd>
<dd><code>topologyId</code> - the topology this key is for</dd>
<dd><code>keyVersion</code> - the version of the key this is for.</dd>
<dd><code>key</code> - the key to store.</dd>
</dl>
</li>
</ul>
<a name="getNextPrivateWorkerKeyVersion-org.apache.storm.generated.WorkerTokenServiceType-java.lang.String-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>getNextPrivateWorkerKeyVersion</h4>
<pre>public&nbsp;long&nbsp;getNextPrivateWorkerKeyVersion(<a href="../../../../org/apache/storm/generated/WorkerTokenServiceType.html" title="enum in org.apache.storm.generated">WorkerTokenServiceType</a>&nbsp;type,
<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>&nbsp;topologyId)</pre>
<div class="block"><span class="descfrmTypeLabel">Description copied from interface:&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#getNextPrivateWorkerKeyVersion-org.apache.storm.generated.WorkerTokenServiceType-java.lang.String-">IStormClusterState</a></code></span></div>
<div class="block"><p>Get the next key version number that should be used for this topology id. This is expected to only ever be called from nimbus, but it is acceptable if the ACLs are setup so that it can work from a privileged daemon for the given service.</p></div>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#getNextPrivateWorkerKeyVersion-org.apache.storm.generated.WorkerTokenServiceType-java.lang.String-">getNextPrivateWorkerKeyVersion</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>type</code> - the type of service this is for.</dd>
<dd><code>topologyId</code> - the topology id this is for.</dd>
<dt><span class="returnLabel">Returns:</span></dt>
<dd>the next version number. It should be 0 for a new topology id/service combination.</dd>
</dl>
</li>
</ul>
<a name="removeExpiredPrivateWorkerKeys-java.lang.String-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>removeExpiredPrivateWorkerKeys</h4>
<pre>public&nbsp;void&nbsp;removeExpiredPrivateWorkerKeys(<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>&nbsp;topologyId)</pre>
<div class="block"><span class="descfrmTypeLabel">Description copied from interface:&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#removeExpiredPrivateWorkerKeys-java.lang.String-">IStormClusterState</a></code></span></div>
<div class="block"><p>Remove all keys for the given topology that have expired. The number of keys should be small enough that doing an exhaustive scan of them all is acceptable as there is no guarantee that expiration time and version number are related. This should be for all service types. This is expected to only ever be called from nimbus and some ACLs may be setup so being called from other daemons will cause it to fail.</p></div>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#removeExpiredPrivateWorkerKeys-java.lang.String-">removeExpiredPrivateWorkerKeys</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>topologyId</code> - the id of the topology to scan.</dd>
</dl>
</li>
</ul>
<a name="removeAllPrivateWorkerKeys-java.lang.String-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>removeAllPrivateWorkerKeys</h4>
<pre>public&nbsp;void&nbsp;removeAllPrivateWorkerKeys(<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>&nbsp;topologyId)</pre>
<div class="block"><span class="descfrmTypeLabel">Description copied from interface:&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#removeAllPrivateWorkerKeys-java.lang.String-">IStormClusterState</a></code></span></div>
<div class="block"><p>Remove all of the worker keys for a given topology. Used to clean up after a topology finishes. This is expected to only ever be called from nimbus and ideally should only ever work from nimbus.</p></div>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#removeAllPrivateWorkerKeys-java.lang.String-">removeAllPrivateWorkerKeys</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>topologyId</code> - the topology to clean up after.</dd>
</dl>
</li>
</ul>
<a name="idsOfTopologiesWithPrivateWorkerKeys--">
<!-- -->
</a>
<ul class="blockListLast">
<li class="blockList">
<h4>idsOfTopologiesWithPrivateWorkerKeys</h4>
<pre>public&nbsp;<a href="https://docs.oracle.com/javase/8/docs/api/java/util/Set.html?is-external=true" title="class or interface in java.util">Set</a>&lt;<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>&gt;&nbsp;idsOfTopologiesWithPrivateWorkerKeys()</pre>
<div class="block"><span class="descfrmTypeLabel">Description copied from interface:&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#idsOfTopologiesWithPrivateWorkerKeys--">IStormClusterState</a></code></span></div>
<div class="block"><p>Get a list of all topologyIds that currently have private worker keys stored, of any kind. This is expected to only ever be called from nimbus.</p></div>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
<dd><code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html#idsOfTopologiesWithPrivateWorkerKeys--">idsOfTopologiesWithPrivateWorkerKeys</a></code>&nbsp;in interface&nbsp;<code><a href="../../../../org/apache/storm/cluster/IStormClusterState.html" title="interface in org.apache.storm.cluster">IStormClusterState</a></code></dd>
<dt><span class="returnLabel">Returns:</span></dt>
<dd>the list of topology ids with any kind of private worker key stored.</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/StormClusterStateImpl.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/cluster/StateStorageFactory.html" title="interface in org.apache.storm.cluster"><span class="typeNameLink">Prev&nbsp;Class</span></a></li>
<li><a href="../../../../org/apache/storm/cluster/VersionedData.html" title="class in org.apache.storm.cluster"><span class="typeNameLink">Next&nbsp;Class</span></a></li>
</ul>
<ul class="navList">
<li><a href="../../../../index.html?org/apache/storm/cluster/StormClusterStateImpl.html" target="_top">Frames</a></li>
<li><a href="StormClusterStateImpl.html" target="_top">No&nbsp;Frames</a></li>
</ul>
<ul class="navList" id="allclasses_navbar_bottom">
<li><a href="../../../../allclasses-noframe.html">All&nbsp;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:&nbsp;</li>
<li>Nested&nbsp;|&nbsp;</li>
<li>Field&nbsp;|&nbsp;</li>
<li><a href="#constructor.summary">Constr</a>&nbsp;|&nbsp;</li>
<li><a href="#method.summary">Method</a></li>
</ul>
<ul class="subNavList">
<li>Detail:&nbsp;</li>
<li>Field&nbsp;|&nbsp;</li>
<li><a href="#constructor.detail">Constr</a>&nbsp;|&nbsp;</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 &#169; 2022 <a href="https://www.apache.org/">The Apache Software Foundation</a>. All rights reserved.</small></p>
</body>
</html>