| Package | Description | 
|---|---|
| org.apache.storm.cluster | |
| org.apache.storm.generated | 
| Modifier and Type | Method and Description | 
|---|---|
StormBase | 
StormClusterStateImpl.stormBase(String stormId,
         Runnable callback)  | 
StormBase | 
IStormClusterState.stormBase(String stormId,
         Runnable callback)
Get a storm base for a topology. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
default Map<String,StormBase> | 
IStormClusterState.topologyBases()  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
StormClusterStateImpl.activateStorm(String stormId,
             StormBase stormBase,
             Map<String,Object> topoConf)  | 
void | 
IStormClusterState.activateStorm(String stormId,
             StormBase stormBase,
             Map<String,Object> topoConf)  | 
void | 
StormClusterStateImpl.updateStorm(String stormId,
           StormBase newElems)
To update this function due to APersistentMap/APersistentSet is clojure’s structure. 
 | 
void | 
IStormClusterState.updateStorm(String stormId,
           StormBase newElems)  | 
| Modifier and Type | Method and Description | 
|---|---|
StormBase | 
StormBase.deepCopy()  | 
| Modifier and Type | Method and Description | 
|---|---|
int | 
StormBase.compareTo(StormBase other)  | 
boolean | 
StormBase.equals(StormBase that)  | 
| Constructor and Description | 
|---|
StormBase(StormBase other)
Performs a deep copy on other. 
 | 
Copyright © 2022 The Apache Software Foundation. All rights reserved.