Uses of Interface
org.apache.storm.topology.BoltDeclarer

Packages that use BoltDeclarer

Package	Description
org.apache.storm.coordination
org.apache.storm.loadgen
org.apache.storm.topology
org.apache.storm.trident.topology

Uses of BoltDeclarer in org.apache.storm.coordination

Methods in org.apache.storm.coordination that return BoltDeclarer

Modifier and Type	Method	Description
BoltDeclarer	BatchSubtopologyBuilder.getMasterDeclarer()
BoltDeclarer	BatchSubtopologyBuilder.setBolt(String id, IBatchBolt bolt)
BoltDeclarer	BatchSubtopologyBuilder.setBolt(String id, IBatchBolt bolt, Number parallelism)
BoltDeclarer	BatchSubtopologyBuilder.setBolt(String id, IBasicBolt bolt)
BoltDeclarer	BatchSubtopologyBuilder.setBolt(String id, IBasicBolt bolt, Number parallelism)

Uses of BoltDeclarer in org.apache.storm.loadgen

Methods in org.apache.storm.loadgen with parameters of type BoltDeclarer

Modifier and Type	Method	Description
abstract void	GroupingType.assign(BoltDeclarer declarer, InputStream stream)

Uses of BoltDeclarer in org.apache.storm.topology

Classes in org.apache.storm.topology that implement BoltDeclarer

Modifier and Type	Class	Description
protected class	TopologyBuilder.BoltGetter

Methods in org.apache.storm.topology that return BoltDeclarer

Modifier and Type	Method	Description
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)

Uses of BoltDeclarer in org.apache.storm.trident.topology

Methods in org.apache.storm.trident.topology that return BoltDeclarer

Modifier and Type	Method	Description
BoltDeclarer	TridentTopologyBuilder.setBolt(String id, ITridentBatchBolt bolt, Integer parallelism, Set<String> committerBatches, Map<String,String> batchGroups)