Uses of Interface
org.apache.storm.topology.BoltDeclarer
Package
Description
-
Uses of BoltDeclarer in org.apache.storm.coordination
Modifier and TypeMethodDescriptionBatchSubtopologyBuilder.getMasterDeclarer()
BatchSubtopologyBuilder.setBolt
(String id, IBatchBolt bolt) BatchSubtopologyBuilder.setBolt
(String id, IBatchBolt bolt, Number parallelism) BatchSubtopologyBuilder.setBolt
(String id, IBasicBolt bolt) BatchSubtopologyBuilder.setBolt
(String id, IBasicBolt bolt, Number parallelism) -
Uses of BoltDeclarer in org.apache.storm.loadgen
Modifier and TypeMethodDescriptionabstract void
GroupingType.assign
(BoltDeclarer declarer, InputStream stream) -
Uses of BoltDeclarer in org.apache.storm.topology
Modifier and TypeMethodDescriptionTopologyBuilder.BoltGetter.allGrouping
(String componentId) TopologyBuilder.BoltGetter.allGrouping
(String componentId, String streamId) TopologyBuilder.BoltGetter.customGrouping
(String componentId, String streamId, CustomStreamGrouping grouping) TopologyBuilder.BoltGetter.customGrouping
(String componentId, CustomStreamGrouping grouping) TopologyBuilder.BoltGetter.directGrouping
(String componentId) TopologyBuilder.BoltGetter.directGrouping
(String componentId, String streamId) TopologyBuilder.BoltGetter.fieldsGrouping
(String componentId, String streamId, Fields fields) TopologyBuilder.BoltGetter.fieldsGrouping
(String componentId, Fields fields) TopologyBuilder.BoltGetter.globalGrouping
(String componentId) TopologyBuilder.BoltGetter.globalGrouping
(String componentId, String streamId) TopologyBuilder.BoltGetter.grouping
(GlobalStreamId id, Grouping grouping) TopologyBuilder.BoltGetter.localOrShuffleGrouping
(String componentId) TopologyBuilder.BoltGetter.localOrShuffleGrouping
(String componentId, String streamId) TopologyBuilder.BoltGetter.noneGrouping
(String componentId) TopologyBuilder.BoltGetter.noneGrouping
(String componentId, String streamId) TopologyBuilder.BoltGetter.partialKeyGrouping
(String componentId, String streamId, Fields fields) TopologyBuilder.BoltGetter.partialKeyGrouping
(String componentId, Fields fields) TopologyBuilder.setBolt
(String id, SerializableBiConsumer<Tuple, BasicOutputCollector> biConsumer, Number parallelismHint, String... fields) Define a new bolt in this topology.TopologyBuilder.setBolt
(String id, SerializableBiConsumer<Tuple, BasicOutputCollector> biConsumer, String... fields) Define a new bolt in this topology.TopologyBuilder.setBolt
(String id, SerializableConsumer<Tuple> consumer) Define a new bolt in this topology.TopologyBuilder.setBolt
(String id, SerializableConsumer<Tuple> consumer, Number parallelismHint) Define a new bolt in this topology.TopologyBuilder.setBolt
(String id, IBasicBolt bolt) Define a new bolt in this topology.TopologyBuilder.setBolt
(String id, IBasicBolt bolt, Number parallelismHint) Define a new bolt in this topology.Define a new bolt in this topology with parallelism of just one thread.Define a new bolt in this topology with the specified amount of parallelism.<T extends State>
BoltDeclarerTopologyBuilder.setBolt
(String id, IStatefulBolt<T> bolt) Define a new bolt in this topology.<T extends State>
BoltDeclarerTopologyBuilder.setBolt
(String id, IStatefulBolt<T> bolt, Number parallelismHint) Define a new bolt in this topology.<T extends State>
BoltDeclarerTopologyBuilder.setBolt
(String id, IStatefulWindowedBolt<T> bolt) Define a new bolt in this topology.<T extends State>
BoltDeclarerTopologyBuilder.setBolt
(String id, IStatefulWindowedBolt<T> bolt, Number parallelismHint) Define a new bolt in this topology.TopologyBuilder.setBolt
(String id, IWindowedBolt bolt) Define a new bolt in this topology.TopologyBuilder.setBolt
(String id, IWindowedBolt bolt, Number parallelismHint) Define a new bolt in this topology.TopologyBuilder.BoltGetter.shuffleGrouping
(String componentId) TopologyBuilder.BoltGetter.shuffleGrouping
(String componentId, String streamId) -
Uses of BoltDeclarer in org.apache.storm.trident.topology