BoltDeclarer |
TopologyBuilder.BoltGetter.allGrouping(String componentId) |
|
BoltDeclarer |
TopologyBuilder.BoltGetter.allGrouping(String componentId,
String streamId) |
|
BoltDeclarer |
TopologyBuilder.BoltGetter.customGrouping(String componentId,
String streamId,
CustomStreamGrouping grouping) |
|
BoltDeclarer |
TopologyBuilder.BoltGetter.customGrouping(String componentId,
CustomStreamGrouping grouping) |
|
BoltDeclarer |
TopologyBuilder.BoltGetter.directGrouping(String componentId) |
|
BoltDeclarer |
TopologyBuilder.BoltGetter.directGrouping(String componentId,
String streamId) |
|
BoltDeclarer |
TopologyBuilder.BoltGetter.fieldsGrouping(String componentId,
String streamId,
Fields fields) |
|
BoltDeclarer |
TopologyBuilder.BoltGetter.fieldsGrouping(String componentId,
Fields fields) |
|
BoltDeclarer |
TopologyBuilder.BoltGetter.globalGrouping(String componentId) |
|
BoltDeclarer |
TopologyBuilder.BoltGetter.globalGrouping(String componentId,
String streamId) |
|
BoltDeclarer |
TopologyBuilder.BoltGetter.grouping(GlobalStreamId id,
Grouping grouping) |
|
BoltDeclarer |
TopologyBuilder.BoltGetter.localOrShuffleGrouping(String componentId) |
|
BoltDeclarer |
TopologyBuilder.BoltGetter.localOrShuffleGrouping(String componentId,
String streamId) |
|
BoltDeclarer |
TopologyBuilder.BoltGetter.noneGrouping(String componentId) |
|
BoltDeclarer |
TopologyBuilder.BoltGetter.noneGrouping(String componentId,
String streamId) |
|
BoltDeclarer |
TopologyBuilder.BoltGetter.partialKeyGrouping(String componentId,
String streamId,
Fields fields) |
|
BoltDeclarer |
TopologyBuilder.BoltGetter.partialKeyGrouping(String componentId,
Fields fields) |
|
BoltDeclarer |
TopologyBuilder.setBolt(String id,
SerializableBiConsumer<Tuple,BasicOutputCollector> biConsumer,
Number parallelismHint,
String... fields) |
Define a new bolt in this topology.
|
BoltDeclarer |
TopologyBuilder.setBolt(String id,
SerializableBiConsumer<Tuple,BasicOutputCollector> biConsumer,
String... fields) |
Define a new bolt in this topology.
|
BoltDeclarer |
TopologyBuilder.setBolt(String id,
SerializableConsumer<Tuple> consumer) |
Define a new bolt in this topology.
|
BoltDeclarer |
TopologyBuilder.setBolt(String id,
SerializableConsumer<Tuple> consumer,
Number parallelismHint) |
Define a new bolt in this topology.
|
BoltDeclarer |
TopologyBuilder.setBolt(String id,
IBasicBolt bolt) |
Define a new bolt in this topology.
|
BoltDeclarer |
TopologyBuilder.setBolt(String id,
IBasicBolt bolt,
Number parallelismHint) |
Define a new bolt in this topology.
|
BoltDeclarer |
TopologyBuilder.setBolt(String id,
IRichBolt bolt) |
Define a new bolt in this topology with parallelism of just one thread.
|
BoltDeclarer |
TopologyBuilder.setBolt(String id,
IRichBolt bolt,
Number parallelismHint) |
Define a new bolt in this topology with the specified amount of parallelism.
|
<T extends State> BoltDeclarer |
TopologyBuilder.setBolt(String id,
IStatefulBolt<T> bolt) |
Define a new bolt in this topology.
|
<T extends State> BoltDeclarer |
TopologyBuilder.setBolt(String id,
IStatefulBolt<T> bolt,
Number parallelismHint) |
Define a new bolt in this topology.
|
<T extends State> BoltDeclarer |
TopologyBuilder.setBolt(String id,
IStatefulWindowedBolt<T> bolt) |
Define a new bolt in this topology.
|
<T extends State> BoltDeclarer |
TopologyBuilder.setBolt(String id,
IStatefulWindowedBolt<T> bolt,
Number parallelismHint) |
Define a new bolt in this topology.
|
BoltDeclarer |
TopologyBuilder.setBolt(String id,
IWindowedBolt bolt) |
Define a new bolt in this topology.
|
BoltDeclarer |
TopologyBuilder.setBolt(String id,
IWindowedBolt bolt,
Number parallelismHint) |
Define a new bolt in this topology.
|
BoltDeclarer |
TopologyBuilder.BoltGetter.shuffleGrouping(String componentId) |
|
BoltDeclarer |
TopologyBuilder.BoltGetter.shuffleGrouping(String componentId,
String streamId) |
|