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 © 2019 The Apache Software Foundation. All rights reserved.