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 © 2022 The Apache Software Foundation. All rights reserved.