backtype.storm.topology
Interface InputDeclarer<T extends InputDeclarer>

All Known Subinterfaces:
BoltDeclarer
All Known Implementing Classes:
TopologyBuilder.BoltGetter

public interface InputDeclarer<T extends InputDeclarer>


Method Summary
 T allGrouping(java.lang.String componentId)
           
 T allGrouping(java.lang.String componentId, java.lang.String streamId)
           
 T customGrouping(java.lang.String componentId, CustomStreamGrouping grouping)
           
 T customGrouping(java.lang.String componentId, java.lang.String streamId, CustomStreamGrouping grouping)
           
 T directGrouping(java.lang.String componentId)
           
 T directGrouping(java.lang.String componentId, java.lang.String streamId)
           
 T fieldsGrouping(java.lang.String componentId, Fields fields)
           
 T fieldsGrouping(java.lang.String componentId, java.lang.String streamId, Fields fields)
           
 T globalGrouping(java.lang.String componentId)
           
 T globalGrouping(java.lang.String componentId, java.lang.String streamId)
           
 T grouping(GlobalStreamId id, Grouping grouping)
           
 T localOrShuffleGrouping(java.lang.String componentId)
           
 T localOrShuffleGrouping(java.lang.String componentId, java.lang.String streamId)
           
 T noneGrouping(java.lang.String componentId)
           
 T noneGrouping(java.lang.String componentId, java.lang.String streamId)
           
 T shuffleGrouping(java.lang.String componentId)
           
 T shuffleGrouping(java.lang.String componentId, java.lang.String streamId)
           
 

Method Detail

fieldsGrouping

T fieldsGrouping(java.lang.String componentId,
                 Fields fields)

fieldsGrouping

T fieldsGrouping(java.lang.String componentId,
                 java.lang.String streamId,
                 Fields fields)

globalGrouping

T globalGrouping(java.lang.String componentId)

globalGrouping

T globalGrouping(java.lang.String componentId,
                 java.lang.String streamId)

shuffleGrouping

T shuffleGrouping(java.lang.String componentId)

shuffleGrouping

T shuffleGrouping(java.lang.String componentId,
                  java.lang.String streamId)

localOrShuffleGrouping

T localOrShuffleGrouping(java.lang.String componentId)

localOrShuffleGrouping

T localOrShuffleGrouping(java.lang.String componentId,
                         java.lang.String streamId)

noneGrouping

T noneGrouping(java.lang.String componentId)

noneGrouping

T noneGrouping(java.lang.String componentId,
               java.lang.String streamId)

allGrouping

T allGrouping(java.lang.String componentId)

allGrouping

T allGrouping(java.lang.String componentId,
              java.lang.String streamId)

directGrouping

T directGrouping(java.lang.String componentId)

directGrouping

T directGrouping(java.lang.String componentId,
                 java.lang.String streamId)

customGrouping

T customGrouping(java.lang.String componentId,
                 CustomStreamGrouping grouping)

customGrouping

T customGrouping(java.lang.String componentId,
                 java.lang.String streamId,
                 CustomStreamGrouping grouping)

grouping

T grouping(GlobalStreamId id,
           Grouping grouping)