| Package | Description | 
|---|---|
| org.apache.storm | |
| org.apache.storm.clojure | |
| org.apache.storm.generated | |
| org.apache.storm.topology | 
| Modifier and Type | Method and Description | 
|---|---|
static StreamInfo | 
Thrift.directOutputFields(List<String> fields)  | 
static StreamInfo | 
Thrift.outputFields(List<String> fields)  | 
| Modifier and Type | Method and Description | 
|---|---|
static ComponentCommon | 
Thrift.prepareComponentCommon(Map<GlobalStreamId,Grouping> inputs,
                      Map<String,StreamInfo> outputs,
                      Integer parallelismHint)  | 
static ComponentCommon | 
Thrift.prepareComponentCommon(Map<GlobalStreamId,Grouping> inputs,
                      Map<String,StreamInfo> outputs,
                      Integer parallelismHint,
                      Map<String,Object> conf)  | 
static Bolt | 
Thrift.prepareSerializedBoltDetails(Map<GlobalStreamId,Grouping> inputs,
                            IBolt bolt,
                            Map<String,StreamInfo> outputs,
                            Integer parallelismHint,
                            Map<String,Object> conf)  | 
static SpoutSpec | 
Thrift.prepareSerializedSpoutDetails(IRichSpout spout,
                             Map<String,StreamInfo> outputs)  | 
| Constructor and Description | 
|---|
ClojureBolt(List fnSpec,
           List confSpec,
           List<Object> params,
           Map<String,StreamInfo> fields)  | 
ClojureSpout(List fnSpec,
            List confSpec,
            List<Object> params,
            Map<String,StreamInfo> fields)  | 
RichShellBolt(String[] command,
             Map<String,StreamInfo> outputs)  | 
RichShellSpout(String[] command,
              Map<String,StreamInfo> outputs)  | 
| Modifier and Type | Method and Description | 
|---|---|
StreamInfo | 
StreamInfo.deepCopy()  | 
| Modifier and Type | Method and Description | 
|---|---|
Map<String,StreamInfo> | 
ComponentCommon.get_streams()  | 
| Modifier and Type | Method and Description | 
|---|---|
int | 
StreamInfo.compareTo(StreamInfo other)  | 
boolean | 
StreamInfo.equals(StreamInfo that)  | 
void | 
ComponentCommon.put_to_streams(String key,
              StreamInfo val)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
ComponentCommon.set_streams(Map<String,StreamInfo> streams)  | 
| Constructor and Description | 
|---|
StreamInfo(StreamInfo other)
Performs a deep copy on other. 
 | 
| Constructor and Description | 
|---|
ComponentCommon(Map<GlobalStreamId,Grouping> inputs,
               Map<String,StreamInfo> streams)  | 
| Modifier and Type | Method and Description | 
|---|---|
Map<String,StreamInfo> | 
OutputFieldsGetter.getFieldsDeclaration()  | 
Copyright © 2022 The Apache Software Foundation. All rights reserved.