| Package | Description |
|---|---|
| org.apache.storm | |
| org.apache.storm.daemon | |
| org.apache.storm.generated |
| Modifier and Type | Method and Description |
|---|---|
static Bolt |
Thrift.prepareSerializedBoltDetails(Map<GlobalStreamId,Grouping> inputs,
IBolt bolt,
Map<String,StreamInfo> outputs,
Integer parallelismHint,
Map<String,Object> conf) |
| Modifier and Type | Method and Description |
|---|---|
static Map<String,Bolt> |
StormCommon.metricsConsumerBoltSpecs(Map<String,Object> conf,
StormTopology topology) |
| Modifier and Type | Method and Description |
|---|---|
Bolt |
Bolt.deepCopy() |
| Modifier and Type | Method and Description |
|---|---|
Map<String,Bolt> |
StormTopology.get_bolts() |
| Modifier and Type | Method and Description |
|---|---|
int |
Bolt.compareTo(Bolt other) |
boolean |
Bolt.equals(Bolt that) |
void |
StormTopology.put_to_bolts(String key,
Bolt val) |
| Modifier and Type | Method and Description |
|---|---|
void |
StormTopology.set_bolts(Map<String,Bolt> bolts) |
| Constructor and Description |
|---|
Bolt(Bolt 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.