| Package | Description |
|---|---|
| org.apache.storm | |
| org.apache.storm.generated |
| Modifier and Type | Method and Description |
|---|---|
static SpoutSpec |
Thrift.prepareSerializedSpoutDetails(IRichSpout spout,
Map<String,StreamInfo> outputs) |
| Modifier and Type | Method and Description |
|---|---|
SpoutSpec |
SpoutSpec.deepCopy() |
| Modifier and Type | Method and Description |
|---|---|
Map<String,SpoutSpec> |
StormTopology.get_spouts() |
| Modifier and Type | Method and Description |
|---|---|
int |
SpoutSpec.compareTo(SpoutSpec other) |
boolean |
SpoutSpec.equals(SpoutSpec that) |
void |
StormTopology.put_to_spouts(String key,
SpoutSpec val) |
| Modifier and Type | Method and Description |
|---|---|
void |
StormTopology.set_spouts(Map<String,SpoutSpec> spouts) |
| Constructor and Description |
|---|
SpoutSpec(SpoutSpec other)
Performs a deep copy on other.
|
| Constructor and Description |
|---|
StormTopology(Map<String,SpoutSpec> spouts,
Map<String,Bolt> bolts,
Map<String,StateSpoutSpec> state_spouts) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.