| 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.