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.