backtype.storm.topology
Class TopologyBuilder.BoltGetter

java.lang.Object
  extended by backtype.storm.topology.BaseConfigurationDeclarer<T>
      extended by backtype.storm.topology.TopologyBuilder.ConfigGetter<BoltDeclarer>
          extended by backtype.storm.topology.TopologyBuilder.BoltGetter
All Implemented Interfaces:
BoltDeclarer, ComponentConfigurationDeclarer<BoltDeclarer>, InputDeclarer<BoltDeclarer>
Enclosing class:
TopologyBuilder

protected class TopologyBuilder.BoltGetter
extends TopologyBuilder.ConfigGetter<BoltDeclarer>
implements BoltDeclarer


Constructor Summary
TopologyBuilder.BoltGetter(java.lang.String boltId)
           
 
Method Summary
 BoltDeclarer allGrouping(java.lang.String componentId)
           
 BoltDeclarer allGrouping(java.lang.String componentId, java.lang.String streamId)
           
 BoltDeclarer customGrouping(java.lang.String componentId, CustomStreamGrouping grouping)
           
 BoltDeclarer customGrouping(java.lang.String componentId, java.lang.String streamId, CustomStreamGrouping grouping)
           
 BoltDeclarer directGrouping(java.lang.String componentId)
           
 BoltDeclarer directGrouping(java.lang.String componentId, java.lang.String streamId)
           
 BoltDeclarer fieldsGrouping(java.lang.String componentId, Fields fields)
           
 BoltDeclarer fieldsGrouping(java.lang.String componentId, java.lang.String streamId, Fields fields)
           
 BoltDeclarer globalGrouping(java.lang.String componentId)
           
 BoltDeclarer globalGrouping(java.lang.String componentId, java.lang.String streamId)
           
 BoltDeclarer grouping(GlobalStreamId id, Grouping grouping)
           
 BoltDeclarer noneGrouping(java.lang.String componentId)
           
 BoltDeclarer noneGrouping(java.lang.String componentId, java.lang.String streamId)
           
 BoltDeclarer shuffleGrouping(java.lang.String componentId)
           
 BoltDeclarer shuffleGrouping(java.lang.String componentId, java.lang.String streamId)
           
 
Methods inherited from class backtype.storm.topology.TopologyBuilder.ConfigGetter
addConfigurations
 
Methods inherited from class backtype.storm.topology.BaseConfigurationDeclarer
addConfiguration, setDebug, setMaxSpoutPending, setMaxTaskParallelism
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface backtype.storm.topology.ComponentConfigurationDeclarer
addConfiguration, addConfigurations, setDebug, setMaxSpoutPending, setMaxTaskParallelism
 

Constructor Detail

TopologyBuilder.BoltGetter

public TopologyBuilder.BoltGetter(java.lang.String boltId)
Method Detail

fieldsGrouping

public BoltDeclarer fieldsGrouping(java.lang.String componentId,
                                   Fields fields)
Specified by:
fieldsGrouping in interface InputDeclarer<BoltDeclarer>

fieldsGrouping

public BoltDeclarer fieldsGrouping(java.lang.String componentId,
                                   java.lang.String streamId,
                                   Fields fields)
Specified by:
fieldsGrouping in interface InputDeclarer<BoltDeclarer>

globalGrouping

public BoltDeclarer globalGrouping(java.lang.String componentId)
Specified by:
globalGrouping in interface InputDeclarer<BoltDeclarer>

globalGrouping

public BoltDeclarer globalGrouping(java.lang.String componentId,
                                   java.lang.String streamId)
Specified by:
globalGrouping in interface InputDeclarer<BoltDeclarer>

shuffleGrouping

public BoltDeclarer shuffleGrouping(java.lang.String componentId)
Specified by:
shuffleGrouping in interface InputDeclarer<BoltDeclarer>

shuffleGrouping

public BoltDeclarer shuffleGrouping(java.lang.String componentId,
                                    java.lang.String streamId)
Specified by:
shuffleGrouping in interface InputDeclarer<BoltDeclarer>

noneGrouping

public BoltDeclarer noneGrouping(java.lang.String componentId)
Specified by:
noneGrouping in interface InputDeclarer<BoltDeclarer>

noneGrouping

public BoltDeclarer noneGrouping(java.lang.String componentId,
                                 java.lang.String streamId)
Specified by:
noneGrouping in interface InputDeclarer<BoltDeclarer>

allGrouping

public BoltDeclarer allGrouping(java.lang.String componentId)
Specified by:
allGrouping in interface InputDeclarer<BoltDeclarer>

allGrouping

public BoltDeclarer allGrouping(java.lang.String componentId,
                                java.lang.String streamId)
Specified by:
allGrouping in interface InputDeclarer<BoltDeclarer>

directGrouping

public BoltDeclarer directGrouping(java.lang.String componentId)
Specified by:
directGrouping in interface InputDeclarer<BoltDeclarer>

directGrouping

public BoltDeclarer directGrouping(java.lang.String componentId,
                                   java.lang.String streamId)
Specified by:
directGrouping in interface InputDeclarer<BoltDeclarer>

customGrouping

public BoltDeclarer customGrouping(java.lang.String componentId,
                                   CustomStreamGrouping grouping)
Specified by:
customGrouping in interface InputDeclarer<BoltDeclarer>

customGrouping

public BoltDeclarer customGrouping(java.lang.String componentId,
                                   java.lang.String streamId,
                                   CustomStreamGrouping grouping)
Specified by:
customGrouping in interface InputDeclarer<BoltDeclarer>

grouping

public BoltDeclarer grouping(GlobalStreamId id,
                             Grouping grouping)
Specified by:
grouping in interface InputDeclarer<BoltDeclarer>