backtype.storm.topology

Interface InputDeclarer<T extends InputDeclarer>

All Known Subinterfaces:

BoltDeclarer

All Known Implementing Classes:

BoltDeclarerImpl

public interface InputDeclarer<T extends InputDeclarer>

Method Summary

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