| Package | Description |
|---|---|
| org.apache.storm | |
| org.apache.storm.daemon | |
| org.apache.storm.generated | |
| org.apache.storm.scheduler.resource.normalization | |
| org.apache.storm.task | |
| org.apache.storm.utils |
| 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) |
| Modifier and Type | Method and Description |
|---|---|
static int |
Thrift.getParallelismHint(ComponentCommon componentCommon) |
| Modifier and Type | Method and Description |
|---|---|
static ComponentCommon |
StormCommon.getComponentCommon(Object component) |
| Modifier and Type | Method and Description |
|---|---|
ComponentCommon |
ComponentCommon.deepCopy() |
ComponentCommon |
SpoutSpec.get_common() |
ComponentCommon |
StateSpoutSpec.get_common() |
ComponentCommon |
Bolt.get_common() |
| Modifier and Type | Method and Description |
|---|---|
int |
ComponentCommon.compareTo(ComponentCommon other) |
boolean |
ComponentCommon.equals(ComponentCommon that) |
void |
SpoutSpec.set_common(ComponentCommon common) |
void |
StateSpoutSpec.set_common(ComponentCommon common) |
void |
Bolt.set_common(ComponentCommon common) |
| Constructor and Description |
|---|
Bolt(ComponentObject bolt_object,
ComponentCommon common) |
ComponentCommon(ComponentCommon other)
Performs a deep copy on other.
|
SpoutSpec(ComponentObject spout_object,
ComponentCommon common) |
StateSpoutSpec(ComponentObject state_spout_object,
ComponentCommon common) |
| Constructor and Description |
|---|
NormalizedResourceRequest(ComponentCommon component,
Map<String,Object> topoConf,
String componentId) |
| Modifier and Type | Method and Description |
|---|---|
ComponentCommon |
GeneralTopologyContext.getComponentCommon(String componentId) |
| Modifier and Type | Method and Description |
|---|---|
static ComponentCommon |
ThriftTopologyUtils.getComponentCommon(StormTopology topology,
String componentId) |
static ComponentCommon |
Utils.getComponentCommon(StormTopology topology,
String id) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.