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

Packages that use BoltDeclarer

Package	Description
org.apache.storm.coordination
org.apache.storm.topology
org.apache.storm.transactional
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 and Description
BoltDeclarer	BatchSubtopologyBuilder.getMasterDeclarer()
BoltDeclarer	BatchSubtopologyBuilder.setBolt(String id, IBasicBolt bolt)
BoltDeclarer	BatchSubtopologyBuilder.setBolt(String id, IBasicBolt bolt, Number parallelism)
BoltDeclarer	BatchSubtopologyBuilder.setBolt(String id, IBatchBolt bolt)
BoltDeclarer	BatchSubtopologyBuilder.setBolt(String id, IBatchBolt bolt, Number parallelism)

Uses of BoltDeclarer in org.apache.storm.topology

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

Modifier and Type	Class and Description
protected class	TopologyBuilder.BoltGetter

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

Modifier and Type	Method and Description
BoltDeclarer	TopologyBuilder.BoltGetter.allGrouping(String componentId)
BoltDeclarer	TopologyBuilder.BoltGetter.allGrouping(String componentId, String streamId)
BoltDeclarer	TopologyBuilder.BoltGetter.customGrouping(String componentId, CustomStreamGrouping grouping)
BoltDeclarer	TopologyBuilder.BoltGetter.customGrouping(String componentId, String streamId, CustomStreamGrouping grouping)
BoltDeclarer	TopologyBuilder.BoltGetter.directGrouping(String componentId)
BoltDeclarer	TopologyBuilder.BoltGetter.directGrouping(String componentId, String streamId)
BoltDeclarer	TopologyBuilder.BoltGetter.fieldsGrouping(String componentId, Fields fields)
BoltDeclarer	TopologyBuilder.BoltGetter.fieldsGrouping(String componentId, String streamId, 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, Fields fields)
BoltDeclarer	TopologyBuilder.BoltGetter.partialKeyGrouping(String componentId, String streamId, Fields fields)
BoltDeclarer	TopologyBuilder.setBolt(String id, IBasicBolt bolt) Define a new bolt in this topology.
BoltDeclarer	TopologyBuilder.setBolt(String id, IBasicBolt bolt, Number parallelism_hint) 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 parallelism_hint) 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 parallelism_hint) 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 parallelism_hint) 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 parallelism_hint) 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.transactional

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

Modifier and Type	Method and Description
BoltDeclarer	TransactionalTopologyBuilder.setBolt(String id, IBasicBolt bolt) Deprecated.
BoltDeclarer	TransactionalTopologyBuilder.setBolt(String id, IBasicBolt bolt, Number parallelism) Deprecated.
BoltDeclarer	TransactionalTopologyBuilder.setBolt(String id, IBatchBolt bolt) Deprecated.
BoltDeclarer	TransactionalTopologyBuilder.setBolt(String id, IBatchBolt bolt, Number parallelism) Deprecated.
BoltDeclarer	TransactionalTopologyBuilder.setCommitterBolt(String id, IBatchBolt bolt) Deprecated.
BoltDeclarer	TransactionalTopologyBuilder.setCommitterBolt(String id, IBatchBolt bolt, Number parallelism) Deprecated.

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

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

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